Hi, you're using vm transaport and you can exchange messages using it only inside the same application (vm). If you want to use this from two applications, one of them must connect over network. See http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.htmlfor more details.
Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Mon, Aug 10, 2009 at 10:09 AM, dirful_zone <z...@i-s.com.cn> wrote: > > Hi, this is dirful. > I've study amq for several weeks. I have also searched the forum > carefully.I'm sorry to say that I'm so confused. I didn't get it.:( > > This is my problem: > I make a project via Struts FrameWork,Spring and tomcat. I injected JNDI > into "context.xml" of tomcat like this: > <Resource name="jms/ConnectionFactory" > auth="Container" > type="org.apache.activemq.ActiveMQConnectionFactory" > description="JMS Connection Factory" > factory="org.apache.activemq.jndi.JNDIReferenceFactory" > brokerURL="vm://192.168.201.249" > brokerName="LocalActiveMQBroker"/> > > <Resource name="jms/Queue1" > auth="Container" > type="org.apache.activemq.command.ActiveMQQueue" > description="my Queue1" > factory="org.apache.activemq.jndi.JNDIReferenceFactory" > physicalName="FOO.BAR"/> > > And I rewrited the xml of Spring，too. Then I made a MessageProducer and a > MessageConsumer. > If the MessageProducer and MessageConsumer is in the same apllication(just > call it projectA),It works! Just sending a message, it can real time > receiving the message.In addtion,the receiving method is written in Action. > > But now, I wanted if A application sent a message, B application recived > it, > and B sent , A recieved. I modified the "context.xml" like this > <Resource name="jms/ConnectionFactory" > auth="Container" > type="org.apache.activemq.ActiveMQConnectionFactory" > description="JMS Connection Factory" > factory="org.apache.activemq.jndi.JNDIReferenceFactory" > brokerURL="vm://192.168.201.249" > brokerName="LocalActiveMQBroker"/> > > <Resource name="jms/Queue1" > auth="Container" > type="org.apache.activemq.command.ActiveMQQueue" > description="my Queue1" > factory="org.apache.activemq.jndi.JNDIReferenceFactory" > physicalName="FOO.BAR"/> > > <Resource name="jms/Queue2" > auth="Container" > type="org.apache.activemq.command.ActiveMQQueue" > description="my Queue2" > factory="org.apache.activemq.jndi.JNDIReferenceFactory" > physicalName="FOO1.BAR"/> > > And this is one of my applictiaonContext.xml,the other one is similar: > > <bean id="jmsConnectionFactory" > class="org.springframework.jndi.JndiObjectFactoryBean"> > <property name="jndiName" > value="java:comp/env/jms/ConnectionFactory"></property> > </bean> > > <bean id="jmsQueue1" > class="org.springframework.jndi.JndiObjectFactoryBean"> > <property name="jndiName" > value="java:comp/env/jms/Queue1"></property> > </bean> > <bean id="jmsQueue2" > class="org.springframework.jndi.JndiObjectFactoryBean"> > <property name="jndiName" > value="java:comp/env/jms/Queue2"></property> > </bean> > > <bean id="jmsTemplate" > class="org.springframework.jms.core.JmsTemplate"> > <property name="connectionFactory" > ref="jmsConnectionFactory"></property> > <property name="defaultDestination" ref="jmsQueue2"></property> > </bean> > > <bean id="sender" class="message.Sender"> > <property name="jmsTemplate" ref="jmsTemplate"></property> > </bean> > > <bean id="receive" class="message.Receiver"></bean> > <bean id="listenerContainer" > > class="org.springframework.jms.listener.DefaultMessageListenerContainer"> > <property name="connectionFactory" > ref="jmsConnectionFactory"></property> > <property name="destination" ref="jmsQueue1"></property> > <property name="messageListener" ref="receive"></property> > </bean> > > I'm depressed. It didn't work very well. When A send a message, B's > listener > didn't work.Sometimes, when B send a message, at the same time, it can > recieve the message. But this isn't what I hope. > Could you give me some directions,sir? How can I do monitor the sending > message in two applications? > > I have annother question,too. > > Er, you see that I injected JNDI into "context.xml", it can send a message > successfully. and I want to make a static Main method In another > application > to receive the message( just test). I'm confused that, If I don't use > JNDI，the url is...,the broker is...,password?username? how can I write it? > I made it like this: > > connectionFactory = new ActiveMQConnectionFactory( > ActiveMQConnection.DEFAULT_USER, > ActiveMQConnection.DEFAULT_PASSWORD, > "vm://192.168.201.249"); > connection = connectionFactory.createConnection(); > connection.start(); > session = > connection.createSession(false,Session.AUTO_ACKNOWLEDGE); > destination = session.createQueue("FOO.BAR"); > consumer = session.createConsumer(destination); > > I got a waring:Waiting to Lock the Store activemq-data\192.168.201.249. > > I appreciate any your help. Best whishes! > > dirful > 08/10/2009 > > -- > View this message in context: > http://www.nabble.com/How-can-consumer-monitor-the-producer-via-Spring-tp24895824p24895824.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > >
