*Messaging in enterprise application needs to work on Webpshere MQ/Tomee
environment. *
For this POC I've written a simple Servlet App to send message.
code:
String MYCF_LOOKUP_NAME = "java:/comp/env/jms/qcf";
String MYQUEUE_LOOKUP_NAME = "java:/comp/env/jms/queue";
ConnectionFactory connectionFactory = null;
Destination dest = null;
Context jndiContext = null;
Connection connection = null;
MessageProducer producer = null;
Session session = null;
MessageConsumer consumer = null;
TextMessage message = null;
try {
jndiContext = new InitialContext();
connectionFactory = (ConnectionFactory)
jndiContext.lookup(MYCF_LOOKUP_NAME);
dest = (Destination) jndiContext.lookup(MYQUEUE_LOOKUP_NAME);
connection = connectionFactory.createConnection();
session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
producer = session.createProducer(dest);
message = session.createTextMessage("Test Message");
producer.send(message);
}
catch( Exception e)
{
e.printStackTrace();
}
finally
{
try {
connection.close();
} catch (JMSException e) {
e.printStackTrace();
}
}
*web.xml*
<resource-ref>
<description>
</description>
<res-ref-name>jms/qcf</res-ref-name>
<res-type>javax.jms.ConnectionFactory</res-type>
<res-auth>Container</res-auth>
<res-sharing-scope>Shareable</res-sharing-scope>
</resource-ref>
<message-destination-ref>
<description>
</description>
<message-destination-ref-name>jms/queue</message-destination-ref-name>
<message-destination-type>javax.jms.Queue</message-destination-type>
<message-destination-usage>ConsumesProduces</message-destination-usage>
<message-destination-link>jms/queue</message-destination-link>
</message-destination-ref>
<message-destination>
<description>
</description>
<message-destination-name>jms/queue</message-destination-name>
</message-destination>
*tomee.xml under META-INF*
<tomee>
<Resource id="jms/queue"
type="javax.jms.Queue"
provider="com.ibm.was.mq.WebsphereMQQueue">
BaseQueueName QUEUE1
BaseQueueManagerName QM_TIERL
</Resource>
<Resource id="jms/qcf"
type="javax.jms.ConnectionFactory"
provider="com.ibm.was.mq.WebsphereMQConnectionFactory">
HostName 10.x.x.x
Port 1414
QueueManager QM_TIERL
Channel SYSTEM.ADMIN.SVRCONN
TransportType CLIENT
UserName xyz
PassWord xyz
</Resource>
</tomee>
I have added wmq.jmsra.rar RAR file to my EAR.
Once this works I was planning to an MDB to consume the message.
--
View this message in context:
http://openejb.979440.n4.nabble.com/websphere-MQ-tp4658647p4659036.html
Sent from the OpenEJB User mailing list archive at Nabble.com.
