can not consume messages on broker network.

[Allen Teng <ss...@gmail.com>]

Hello All 

	i'v encountered strange problem on message consuming on broker network .
		
	i have 2 computers M1 and M2 each with an embedded broker on it . assume B1
on M1 and B2 on M2,
	and each of the broker has a queue with same queue name(test-queue). 
		
	B2 has configuring a network of brokers with duplex . 
	(... 
		<amq:networkConnectors>
			<amq:networkConnector uri="static://([uri-of-B1])" duplex="true"/>
		</amq:networkConnectors>
	 ... )
	 
	 B1 has no configration of network connectors .
	 B1 is config to integrate with jboss by activemq-ra and B2 is a simple
broker in vm .
		 
	 Producer(P) connect to B1 and Consumer(C) connect to B2.
	 
	 i write a test to send out 1000 messages by P , and according to the log
of C , all the messages 
	 are received . but when i restart C , C will receive those messages again
.
	 
	 i try to monitor the test-queue on B1 by hermes-jms and found that all the
messages in test-queue on B1 
	 never be removed . when C is startup to consume messages , messages act
just like be "copy to" test-queue on B2
	 and these messages on test-queue(B2) will be removed after they are
consumed , but nothing happens to 
	 the messages on test-queue(B1).
	 
	 in activemq's document , i found that " A Store and Forward Network of
Brokers means the messages travel from broker 
	 to broker until they reach a consumer; with each message being owned by a
single broker at any point in time." , 
	 so the message cant be in both test-queue on B1 and B2 . but this is
exactlly not what i see . 
	 
	 i dont know whether it is a configration problem or anything else . could
someone shed any light on it ?
	 	
	 i appreciated very much for any help .
	 
	 my environment and codes/configurations :
	 
	 M1 : windows xp , jdk1.6.0_03 , jboss-4.2.2.GA , activemq-5.0.0 ,
activemq-ra-5.0 , spring2.5
	some configuration	for B1 ( i only post those part which i'v changed it ) :
	1) ra.xml in activemq-ra.rar\META-INF 
	....
	<resourceadapter>
	  ....
	  <config-property>
	    ...
	    <config-property-name>ServerUrl</config-property-name>
	    ....
	    <config-property-value>vm://localhost</config-property-value> 
	  </config-property>
	  ....
	  <config-property>
	    ....
	    <config-property-name>BrokerXmlConfig</config-property-name>
	    ....
	    <config-property-value>xbean:broker-config.xml</config-property-value>            
	  </config-property>
	  ....
	2) broker-config.xml in activemq-ra.rar 
	....
	<broker useJmx="true" brokerName="test.broker"
xmlns="http://activemq.org/config/1.0">
	  ....
	  <persistenceAdapter>
	    <journaledJDBC journalLogFiles="5" dataDirectory="../data/activemq"/>     
	  </persistenceAdapter>
	  <transportConnectors>     
	    <transportConnector name="parcel.broker.openwire"
uri="tcp://localhost:61616"/>     
	  </transportConnectors>
	  <networkConnectors>
	  </networkConnectors>
	  ....
	....
	3) activemq-jms-ds.xml in my jboss configuration (
%jboss_home%/server/default/deploy) 
	....
	<connection-factories>
	  <tx-connection-factory>
	    ....
	    <jndi-name>activemq/QueueConnectionFactory</jndi-name>
	    ....
	    <ServerUrl>tcp://localhost:61616</ServerUrl>
	    ....
	  ....
	  
	4) spring config for producer
	....
	  <jee:jndi-lookup id="jmsFactory"
jndi-name="java:activemq/QueueConnectionFactory" />	
	  <bean id="simpleConverter"
class="org.springframework.jms.support.converter.SimpleMessageConverter" />	
	  <bean id="jmsTemplate" class="org.springframework.jms.core.JmsTemplate">
	    <property name="connectionFactory" ref="jmsFactory" />
	    <property name="messageConverter" ref="converter" />
	  </bean>	
	  <bean id="converter" class="com.al.SimpleConverter">
	    <property name="converter" ref="simpleConverter"/>
	  </bean> 	
	  <bean id="sender" class="com.al.producer.DefaultSender">
	    <property name="template" ref="jmsTemplate" />
	    <property name="destinationName" value="test-queue" />
	  </bean>					
	....
	5) code for producer
	 http://www.nabble.com/file/p18833203/DefaultSender.java DefaultSender.java 	
	
	6) code for send messages
	...
	DefaultSender sender = (DefaultSender)context.getBean("sender");
	int idx = 0;
	while (idx < SimpleMessageHelper.payloads.size()) {
	  sender.sendMessage(SimpleMessageHelper.genSimpleMessage(idx++));
	}
	...

	M2 : windows xp , jdk1.6.0_01 , activemq-5.0.0 ,spring2.5
		 	 
	1) spring config for consumer
	 http://www.nabble.com/file/p18833203/spring_consumer.xml
spring_consumer.xml 

	 	 
	2) code for consumer
	 http://www.nabble.com/file/p18833203/DefaultListener.java
DefaultListener.java 
		 	 
	Code for helper class used in both side of B1 and B2
	 http://www.nabble.com/file/p18833203/SimpleMessageHelper.java
SimpleMessageHelper.java 
	 http://www.nabble.com/file/p18833203/SimpleConverter.java
SimpleConverter.java 
	 http://www.nabble.com/file/p18833203/SimpleMessage.java SimpleMessage.java 
	 http://www.nabble.com/file/p18833203/spring_consumer.xml
spring_consumer.xml 
	
	One of messages which left in test-queue(B1) , i copy it from ui of
herme-jms
	
	  ActiveMQTextMessage {commandId = 5, responseRequired = true, messageId =
ID:erry-al-4741-1217940624875-3:0:1:1:1, 
	  originalDestination = null, originalTransactionId = null, producerId =
ID:erry-al-4741-1217940624875-3:0:1:1, 
	  destination = queue://test-in, transactionId = null, expiration = 0,
timestamp = 1217940649078, arrival = 0, 
	  brokerInTime = 1217940649093, brokerOutTime = 1217944061875,
correlationId = null, replyTo = null, 
	  persistent = true, type = null, priority = 4, groupID = null,
groupSequence = 0, targetConsumerId = null, 
	  compressed = false, userID = null, content = null, marshalledProperties =
null, dataStructure = null, 
	  redeliveryCounter = 18, size = 0, properties = null, readOnlyProperties =
true, readOnlyBody = true, 
	  droppable = false, text = .... }
-- 
View this message in context: http://www.nabble.com/can-not-consume-messages-on-broker-network.-tp18833203p18833203.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.