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
