com.r3corda.node.services.messaging / ArtemisMessagingClient / <init>

<init>

ArtemisMessagingClient(directory: Path, config: NodeConfiguration, serverHostPort: <ERROR CLASS>, myHostPort: <ERROR CLASS>, defaultExecutor: Executor = RunOnCallerThread)

This class implements the MessagingService API using Apache Artemis, the successor to their ActiveMQ product. Artemis is a message queue broker and here we run a client connecting to the specified broker instance ArtemisMessagingServer

Parameters

serverHostPort - The address of the broker instance to connect to (might be running in the same process)

myHostPort - What host and port to use as an address for incoming messages

defaultExecutor - This will be used as the default executor to run message handlers on, if no other is specified.