Java 类org.hamcrest.core.IsInstanceOf 实例源码

项目：orizuru-java 文件：MessageTest.java

@Test
public void decodeFromTransport_shouldThrowADecodeMessageExceptionWithAClassNotFoundExceptionIfTheMessageSchemaNameClassDoesNotExist()
        throws Exception {

    // expect
    exception.expect(DecodeMessageException.class);
    exception.expectMessage("Failed to consume message: Failed to decode message");
    exception.expectCause(IsInstanceOf.<Throwable>instanceOf(ClassNotFoundException.class));

    // given
    Transport transport = new Transport();
    transport.setMessageSchemaName("invalid");

    Message message = new Message();

    // when
    message.decodeFromTransport(transport);

}

项目：orizuru-java 文件：AbstractConsumerTest.java

@Test
public void consume_throwsAHandleMessageExceptionForAnInvalidMessage() throws Exception {

    // expect
    exception.expect(HandleMessageException.class);
    exception.expectMessage("Failed to consume message: Failed to handle message");
    exception.expectCause(IsInstanceOf.<Throwable>instanceOf(NullPointerException.class));

    // given
    byte[] body = VALID_MESSAGE.getBytes();

    IConsumer consumer = new ErrorConsumer(QUEUE_NAME);

    // when
    consumer.consume(body);

}

项目：orizuru-java 文件：AbstractConsumerTest.java

@Test
public void consume_throwsAHandleMessageExceptionWithAnAlteredInvalidMessage() throws Exception {

    // expect
    exception.expect(HandleMessageException.class);
    exception.expectMessage("Failed to consume message: Failed to handle message: test");
    exception.expectCause(IsInstanceOf.<Throwable>instanceOf(NullPointerException.class));

    // given
    byte[] body = VALID_MESSAGE.getBytes();

    IConsumer consumer = new ErrorConsumer2(QUEUE_NAME);

    // when
    consumer.consume(body);

}

项目：orizuru-java 文件：AbstractPublisherTest.java

@Test
public void publish_shouldThrowAnEncodeTransportExceptionForAnInvalidTransportMessage() throws Exception {

    // expect
    exception.expect(EncodeMessageContentException.class);
    exception.expectCause(IsInstanceOf.<Throwable>instanceOf(ClassCastException.class));
    exception.expectMessage("Failed to publish message: Failed to encode message content");

    // given
    Context context = mock(Context.class);
    when(context.getSchema())
            .thenReturn(new Schema.Parser().parse("{\"name\":\"test\",\"type\":\"record\",\"fields\":[]}"));
    when(context.getDataBuffer()).thenReturn(ByteBuffer.wrap("{}".getBytes()));

    GenericRecordBuilder builder = new GenericRecordBuilder(schema);
    builder.set("testString", Boolean.TRUE);
    Record record = builder.build();

    // when
    publisher.publish(context, record);

}

项目：orizuru-java 文件：AbstractPublisherTest.java

@Test
public void publish_shouldThrowAnEncodeTransportExceptionForAnInvalidTransportContext() throws Exception {

    // expect
    exception.expect(EncodeTransportException.class);
    exception.expectCause(IsInstanceOf.<Throwable>instanceOf(NullPointerException.class));
    exception.expectMessage("Failed to publish message: Failed to encode transport");

    // given
    Context context = mock(Context.class);
    when(context.getSchema())
            .thenReturn(new Schema.Parser().parse("{\"name\":\"test\",\"type\":\"record\",\"fields\":[]}"));
    when(context.getDataBuffer()).thenReturn(null);

    GenericRecordBuilder builder = new GenericRecordBuilder(schema);
    builder.set("testString", "testString");
    Record record = builder.build();

    // when
    publisher.publish(context, record);

}

项目：oscm 文件：RestTriggerResourceTest.java

@Test
public void testAction() throws Exception {
    RestTriggerResource.Action action = new RestTriggerResource()
            .redirectToAction();

    RequestParameters params = new RequestParameters();
    params.setId(1L);

    UriInfo uri = Mockito.mock(UriInfo.class);
    MultivaluedMap<String, String> map = new MultivaluedHashMap<>();
    map.putSingle(PARAM_VERSION, "v" + VERSION_1);
    when(uri.getPathParameters()).thenReturn(map);

    Response response = action.getCollection(uri, params);
    assertThat(response.getEntity(),
            IsInstanceOf.instanceOf(RepresentationCollection.class));

    assertNull(action.getItem(uri, params));
}

项目：cdversion-maven-extension 文件：CDVersionLifecycleParticipantTest.java

@Test
public void testAfterSessionStart_nullRevision()
        throws MavenExecutionException,
        RevisionGeneratorException {
    String revision = null;
    exceptions.expect(MavenExecutionException.class);
    exceptions.expectMessage("RevisionGenerator returned a null revision value");
    exceptions.expectCause(IsInstanceOf.any(RevisionGeneratorException.class));
    when(revisionGenerator.getRevision()).thenReturn(revision);

    try {
        item.afterSessionStart(session);
    } finally {
        verify(revisionGenerator).init(eq(session), any(Logger.class));
        verify(revisionGenerator).getRevision();
        verifyNoMoreInteractions(revisionGenerator);
        verifyZeroInteractions(session);
        verifyZeroInteractions(pluginMerger);
        verifyZeroInteractions(plugins);
    }
}