[jboss-user] [JBoss Messaging] - Create Queue Connection Error
Hello, I am trying to use jms(jboss-messaging-1.4.0.SP3). When I started my application I
have this problem :
Exception in thread "main"
org.jboss.jms.exception.MessagingNetworkFailureException
This problem arrived when I execut this code :
conn = qcf.createQueueConnection();
All application cod:
|
| import javax.jms.JMSException;
| import javax.jms.Message;
| import javax.jms.MessageListener;
| import javax.jms.Queue;
| import javax.jms.QueueConnection;
| import javax.jms.QueueConnectionFactory;
| import javax.jms.QueueReceiver;
| import javax.jms.QueueSender;
| import javax.jms.QueueSession;
| import javax.jms.TextMessage;
| import javax.naming.InitialContext;
| import javax.naming.NamingException;
|
| import EDU.oswego.cs.dl.util.concurrent.CountDown;
| import org.apache.log4j.Logger;
|
| /**
| * A complete JMS client example program that sends a
| * TextMessage to a Queue and asynchronously receives the
| * message from the same Queue.
| *
| * @author Scott.Stark(a)jboss.org
| * @version $Revision: 1.2 $
| */
| public class SendRecvClient
| {
| static CountDown done = new CountDown(1);
| QueueConnection conn;
| QueueSession session;
| Queue que;
|
| public static class ExListener
| implements MessageListener
| {
| public void onMessage(Message msg)
| {
| done.release();
| TextMessage tm = (TextMessage) msg;
| try {
| System.out.println("onMessage, recv text=" + tm.getText());
| } catch(Throwable t) {
| t.printStackTrace();
| }
| }
| }
|
| public void setupPTP()
| throws JMSException,
| NamingException
| {
| InitialContext iniCtx = new InitialContext();
| Object tmp = iniCtx.lookup("ConnectionFactory");
| QueueConnectionFactory qcf = (QueueConnectionFactory) tmp;
| conn = qcf.createQueueConnection();
| que = (Queue) iniCtx.lookup("queue/DLQ");
| session = conn.createQueueSession(false,
| QueueSession.AUTO_ACKNOWLEDGE);
| conn.start();
| }
|
| public void sendRecvAsync(String text)
| throws JMSException,
| NamingException
| {
| System.out.println("Begin sendRecvAsync");
| // Setup the PTP connection, session
| setupPTP();
|
| // Set the async listener
| QueueReceiver recv = session.createReceiver(que);
| recv.setMessageListener(new ExListener());
|
| // Send a text msg
| QueueSender send = session.createSender(que);
| TextMessage tm = session.createTextMessage(text);
| send.send(tm);
| System.out.println("sendRecvAsync, sent text=" + tm.getText());
| send.close();
| System.out.println("End sendRecvAsync");
| }
|
| public void stop()
| throws JMSException
| {
| conn.stop();
| session.close();
| conn.close();
| }
|
| public static void main(String args[])
| throws Exception
| {
| SendRecvClient client = new SendRecvClient();
| client.sendRecvAsync("A text msg");
| client.done.acquire();
| client.stop();
| System.exit(0);
| }
| }
|
Someone can help me, please.
Jboss 5.0.0
jboss-messaging-1.4.0.SP3
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4223224#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...