Details
Description
Configure broker transport connector like this:
<transportConnector name="amqpws" uri="ws://0.0.0.0:5680?amqp.traceFrames=true&wireFormat=amqp&wireFormat.transformer=jms&wireFormat.allowNonSaslConnections=true"/>
Try to connect to this instance with rhea.js library.
First attempt to connect would be successful.
Second and all subsequent attempts would fail.
The only way to "fix" this would be a broker restart.
The issue is here:
https://github.com/apache/activemq/blob/4bbb055187166706103d785e9665efb439792c51/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/WSServlet.java#L162
transportOptions would be "consumed" by introspection on the first connection attempt, and on subsequent attempts "allowNonSaslConnections" and "transformer" would not be there, so won't be applied to wireformat and the result would be an error.
Interestingly this was already spotted and fixed in the same class for MQTT subprotocol here:
https://github.com/apache/activemq/blob/4bbb055187166706103d785e9665efb439792c51/activemq-http/src/main/java/org/apache/activemq/transport/ws/jetty9/WSServlet.java#L115C86-L115C86
by simply creating a copy of transport options before sending it into introspecting setters.
Please apply the same fix.