Skip to content

Commit

Permalink
Minor changes
Browse files Browse the repository at this point in the history
  • Loading branch information
Qingyixia committed Feb 9, 2023
1 parent 9ba48bf commit c056aeb
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -208,6 +208,7 @@ public void testMessageSubscriber_PermitsInterceptorsToModifyOutgoingEnvelope()
});
when(myInterceptorBroadcaster.callHooks(eq(Pointcut.SUBSCRIPTION_AFTER_MESSAGE_DELIVERY), any())).thenReturn(false);
when(myChannelFactory.getOrCreateProducer(any(), any(), any())).thenReturn(myChannelProducer);
when(myDaoRegistry.getResourceDao(anyString())).thenReturn(myResourceDao);

CanonicalSubscription subscription = generateSubscription();
Patient patient = generatePatient();
Expand Down Expand Up @@ -345,6 +346,7 @@ public void testDeliveryMessageWithPartition() throws URISyntaxException {
when(myInterceptorBroadcaster.callHooks(eq(Pointcut.SUBSCRIPTION_BEFORE_MESSAGE_DELIVERY), any())).thenReturn(true);
when(myInterceptorBroadcaster.callHooks(eq(Pointcut.SUBSCRIPTION_AFTER_MESSAGE_DELIVERY), any())).thenReturn(false);
when(myChannelFactory.getOrCreateProducer(any(), any(), any())).thenReturn(myChannelProducer);
when(myDaoRegistry.getResourceDao(anyString())).thenReturn(myResourceDao);

CanonicalSubscription subscription = generateSubscription();
Patient patient = generatePatient();
Expand Down

0 comments on commit c056aeb

Please sign in to comment.