Hello... I am using ActiveMQ 4.1.1 with Spring 2.0 and JDK6. I have a network of two brokers deployed as follows:
HostA: transportConnectorURIs = tcp://localhost:61616 networkConnectorURIs = tcp://HostB:61616 Number of JMS Clients = 1 HostB: transportConnectorURIs = tcp://localhost:61616 networkConnectorURIs = tcp://HostA:61616 Number of JMS Clients = 1 I statically (in the configuration) a Topic ("com.foo.MyTopic") on both the brokers. When client on HostA publishes a message, broker on HostA receives it but is never seen on the broker on HostB (and vice versa). Enabling the following debugs yields no information: log4j.logger.org.apache.activemq.broker.BrokerService=DEBUG, rootLogger Given below is my broker configuration on HostA: <bean id="broker" class="org.apache.activemq.broker.BrokerService"> <property name="transportConnectorURIs"> <value>tcp://localhost:61616</value> </property> <property name="networkConnectorURIs"> <value>static:(tcp://HostB:61616)</value> </property> </bean> <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic"> <constructor-arg> <value>com.foo.MyTopic</value> </constructor-arg> </bean> <!-- JMS ConnectionFactory to use --> <bean id="jmsFactory" class="org.apache.activemq.ActiveMQConnectionFactory" depends-on="broker"> <property name="brokerURL"> <value>tcp://localhost:61616</value> </property> </bean> Does anything in this stand out as something that could be causing the messages to be not forwarded across the brokers? The default value of networkTTL is 1 (per the documentation); does this mean that messages will not cross more than one broker? Could that be causing the problem above? Any help appreciated, Tx, /U -------------- Original message ---------------------- From: [EMAIL PROTECTED] > Hi - > > I am using Spring 2.0 with ActiveMQ 4.1.1 (JDK6, Tomcat 5.5.x). I am > instantiating a broker using > Xbean as follows: > <?xml version="1.0" encoding="UTF-8"?> > <beans xmlns="http://activemq.org/config/1.0"> > <broker brokerName="MyBroker" persistent="false" useJmx="false"> > <transportConnectors> > <transportConnector uri="tcp://localhost:61616"/> > </transportConnectors> > //... > </beans> > > As the (webapp) context loads, it aborts with the following error: > > > org.springframework.beans.factory.BeanCreationException: Error creating bean > with name 'broker' defined in ServletContext resource [/WEB-INF/common.xml]: > Invocation of init method failed; nested exception is > org.springframework.beans.factory.BeanDefinitionStoreException: Unrecognized > xbean element mapping: beans in namespace http://activemq.org/config/1.0 > C aused by: > //... > > > I saw a similar report clarified by James Strachan at > http://mail-archives.apache.org/mod_mbox/activemq-dev/200704.mbox/%3C9850511.pos > [EMAIL PROTECTED] > > but I am certain I am not using an old version of amq in my webapp. > > Pl help, > > Thanks, > > /U