Hello,
I am trying to create/send a message to a topic.
For this I'm using Java/Kotlin with
https://qpid.apache.org/releases/qpid-protonj2-1.0.0-M1
Target-Broker: ActiveMQ v5.15.15
Target-URL:
amqp+ssl://b-xxxxxxxx-xxxx-4xxx-xxxx-xxxxxxxxxxxxx-1.mq.eu-central-1.amazonaws.com:5671
On ActiveMQ the access is restricted to users, but they are currently allowed
to create a topic: <authorizationEntry admin="myUserName" read="myUserName"
topic=">" write="myUserName"/>
-----------8<---------------------------
val client = Client.create(ClientOptions().id("myClientId"))
val options = ConnectionOptions()
options.user("myUserName")
options.password("myPassword")
options.reconnectEnabled(true)
options.sslEnabled(true)
// options.saslOptions().saslEnabled(true)
// options.saslOptions().addAllowedMechanism("PLAIN")
val connection =
client.connect("b-xxxxxxxx-xxxx-4xxx-xxxx-xxxxxxxxxxxxx-1.mq.eu-central-1.amazonaws.com",
5671, options)
val session = connection.openSession()
val sender = session.openSender("topic://myTopic")
----------->8---------------------------
With SSL only (as above) I get:
-----------8<---------------------------
[org.apache.qpid.protonj2.client.impl.ClientTransportListener]
(ClientConnection :(ID:xxxx:1:1): I/O Thread) Caught problem during incoming
data processing: Received SASL Header but no SASL support configured:
org.apache.qpid.protonj2.engine.exceptions.EngineFailedException: Received SASL
Header but no SASL support configured
----------->8---------------------------
With SSL + SASL:
-----------8<---------------------------
[org.apache.qpid.protonj2.client.impl.ClientConnection] (ClientConnection
:(ID:xxxx:1:1): I/O Thread) Connection ID:xxxx:1:1 has failed due to:
ClientConnectionSecuritySaslException -> SASL exchange failed to authenticate
client
[org.apache.qpid.protonj2.client.impl.ClientTransportListener]
(ClientConnection :(ID:xxxx:1:1): I/O Thread) Caught problem during incoming
data processing: Cannot ingest data into an Engine that has been shutdown or
failed: org.apache.qpid.protonj2.engine.exceptions.EngineFailedException:
Cannot ingest data into an Engine that has been shutdown or failed
----------->8---------------------------
What do I need to do to connect to ActiveMQ in AWS?
Best Regards,
Peter
