Need guidance on how we can connect to Azure service bus and able to send the message to ASB queue through JMSSender as one of the destination

[gpatil-github]

Describe the bug
Recently we are trying to move from ActiveMQ to Azure Service bus. In current ActiveMQ config we have a JMSSender configured with destination as one of the queue and specified below properties in channel destination:

1. Connection Factory class: org.apache.activemq.ActiveMQConnectionFactory
2. connection properties: brokerURL, useCompression and closeTimeout
3. specified queue and its name
   This is working fine with lib active-all jar added in custom-lib directory.

But when we are trying to do the same for Azure Service bus its failing with below error:
ERROR 2024-05-14 10:19:12.352 [JMS Sender Process Thread on HL7 Default JMS - ASB (80738b92-2a61-44e2-854a-65e1c9acd02f), Destination 1 (1)] com.mirth.connect.connectors.jms.JmsDispatcher: An error occurred in channel "HL7 Default JMS - ASB": This ServiceBusJmsConnectionFactory object is not initialized with the proper parameters. java.lang.RuntimeException: This ServiceBusJmsConnectionFactory object is not initialized with the proper parameters. at com.microsoft.azure.servicebus.jms.ServiceBusJmsConnectionFactory.ensureInitialized(ServiceBusJmsConnectionFactory.java:393) ~[azure-servicebus-jms-1.0.2.jar:?] at com.microsoft.azure.servicebus.jms.ServiceBusJmsConnectionFactory.createConnection(ServiceBusJmsConnectionFactory.java:240) ~[azure-servicebus-jms-1.0.2.jar:?] at com.mirth.connect.connectors.jms.JmsDispatcher.getJmsConnection(JmsDispatcher.java:291) ~[jms-server.jar:?] at com.mirth.connect.connectors.jms.JmsDispatcher.send(JmsDispatcher.java:141) ~[jms-server.jar:?] at com.mirth.connect.donkey.server.channel.DestinationConnector.handleSend(DestinationConnector.java:904) ~[donkey-server.jar:?] at com.mirth.connect.donkey.server.channel.DestinationConnector.process(DestinationConnector.java:527) ~[donkey-server.jar:?] at com.mirth.connect.donkey.server.channel.DestinationChain.doCall(DestinationChain.java:122) ~[donkey-server.jar:?] at com.mirth.connect.donkey.server.channel.DestinationChain.call(DestinationChain.java:64) ~[donkey-server.jar:?] at com.mirth.connect.donkey.server.channel.Channel.process(Channel.java:1850) ~[donkey-server.jar:?] at com.mirth.connect.donkey.server.channel.Channel.dispatchRawMessage(Channel.java:1302) ~[donkey-server.jar:?] at com.mirth.connect.donkey.server.channel.SourceConnector.dispatchRawMessage(SourceConnector.java:194) ~[donkey-server.jar:?] at com.mirth.connect.server.controllers.DonkeyEngineController.dispatchRawMessage(DonkeyEngineController.java:1145) ~[mirth-server.jar:?] at com.mirth.connect.server.controllers.DonkeyMessageController.reprocessMessages(DonkeyMessageController.java:449) ~[mirth-server.jar:?] at com.mirth.connect.server.api.servlets.MessageServlet$1.run(MessageServlet.java:224) ~[mirth-server.jar:?] at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_282]

To Reproduce
Steps to reproduce the behavior:

1. Add below jars under custom-lib directory: azure-core-1.49.0.jar, azure-servicebus-jms-1.0.2.jar, javax.jms-api-2.0.1.jar
2. redeploy the channel try to process a message
3. specified below properties in channel destination:
4. Connection Factory class: com.microsoft.azure.servicebus.jms.ServiceBusJmsConnectionFactory
5. connection properties: brokerURL as ConnectionString, useCompression and closeTimeout
6. specified queue and its name

Expected behavior
Looking for a way configure a JMSSender which can send the message to ASB queue

Environment (please complete the following information):

• OS: Linux (CentOS)
• Java Distribution/Version -> Java 8
• Connect Version [e.g. 4.4.2]

[pacmano1]

@gpatil-github - moving this to discussions. You are asking a "How To" here.

[ab-mg-23]

Looking at the source for ServiceBusJmsConnectionFactory, it wants to be instantiated with one of the non-empty constructors. Those will call one of the initalizeWithXXX methods that sets up the connection factory. When Mirth creates the ConnectionFactory in the JmsDispatcher it uses the empty constructor before then using BeanUtils to reflectively set properties on the connection factory. So off the top of my head two options are:

1. Use a JavaScript writer and write the code to build the ConnectionFactory and send the message. It will be dog slow if you can't find a way to cache the ConnectionFactory and/or Connections.

2. Write a light Java class that implements the ConnectionFactory interface and delegates to ServiceBusJmsConnectionFactory. Then you can make calls to the non-empty constructors in createConnection() and just delegate results to-and-fro.

[gpatil-github]

Thanks for the prompt reply!

For option 1, Azure have support with nodejs please see (https://learn.microsoft.com/en-us/azure/service-bus-messaging/service-bus-nodejs-how-to-use-queues?tabs=connection-string). Can I get a guidance that how do we use the in mirth context?

For Option 2, We are not inclined towards more as it involves maintenance aspect of custom jar and the jars used for building the custom jar.

[ab-mg-23]

Mirth Connect uses Rhino for it's JavaScript runtime, not Node.js. What I was describing re: option 1 would look something like this:

importPackage(com.azure.servicebus.jms);

var conSettings = new ServiceBusJmsConnectionFactorySettings();
var conFactory = new ServiceBusJmsConnectionFactory("connection_url_goes_here",conSettings);
var con = conFactory.createConnection();
... 

Ultimately that code is calling into the ASB JMS API through the Rhino bridge to Java.

[gpatil-github]

Currently in our setup we have a channel configured as HTTP Receiver which is of type HTTPListener with request Body as Plain/Text type.

Suppose it receives the message without new line delimiter, does it add delimiter after each segment like MSH, PID, PV1 etc?

Because right now the sample message its receiving is without delimiter but when we look at the Source in Mirth Connect it looks properly formatted with new line delimiter.

[pacmano1]

Is this related to your initial post/question here?

[gpatil-github]

Yeah, we have created a new in-house component which receives the same HL7 Message which in current setup Mirth Connect receives but the content we are receiving on in-house component doesn't contain newline delimiter in it and which is causing some issues at our end.

And same message in current setup with MirthConnect works fine without any issues. So, trying to understand is there anything extra internally happening with HTTP Listener on MirthConnect side in order to process the same message.