docs/net.corda.testing.node.internal/MockNodeMessagingService

MockNodeMessagingService

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

Constructors

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

Properties

myAddress

open val myAddress: InMemoryMessagingNetwork.PeerHandle

ourSenderUUID

open val ourSenderUUID: String

spy

var spy: MessagingServiceSpy?

Functions

addMessageHandler

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

open fun close()

createMessage

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.

getAddressOfParty

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

hasPendingDeliveries

fun hasPendingDeliveries(): Boolean

pumpReceive

fun pumpReceive(block: Boolean): InMemoryMessagingNetwork.MessageTransfer?

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.

removeMessageHandler

open fun removeMessageHandler(registration: <Error class: unknown class>)

send

open fun send(message: <Error class: unknown class>, target: <Error class: unknown class>, sequenceKey: Any)

sendAll

open fun sendAll(addressedMessages: List<<Error class: unknown class>>)

start

open fun start()

fun start(network: InMemoryMessagingNetwork, manuallyPumped: Boolean, id: Int, notaryService: <Error class: unknown class>?)

stop

open fun stop()