@Before
messenger = mock(Messenger.class);
T message = mock(Message.class);
when(message.getCorrelationId()).thenReturn(Randoms.alphanumeric("correlationId_"));
when(context.getMessage()).thenReturn(message);
@Test
public void handleEvent_forTerminationStartedEventWitOnlyRxConnection_aReleaseConnectionRequestIsSentForTheRxConnection() {
// given
String outgoingRequestId = whenMessenger(messenger) <-- this is line 73
.sendRequest(ReleaseConnectionRequest.class)
.to(MediaGraphServiceReference.PSI_ADDRESS)
.withCorrelationIdFromExecutionContext()
.thenReturnRandomRequestId();
// ...
}
protected OngoingMessengerStubbing whenMessenger(final Messenger messenger) {
return new OngoingMessengerStubbing(messenger, context);
}
public OngoingMessengerSendRequestStubbing sendRequest(final Class<? extends Request> requestClazz) {
return new OngoingMessengerSendRequestStubbing(context, messenger, any(requestClazz)); <-- this is line 35
}
import static org.mockito.Matchers.anyString;
import static org.mockito.Matchers.eq;
public class OngoingMessengerSendRequestStubbing {
private final ExecutionContext context;
private final Messenger messenger;
private final Request request;
private PsiAddress destination;
private String correlationId;
private boolean sendToSelf;
public OngoingMessengerSendRequestStubbing(
final ExecutionContext context,
final Messenger messenger,
final Request request) {
this.context = context;
this.messenger = messenger;
this.request = request;
}
public OngoingMessengerSendRequestStubbing withCorrelationId(final String theCorrelationId) {
this.correlationId = eq(theCorrelationId);
return this;
}
public OngoingMessengerSendRequestStubbing withCorrelationIdFromExecutionContext() {
if (context.getMessage() == null) {
throw new IllegalStateException("Message in context is null!"); <-- This is line 56
}
String id = context.getMessage().getCorrelationId();
this.correlationId = eq(id);
return this;
}
public OngoingMessengerSendRequestStubbing to(final PsiAddress theDestination) {
this.destination = eq(theDestination); <-- this is line 68
return this;
}
public OngoingMessengerSendRequestStubbing toSelf() {
this.sendToSelf = true;
return this;
}
public String thenReturnRandomRequestId() {
String requestId = Randoms.alphanumeric("reqId_");
setupMessengerToReturnRequestIdOnSend(requestId);
return requestId;
}
private void setupMessengerToReturnRequestIdOnSend(final String requestId) {
if (!sendToSelf) {
Mockito.when(messenger.send(destination, correlationId, request)).thenReturn(requestId);
} else {
Mockito.when(messenger.sendToSelf(correlationId, request)).thenReturn(requestId);
}
}
}
--
You received this message because you are subscribed to the Google Groups "mockito" group.
To unsubscribe from this group and stop receiving emails from it, send an email to mockito+u...@googlegroups.com.
To post to this group, send email to moc...@googlegroups.com.
Visit this group at http://groups.google.com/group/mockito.
For more options, visit https://groups.google.com/d/optout.