Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 42691 invoked from network); 20 Aug 2007 07:52:43 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 20 Aug 2007 07:52:43 -0000 Received: (qmail 14101 invoked by uid 500); 20 Aug 2007 07:52:39 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 14067 invoked by uid 500); 20 Aug 2007 07:52:39 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 14058 invoked by uid 99); 20 Aug 2007 07:52:39 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Aug 2007 00:52:39 -0700 X-ASF-Spam-Status: No, hits=2.6 required=10.0 tests=DNS_FROM_OPENWHOIS,SPF_HELO_PASS,SPF_PASS,WHOIS_MYPRIVREG X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates 216.139.236.158 as permitted sender) Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 20 Aug 2007 07:52:37 +0000 Received: from isper.nabble.com ([192.168.236.156]) by kuber.nabble.com with esmtp (Exim 4.63) (envelope-from ) id 1IN23d-000313-5k for users@activemq.apache.org; Mon, 20 Aug 2007 00:52:17 -0700 Message-ID: <12231481.post@talk.nabble.com> Date: Mon, 20 Aug 2007 00:52:17 -0700 (PDT) From: denez To: users@activemq.apache.org Subject: RE: Error on starting QueueConnection In-Reply-To: <5BD9FA70F5EDAC43AB816A5FDE30F6AC04EA0379@xmb-sjc-21a.amer.cisco.com> MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-From: ibouddha@yahoo.fr References: <12178078.post@talk.nabble.com> <12178653.post@talk.nabble.com> <12180186.post@talk.nabble.com> <12182022.post@talk.nabble.com> <5BD9FA70F5EDAC43AB816A5FDE30F6AC04EA00CC@xmb-sjc-21a.amer.cisco.com> <20070817105803.GSFA5.86101.root@fepweb16> <5BD9FA70F5EDAC43AB816A5FDE30F6AC04EA0379@xmb-sjc-21a.amer.cisco.com> X-Virus-Checked: Checked by ClamAV on apache.org I try your both sample, but it still doesn't work. I try to move my project directory because originally contains space. but still have the same error. I probaly miss something in my configuration or someting is wrong in my code. I don't understand. So, could you give me or send me a sample web application that use ActiveMQ ? Thanks in advance. Regards, Denez Suchitha Koneru (sukoneru) wrote: > > The JMS documentation suggests that we start the connection after > creating the receiver and registering it with a message listener. Please > look at point no: 6 in the section "Client to Consume Messages" > http://java.sun.com/developer/technicalArticles/Ecommerce/jms/index.html > > > -----Original Message----- > From: Dave Carlson [mailto:gshpsrule@charter.net] > Sent: Friday, August 17, 2007 7:58 AM > To: users@activemq.apache.org > Cc: Suchitha Koneru (sukoneru) > Subject: RE: Error on starting QueueConnection > > Are you sure about the ordering? It seems odd that you would want to > start the flow of messages across the connection before you have created > a receiver. Looking at ActiveMQ example code in ConsumerTool, they are > creating the receiver first... > > ActiveMQConnectionFactory connectionFactory = > new ActiveMQConnectionFactory(user, password, url); > Connection connection = > connectionFactory.createConnection(); > if (durable && clientId != null && > clientId.length()>0 && !"null".equals(clientId) ) { > connection.setClientID(clientId); > } > connection.setExceptionListener(this); > connection.start(); > > session = connection.createSession(transacted, > ackMode); > if (topic) { > destination = > session.createTopic(subject); > } else { > destination = > session.createQueue(subject); > } > > replyProducer = session.createProducer(null); > > replyProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT); > > MessageConsumer consumer = null; > if (durable && topic) { > consumer = > session.createDurableSubscriber((Topic) destination, consumerName); > } else { > consumer = > session.createConsumer(destination); > } > > ---- "Suchitha Koneru (sukoneru)" wrote: >> Start the queue connection after creating the receiver . Change the >> order and see. It is always recommended that the connection is started > >> after creating the receiver . The following should be the order. Give >> it a try. >> >> ActiveMQQueueReceiver aqr = >> (ActiveMQQueueReceiver)qs.createReceiver(q) ; >> aqr.setMessageListener(new >> BatchReceiverTechnicalService()) ; >> aqc.start() ; >> >> Also I noticed that in the jndi resource for jms/Connectionfactory >> you are not using max.Inactivity flag for the broker url. >> But while adding connector to the broker you are using this flag, >> please use the same broker url through out for consistency. >> >> >> -----Original Message----- >> From: denez [mailto:ibouddha@yahoo.fr] >> Sent: Thursday, August 16, 2007 7:03 AM >> To: users@activemq.apache.org >> Subject: Re: Error on starting QueueConnection >> >> >> Do you already have this type of error ? >> Do i forget something in my configuration. >> I use : >> apache-activemq-4.1.1.jar >> Tomcat 5.5.23 >> jdk1.5.0_07 >> >> Could you tell me if something is wrong ! >> Here is my context declaration in Tomcat : >> >> > workDir="C:\myJMSApp\work" > >> > name="jms/ConnectionFactory" >> auth="Container" >> type="org.apache.activemq.ActiveMQConnectionFactory" >> description="JMS Connection Factory" >> factory="org.apache.activemq.jndi.JNDIReferenceFactory" >> brokerURL="tcp://localhost:61616" >> brokerName="LocalActiveMQBroker" >> useEmbeddedBroker="true"/> >> >> > auth="Container" >> type="org.apache.activemq.command.ActiveMQQueue" >> factory="org.apache.activemq.jndi.JNDIReferenceFactory" >> physicalName="batch"/> >> >> >> Thanks in advance for all reply, help / answer. >> Regards, >> >> Denez >> >> >> denez wrote: >> > >> > Hi all, >> > >> > I got the same error trying to create a sender ! >> > A very strange thing appear because there is no exception throw ! >> > Just >> >> > nothing happened and the rest of my code is never (i suspect) >> excecuted. >> > >> > Could you help me, or ask me if something is not clear. >> > Thanks in advance, >> > Regards, >> > >> > Denez >> > >> > >> > denez wrote: >> >> >> >> I search around to find my error and find that you should use >> >> ActiveMQConnection. >> >> Now i can start the connection but have a same problem will trying >> >> to >> >> >> createReceiver. >> >> See the code below (previous + modification) : >> >> >> >> public class ActiveMQBrokerStartListener implements >> >> ServletContextListener { >> >> >> >> BrokerService broker = new BrokerService(); >> >> ActiveMQConnection aqc = null ; >> >> >> >> public void contextInitialized(ServletContextEvent arg0) { >> >> try{ >> >> >> >> >> broker.addConnector("tcp://localhost:61616?trace=true&wireFormat.maxIn >> ac >> tivityDuration=-1"); >> >> broker.start(); >> >> InitialContext ic = new InitialContext(); >> >> Context ctx = (Context) ic.lookup("java:comp/env"); >> >> ActiveMQConnectionFactory acf = >> >> >> >> (ActiveMQConnectionFactory)ctx.lookup("jms/ConnectionFactory"); >> >> aqc = > (ActiveMQConnection)acf.createQueueConnection(); >> >> aqc.start() ; >> >> ActiveMQQueueSession qs = >> >> >> >> (ActiveMQQueueSession)aqc.createQueueSession(false, >> >> Session.CLIENT_ACKNOWLEDGE) ; >> >> ActiveMQQueue q = >> (ActiveMQQueue)ctx.lookup("jms/batch"); >> >> ActiveMQQueueReceiver aqr = >> >> (ActiveMQQueueReceiver)qs.createReceiver(q) ; // ERROR LINE >> >> aqr.setMessageListener(new >> >> BatchReceiverTechnicalService()) ; >> >> }catch(Exception e){ >> >> System.err.println(e.getMessage()); >> >> e.printStackTrace(); >> >> throw new RuntimeException(e); >> >> } >> >> } >> >> >> >> public void contextDestroyed(ServletContextEvent arg0) { >> >> try{ >> >> aqc.close() ; >> >> //qc.close() ; >> >> broker.stop(); >> >> }catch(Exception e){ >> >> System.err.println(e.getMessage()); >> >> e.printStackTrace(); >> >> throw new RuntimeException(e); >> >> } >> >> } >> >> } >> >> >> >> What is wrong ?? >> >> Why i can not create a Receiver ? >> >> >> >> Thanks in advance >> >> Regards, >> >> Denez >> >> >> >> >> >> >> >> >> >> denez wrote: >> >>> >> >>> Hi all, >> >>> >> >>> I would like to start a broker and Activate a MessageListener on >> >>> startup of my webApp. >> >>> I made all the needed configuration to have a >> ServletContextListener. >> >>> I can debug inside my ServletContextListener implementation named > : >> >>> ActiveMQBrokerStartListener. >> >>> You can see the code of it below : >> >>> >> >>> public class ActiveMQBrokerStartListener implements >> >>> ServletContextListener { >> >>> BrokerService broker = new BrokerService(); >> >>> QueueConnection qc = null ; >> >>> >> >>> public void contextInitialized(ServletContextEvent arg0) { >> >>> try{ >> >>> >> >>> >> broker.addConnector("tcp://localhost:61616?trace=true&wireFormat.maxIn >> ac >> tivityDuration=-1"); >> >>> broker.start(); >> >>> InitialContext ic = new InitialContext(); >> >>> Context ctx = (Context) ic.lookup("java:comp/env"); >> >>> ActiveMQConnectionFactory cf = >> >>> >> >>> ActiveMQConnectionFactory)ctx.lookup("jms/ConnectionFactory"); >> >>> qc = (QueueConnection) cf.createQueueConnection(); >> >>> qc.start() ; >> >>> QueueSession qs = qc.createQueueSession(false, >> >>> Session.CLIENT_ACKNOWLEDGE) ; >> >>> Queue q = (Queue)ctx.lookup("jms/batch"); >> >>> QueueReceiver qr = qs.createReceiver(q) ; >> >>> qr.setMessageListener(new Receiver()) ; >> >>> }catch(Exception e){ >> >>> System.err.println(e.getMessage()); >> >>> e.printStackTrace(); >> >>> throw new RuntimeException(e); >> >>> } >> >>> } >> >>> >> >>> public void contextDestroyed(ServletContextEvent arg0) { >> >>> try{ >> >>> qc.close() ; >> >>> broker.stop(); >> >>> }catch(Exception e){ >> >>> System.err.println(e.getMessage()); >> >>> e.printStackTrace(); >> >>> throw new RuntimeException(e); >> >>> } >> >>> } >> >>> } >> >>> >> >>> I place a breakpoint on the line that should create a > QueueSession. >> >>> But never enter in it. If i place a breakpoint on the ligne that >> >>> createQueueConnection i have it. >> >>> So the problem is on the qc.start() ; If i inspect the >> >>> QueueConnection i can see that the started=false as normal. >> >>> >> >>> What is wrong on my code ? >> >>> Could you help me, or tell me what you think about this ? >> >>> >> >>> Regards, >> >>> Denez >> >>> >> >> >> >> >> > >> > >> >> -- >> View this message in context: >> http://www.nabble.com/Error-on-starting-QueueConnection-tf4278515s2354 >> .h >> tml#a12182022 >> Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- View this message in context: http://www.nabble.com/Error-on-starting-QueueConnection-tf4278515s2354.html#a12231481 Sent from the ActiveMQ - User mailing list archive at Nabble.com.