[TechCorner Challenge #10] Connecting to JMS using Groovy script

Task: write a script for the Groovy Script test step which creates a connection to a JMS provider (ActiveMQ, WebSphere or another), sends a JMS message to the “Test“ queue, and shows all messages in this queue.

This is a solution created for [TechCorner Challenge #10]

Okay, that's what I thought too nmrao. I am just not certain how to actually tie in to the JMS server connection as entered into the "JMS" connection panel. I do have a script that does everything by hand though. Which is as below. This does require the ActiveMQ client jar placed in the appropriate lib folder in ReadAPI install.

This script browses a queue, per the requirements of the task. It will NOT consume messages from a queue.

package org.apache.activemq.simple;

import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;


def queueNames = ["Test"];
def msgToSend = 10;
def msgCount = 0;
def user = "username"
def pass = "password"
def host = "tcp://x.x.x.x:61616"

// Write to Queue
for (queueName in queueNames)
{
	ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, pass, host);

	Connection connection = connectionFactory.createConnection();
	connection.start();

	Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
	Destination dest = session.createQueue(queueName);
	MessageProducer prod = session.createProducer(dest);
	
	for (int i = 1; i <= msgToSend; i++)
	{
		
		def messageText = "This is message $i." 
		TextMessage message = session.createTextMessage(messageText);
		prod.send(message);
	}
	prod.close()
	
	QueueBrowser qb = session.createBrowser(dest);
	Enumeration msgs = qb.getEnumeration();
	if (!msgs.hasMoreElements())
	{
		log.info("Queue is empty.")
	}
	else
	{
		while (msgs.hasMoreElements())
		{
			Message tempMsg = (Message)msgs.nextElement();
			log.info(tempMsg);
			msgCount++
		}
	}
	qb.close();
	session.close();
	connection.close();
}
log.info("Messages sent: $msgToSend. Messages browsed: $msgCount.");

System.gc();
System.sleep(1000);

This script CONSUMES messages, use at your own risk. Still a worthwhile example, in my opinion.

package org.apache.activemq.simple;

import javax.jms.*;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.command.ActiveMQQueue;


// For multiple queues
def queueNames = ["Test"];

// Configurable messages to send
def msgToSend = 10;

// Keep track of how many are read
def msgCount = 0;

// ActiveMQ connection information
def user = "userName"
def pass = "P@ssw0rd100$"
def host = "tcp://x.x.x.x:61616"

// Write to / Read From Queue
for (queueName in queueNames)
{
	// Create ActiveMQ connection, session, destination, and producer.
	ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(user, pass, host);

	Connection connection = connectionFactory.createConnection();
	connection.start();

	Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
	Destination dest = session.createQueue(queueName);
	MessageProducer prod = session.createProducer(dest);
	
	// Send messages
	for (int i = 1; i <= msgToSend; i++)
	{
		def messageText = "This is message $i." 
		TextMessage message = session.createTextMessage(messageText);
		prod.send(message);
	}
	// Close producer.
	prod.close()
	
	//Create consumer.
	MessageConsumer consumer = session.createConsumer(dest);
	Message message = consumer.receive(5000);
	while (message != null)
	{
		msgCount++;
		message = consumer.receive(5000);
	}
	// Close consumer, session, and connection.
	consumer.close();
	session.close();
	connection.close();
}

log.info("Messages sent: $msgToSend. Messages received: $msgCount.");