MockNodeMessagingService

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

Constructors

Link copied to clipboard
constructor(configuration: <Error class: unknown class>, executor: <Error class: unknown class>, stateHelper: <Error class: unknown class> = ServiceStateHelper(log))

Properties

Link copied to clipboard
Link copied to clipboard
Link copied to clipboard

Functions

Link copied to clipboard
open fun addMessageHandler(topic: String, callback: <Error class: unknown class>): <Error class: unknown class>
Link copied to clipboard
open fun close()
Link copied to clipboard
open fun createMessage(topic: String, data: ByteArray, deduplicationId: <Error class: unknown class>, additionalHeaders: Map<String, String>): <Error class: unknown class>

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

Link copied to clipboard
open fun getAddressOfParty(partyInfo: <Error class: unknown class>): <Error class: unknown class>
Link copied to clipboard
Link copied to clipboard

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.

Link copied to clipboard
open fun removeMessageHandler(registration: <Error class: unknown class>)
Link copied to clipboard
open fun send(message: <Error class: unknown class>, target: <Error class: unknown class>, sequenceKey: Any)
Link copied to clipboard
open fun sendAll(addressedMessages: List<<Error class: unknown class>>)
Link copied to clipboard
open fun start()
fun start(network: InMemoryMessagingNetwork, manuallyPumped: Boolean, id: Int, notaryService: <Error class: unknown class>?)
Link copied to clipboard
open fun stop()