/
JMS file sender with headers
25 lines (22 loc) · 1.23 KB
/
JMS file sender with headers
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
importPackage(Packages.org.apache.activemq);
importPackage(Packages.javax.jms);
try {
var connectionFactory = new ActiveMQConnectionFactory("tcp://someActiveMQServer:61616");
var connection = connectionFactory.createConnection();
connection.start();
var session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
var destination = session.createQueue("DestinationQueue");
var producer = session.createProducer(destination);
producer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
var text = $('someJsonObject');
var message = session.createTextMessage(text);
//Setting a property on the message(message is a data type in activemq, not just a string), not currently supported by mirth connect natively
//https://activemq.apache.org/maven/apidocs/org/apache/activemq/command/Message.html
message.setType("someType");
producer.send(message);
session.close();
connection.close();
}
catch (e) {
logger.error(e.printStackTrace());
}