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 rafal.rusin@gmail.com
 designates 209.85.219.220 as permitted sender)
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:date:message-id:subject:from:to
         :content-type:content-transfer-encoding;
        b=JtHYhLNVxmLLLDR4H0Li+fMoSn7Omgrl2N6Hb8vB1olHaIzmHHDmSPFSm/b6DKpAtr
         b4yk+boxnY8Hl9xcbhaMD1D++2zplZ18MsLOpjMu6P6gnCmRBZBl4PVnXlrnYOXwvUtR
         3fVqxBuldGs7e8WsT1Mon9ITXOjkZWbxmAxNk=
MIME-Version: 1.0
In-Reply-To: <4AB6D26F.90204@gmail.com>
References: <4AB6D26F.90204@gmail.com>
Date: Mon, 21 Sep 2009 09:22:28 +0200
Message-ID: <9bbf67fa0909210022h417e80fdp5fb6e5e4ece79c69@mail.gmail.com>
Subject: Re: Spring JMS : can't receive message ?
From: Rafal Rusin <rafal.rusin@gmail.com>
To: users@activemq.apache.org
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: quoted-printable

Do you have broker running at tcp://localhost:61616? I don't see an
entry for it in your spring config.
If not, consider adding something like this:
      <amq:broker id=3D"brokerLocal" brokerName=3D"localBroker">
         <amq:persistenceAdapter>
            <amq:amqPersistenceAdapter directory=3D"file:./data/amq-local"/=
>
         </amq:persistenceAdapter>
          <amq:transportConnectors>
          <amq:transportConnector uri=3D"tcp://localhost:61616" />
          </amq:transportConnectors>
         <amq:networkConnectors>
         </amq:networkConnectors>
        </amq:broker>

Regards,

2009/9/21 czy11421 <czy11421@gmail.com>:
> Hi, All,
>
> I have tried to write a JMS with Spring, but failed. no compiler error, n=
o
> runtime error, just wait infinitely, can't receive message, but I am sure
> the ActiveMQ is publishing data in 'STOCKS.SUNW' topic.
>
> Anybody has some clues ? Thanks.
>
> ///////////////////////// MessageReceiver.java /////////////////////////
> import javax.jms.JMSException;
> import javax.jms.Message;
> import javax.jms.TextMessage;
>
> import org.springframework.jms.core.JmsTemplate;
>
> public class MessageReceiver {
> =C2=A0 private JmsTemplate jmsTemplate;
> =C2=A0 public MessageReceiver() {
> =C2=A0 }
>
> =C2=A0 public void setJmsTemplate(JmsTemplate jmsTemplate) {
> =C2=A0 =C2=A0 =C2=A0 this.jmsTemplate =3D jmsTemplate;
> =C2=A0 } =C2=A0 =C2=A0 =C2=A0 public void receiveMessage() {
> System.out.println("receiving");
> =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 Message message =3D jmsTemplate=
.receive(); // wait infinitely
> =C2=A0 =C2=A0 =C2=A0 System.out.println("Message=3D"+message); // never r=
each here
> =C2=A0 =C2=A0 =C2=A0 TextMessage textMessage =3D null;
> =C2=A0 =C2=A0 =C2=A0 if (message instanceof TextMessage) {
> =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 textMessage =3D (TextMessage) message;
> =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 //....
> =C2=A0 =C2=A0 =C2=A0 }
> =C2=A0 }
> }
>
> /////////////////////////////////
>
> //////////////////////// spring beans xml /////////////////////
> <?xml version=3D"1.0"?>
>
> <!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN"
> "http://www.springframework.org/dtd/spring-beans.dtd">
>
> <beans>
> =C2=A0 <bean id=3D"activeMQConnectionFactory"
> class=3D"org.apache.activemq.ActiveMQConnectionFactory">
> =C2=A0 =C2=A0 =C2=A0 <property name=3D"brokerURL" value=3D"tcp://localhos=
t:61616" />
> =C2=A0 </bean>
>
> =C2=A0 <bean id=3D"sampleJmsTemplate"
> class=3D"org.springframework.jms.core.JmsTemplate">
> =C2=A0 =C2=A0 =C2=A0 <property name=3D"connectionFactory" ref=3D"activeMQ=
ConnectionFactory" />
> =C2=A0 =C2=A0 =C2=A0 <property name=3D"defaultDestination">
> =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 <ref bean=3D"defaultDestination" />
> =C2=A0 =C2=A0 =C2=A0 </property>
> =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 =C2=A0 <property name=3D"receiveTimeou=
t">
> =C2=A0 =C2=A0 <value>3000000</value>
> =C2=A0 </property>
> =C2=A0 =C2=A0 =C2=A0 =C2=A0 </bean>
>
> =C2=A0 <bean id=3D"messageReceiver" class=3D"com.MessageReceiver">
> =C2=A0 =C2=A0 =C2=A0 <property name=3D"jmsTemplate" ref=3D"sampleJmsTempl=
ate" />
> =C2=A0 </bean>
> =C2=A0 =C2=A0 <bean id=3D"defaultDestination"
> class=3D"org.apache.activemq.command.ActiveMQQueue">
> =C2=A0 =C2=A0 =C2=A0 <constructor-arg value=3D"STOCKS.SUNW" />
> =C2=A0 </bean>
> </beans>
>
> /////////////////////////// main class /////////////////////////
>
> import org.springframework.context.ApplicationContext;
> import org.springframework.context.support.ClassPathXmlApplicationContext=
;
>
> public class Test {
>
> =C2=A0 public static void main(String[] args) throws Exception {
> =C2=A0 =C2=A0 =C2=A0 ApplicationContext ctx =3D new
> ClassPathXmlApplicationContext("appContext.xml");
>
> =C2=A0 =C2=A0 =C2=A0 MessageReceiver receiver =3D (MessageReceiver)
> ctx.getBean("messageReceiver");
>
> =C2=A0 =C2=A0 =C2=A0 receiver.receiveMessage();
>
> =C2=A0 }
>
> }
>


--=20
Rafa=C5=82 Rusin
http://www.touk.pl
http://top.touk.pl
http://www.mimuw.edu.pl/~rrusin