How to Receive a Message from an Apache ActiveMQ Queue with Jython

from javax.jms import Session

from org.apache.activemq import ActiveMQConnectionFactory

connFactory = ActiveMQConnectionFactory()

conn = connFactory.createConnection()

sess = conn.createSession(False, Session.AUTO_ACKNOWLEDGE)

dest = sess.createQueue('SampleQueue')

cons = sess.createConsumer(dest)

conn.start()

msg = cons.receive()

print(msg)

conn.close()

Leave a Reply

Fill in your details below or click an icon to log in:

WordPress.com Logo

You are commenting using your WordPress.com account. Log Out / Change )

Twitter picture

You are commenting using your Twitter account. Log Out / Change )

Facebook photo

You are commenting using your Facebook account. Log Out / Change )

Google+ photo

You are commenting using your Google+ account. Log Out / Change )

Connecting to %s