Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (athena.apache.org: domain of sukoneru@cisco.com designates
 171.68.10.86 as permitted sender)
Content-class: urn:content-classes:message
MIME-Version: 1.0
Content-Type: text/plain;
	charset="us-ascii"
Content-Transfer-Encoding: quoted-printable
Subject: RE: Error on starting QueueConnection
Date: Fri, 17 Aug 2007 08:40:53 -0700
Message-ID: 
 <5BD9FA70F5EDAC43AB816A5FDE30F6AC04EA0379@xmb-sjc-21a.amer.cisco.com>
In-Reply-To: <20070817105803.GSFA5.86101.root@fepweb16>
Thread-Topic: Error on starting QueueConnection
Thread-Index: Acfg3wPlai2Dd8DxTqOotQw69F72EAABZFvw
References: 
 <5BD9FA70F5EDAC43AB816A5FDE30F6AC04EA00CC@xmb-sjc-21a.amer.cisco.com>
 <20070817105803.GSFA5.86101.root@fepweb16>
From: "Suchitha Koneru \(sukoneru\)" <sukoneru@cisco.com>
To: "Dave Carlson" <gshpsrule@charter.net>
Cc: <users@activemq.apache.org>

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
=20

-----Original Message-----
From: Dave Carlson [mailto:gshpsrule@charter.net]=20
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 =3D
new ActiveMQConnectionFactory(user, password, url);
			Connection connection =3D
connectionFactory.createConnection();
			if (durable && clientId !=3D null &&
clientId.length()>0 && !"null".equals(clientId) ) {
				connection.setClientID(clientId);
			}
			connection.setExceptionListener(this);
			connection.start();

			session =3D connection.createSession(transacted,
ackMode);
			if (topic) {
				destination =3D
session.createTopic(subject);
			} else {
				destination =3D
session.createQueue(subject);
			}

			replyProducer =3D session.createProducer(null);
=09
replyProducer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);

			MessageConsumer consumer =3D null;
			if (durable && topic) {
				consumer =3D
session.createDurableSubscriber((Topic) destination, consumerName);
			} else {
				consumer =3D
session.createConsumer(destination);
			}

---- "Suchitha Koneru (sukoneru)" <sukoneru@cisco.com> wrote:=20
> Start the queue connection after creating the receiver .  Change the=20
> order and see. It is always recommended that the connection is started

> after creating the receiver . The following should be the order. Give=20
> it a try.
>=20
>   ActiveMQQueueReceiver aqr =3D
>  (ActiveMQQueueReceiver)qs.createReceiver(q) ;=20
>                 aqr.setMessageListener(new
>  BatchReceiverTechnicalService()) ;
>   aqc.start() ;
>=20
> Also I noticed that in the jndi resource for jms/Connectionfactory =20
> you are not using max.Inactivity flag for the broker url.
> But while adding connector to the broker you are using this flag,=20
> please use the same broker url through out for consistency.
>=20
>=20
> -----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
>=20
>=20
> 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
>=20
> Could you tell me if something is wrong !
> Here is my context declaration in Tomcat :
>=20
> <Context path=3D"/jms" reloadable=3D"true" docBase=3D"C:\myJMSApp"
> workDir=3D"C:\myJMSApp\work" >
> 	<Resource
>         	name=3D"jms/ConnectionFactory"
>         	auth=3D"Container"
>         	type=3D"org.apache.activemq.ActiveMQConnectionFactory"
>         	description=3D"JMS Connection Factory"
>         	factory=3D"org.apache.activemq.jndi.JNDIReferenceFactory"
>         	brokerURL=3D"tcp://localhost:61616"
>         	brokerName=3D"LocalActiveMQBroker"
> 	        useEmbeddedBroker=3D"true"/>
>=20
>     	<Resource name=3D"jms/batch"
>         	auth=3D"Container"
>         	type=3D"org.apache.activemq.command.ActiveMQQueue"
>         	factory=3D"org.apache.activemq.jndi.JNDIReferenceFactory"
>         	physicalName=3D"batch"/>
> </Context>
>=20
> Thanks in advance for all reply, help / answer.
> Regards,
>=20
> Denez
>=20
>=20
> denez wrote:
> >=20
> > Hi all,
> >=20
> > I got the same error trying to create a sender !
> > A very strange thing appear because there is no exception throw !=20
> > Just
>=20
> > nothing happened and the rest of my code is never (i suspect)
> excecuted.
> >=20
> > Could you help me, or ask me if something is not clear.
> > Thanks in advance,
> > Regards,
> >=20
> > Denez
> >=20
> >=20
> > denez wrote:
> >>=20
> >> I search around to find my error and find that you should use=20
> >> ActiveMQConnection.
> >> Now i can start the connection but have a same problem will trying=20
> >> to
>=20
> >> createReceiver.
> >> See the code below (previous + modification) :
> >>=20
> >> public class ActiveMQBrokerStartListener implements=20
> >> ServletContextListener {
> >> =09
> >>      BrokerService broker =3D new BrokerService();
> >>      ActiveMQConnection aqc =3D null ;
> >> =09
> >>      public void contextInitialized(ServletContextEvent arg0) {
> >>         try{
> >>              =20
> >>
> =
broker.addConnector("tcp://localhost:61616?trace=3Dtrue&wireFormat.maxIn
> ac
> tivityDuration=3D-1");
> >>                broker.start();
> >>                InitialContext ic =3D new InitialContext();
> >>                Context ctx =3D (Context) =
ic.lookup("java:comp/env");
> >>                ActiveMQConnectionFactory acf =3D
> >>                   =20
> >> (ActiveMQConnectionFactory)ctx.lookup("jms/ConnectionFactory");
> >>                aqc =3D
(ActiveMQConnection)acf.createQueueConnection();
> >>                aqc.start() ;
> >>                ActiveMQQueueSession qs =3D
> >>                    =20
> >> (ActiveMQQueueSession)aqc.createQueueSession(false,
> >> Session.CLIENT_ACKNOWLEDGE) ;
> >>                ActiveMQQueue q =3D
> (ActiveMQQueue)ctx.lookup("jms/batch");
> >>                ActiveMQQueueReceiver aqr =3D
> >> (ActiveMQQueueReceiver)qs.createReceiver(q) ; // ERROR LINE
> >>                aqr.setMessageListener(new
> >> BatchReceiverTechnicalService()) ;
> >>         }catch(Exception e){
> >>                System.err.println(e.getMessage());
> >>                e.printStackTrace();
> >>                throw new RuntimeException(e);
> >>         }
> >>      }
> >>=20
> >>      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);
> >>                }
> >>      }
> >> }
> >>=20
> >> What is wrong ??
> >> Why i can not create a Receiver ?
> >>=20
> >> Thanks in advance
> >> Regards,
> >> Denez
> >>=20
> >>=20
> >>=20
> >>=20
> >> denez wrote:
> >>>=20
> >>> Hi all,
> >>>=20
> >>> I would like to start a broker and Activate a MessageListener on=20
> >>> 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 :
> >>>=20
> >>> public class ActiveMQBrokerStartListener implements=20
> >>> ServletContextListener {
> >>>      BrokerService broker =3D new BrokerService();
> >>>      QueueConnection qc =3D null ;
> >>> =09
> >>>      public void contextInitialized(ServletContextEvent arg0) {
> >>>         try{
> >>>        	     =20
> >>>
> =
broker.addConnector("tcp://localhost:61616?trace=3Dtrue&wireFormat.maxIn
> ac
> tivityDuration=3D-1");
> >>>                broker.start();
> >>>                InitialContext ic =3D new InitialContext();
> >>>                Context ctx =3D (Context) =
ic.lookup("java:comp/env");
> >>>                ActiveMQConnectionFactory cf =3D
> >>>                           =20
> >>> ActiveMQConnectionFactory)ctx.lookup("jms/ConnectionFactory");
> >>>                qc =3D (QueueConnection) =
cf.createQueueConnection();
> >>>                qc.start() ;
> >>>                QueueSession qs =3D qc.createQueueSession(false,
> >>> Session.CLIENT_ACKNOWLEDGE) ;
> >>>                Queue q =3D (Queue)ctx.lookup("jms/batch");
> >>>                QueueReceiver qr =3D qs.createReceiver(q) ;
> >>>                qr.setMessageListener(new Receiver()) ;
> >>>         }catch(Exception e){
> >>>                System.err.println(e.getMessage());
> >>>                e.printStackTrace();
> >>>                throw new RuntimeException(e);
> >>>         }
> >>>      }
> >>>=20
> >>>      public void contextDestroyed(ServletContextEvent arg0) {
> >>>         try{
> >>>                qc.close() ;
> >>>                broker.stop();
> >>>         }catch(Exception e){
> >>>                System.err.println(e.getMessage());
> >>>                e.printStackTrace();
> >>>                throw new RuntimeException(e);
> >>>         }
> >>>      }
> >>> }
> >>>=20
> >>> 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=20
> >>> createQueueConnection i have it.
> >>> So the problem is on the qc.start() ; If i inspect the=20
> >>> QueueConnection i can see that the started=3Dfalse as normal.
> >>>=20
> >>> What is wrong on my code ?
> >>> Could you help me, or tell me what you think about this ?
> >>>=20
> >>> Regards,
> >>> Denez
> >>>=20
> >>=20
> >>=20
> >=20
> >=20
>=20
> --
> 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.