Constructor Detail

• MockNodeMessagingService

  MockNodeMessagingService(<Error class: unknown class> configuration, <Error class: unknown class> executor, <Error class: unknown class> stateHelper)

Method Detail

• getOurSenderUUID

   String getOurSenderUUID()

• getMyAddress

   InMemoryMessagingNetwork.PeerHandle getMyAddress()

• getSpy

   final MessagingServiceSpy getSpy()

• setSpy

   final Unit setSpy(MessagingServiceSpy spy)

• start

   Unit start()

• start

   final Unit )>start(InMemoryMessagingNetwork network, Boolean manuallyPumped, Integer id, <Error class: unknown class> notaryService)

  Parameters:

  manuallyPumped - if set to true, then you are expected to call MockNodeMessagingService.pumpReceive in order to cause the delivery of a single message, which will occur on the thread of the caller.

  id - the numeric ID to use, e.g.

• stop

   Unit stop()

• getAddressOfParty

   <Error class: unknown class> )>getAddressOfParty(<Error class: unknown class> partyInfo)

• addMessageHandler

   <Error class: unknown class> )>addMessageHandler(String topic, <Error class: unknown class> callback)

• removeMessageHandler

   Unit )>removeMessageHandler(<Error class: unknown class> registration)

• send

   Unit ,.,java.lang.Object)>send(<Error class: unknown class> message, <Error class: unknown class> target, Object sequenceKey)

• sendAll

   Unit sendAll(List<<Error class: unknown class>> addressedMessages)

• close

   Unit close()

• createMessage

   <Error class: unknown class> ,java.util.Map)>createMessage(String topic, ByteArray data, <Error class: unknown class> deduplicationId, Map<String, String> additionalHeaders)

  Returns the given (topic & session, data) pair as a newly created message object.

• pumpReceive

   final InMemoryMessagingNetwork.MessageTransfer pumpReceive(Boolean block)

  Delivers a single message from the internal queue. If there are no messages waiting to be delivered and block is true, waits until one has been provided on a different thread via send. If block is false, the return result indicates whether a message was delivered or not.

• hasPendingDeliveries

   final Boolean hasPendingDeliveries()