activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From uma...@comcast.net
Subject Network of brokers - messages not forwarded
Date Tue, 01 May 2007 21:09:09 GMT
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: uma_rk@comcast.net
> 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
> t@talk.nabble.com%3E
> 
> but I am certain I am not using an old version of amq in my webapp.
> 
> Pl help,
> 
> Thanks,
> 
> /U


Mime
View raw message