class ArtemisMessagingServer : ArtemisMessagingComponent
This class configures and manages an Apache Artemis message queue broker.
Nodes communication is managed using an Artemis specific protocol, but it supports other protocols like AMQP/1.0 as well for interop.
The current implementation is skeletal and lacks features like security or firewall tunnelling (that is, you must be able to receive TCP connections in order to receive messages). It is good enough for local communication within a fully connected network, trusted network or on localhost.
NodeLoginModule |
class NodeLoginModule : LoginModule |
<init> |
ArtemisMessagingServer(config: NodeConfiguration, myHostPort: <ERROR CLASS>, networkMapCache: NetworkMapCache, userService: RPCUserService) This class configures and manages an Apache Artemis message queue broker. |
config |
val config: NodeConfiguration The config object is used to pass in the passwords for the certificate KeyStore and TrustStore |
myHostPort |
val myHostPort: <ERROR CLASS> |
networkMapCache |
val networkMapCache: NetworkMapCache |
userService |
val userService: RPCUserService |
bridgeToNetworkMapService |
fun bridgeToNetworkMapService(networkMapService: SingleMessageRecipient?): Unit |
start |
fun start(): Unit |
stop |
fun stop(): Unit |
checkStorePasswords |
fun checkStorePasswords(): Unit Returns nothing if the keystore was opened OK or throws if not. Useful to check the password, as unfortunately Artemis tends to bury the exception when the password is wrong. |
configureWithDevSSLCertificate |
fun configureWithDevSSLCertificate(): Unit |
expectedOnDefaultFileSystem |
fun Path.expectedOnDefaultFileSystem(): Unit |
parseKeyFromQueueName |
fun parseKeyFromQueueName(name: String): PublicKey |
tcpTransport |
fun tcpTransport(direction: ConnectionDirection, host: String, port: Int): <ERROR CLASS> |