How to Receive a Message from an Apache ActiveMQ Queue with OCaml-Java

open Java

open JavaString

open Package'java'io

open Package'javax'jms

open Package'org'apache'activemq

let conn_factory = Java.make "ActiveMQConnectionFactory()" ()

let conn = call "ConnectionFactory.createConnection()" conn_factory

let sess = call "Connection.createSession(boolean, int)" conn false (get "Session.AUTO_ACKNOWLEDGE" ())

let dest = call "Session.createQueue(String)" sess (of_string "SampleQueue")

let cons = call "Session.createConsumer(Destination)" sess dest

let _ = call "Connection.start()" conn

let msg = call "MessageConsumer.receive()" cons

let _ = call "PrintStream.println(Object)" (get "System.out" ()) msg

let _ = call "Connection.close()" conn
Advertisements

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 )

Google photo

You are commenting using your Google 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 )

Connecting to %s

This site uses Akismet to reduce spam. Learn how your comment data is processed.