Having some trouble making a simple network...

Sun, 15 Oct 2006 20:15:36 -0700

Hiya... I'm having some trouble making a simple broker network for GBuild. The idea was to embed a broker in each node, and then have the slave nodes connect to the master node, so that all client code will always be connected, and let activemq handle broker to broker connectivity. 

But, I can not seems to get it to work.
NOTE: This is not master/slave in terms of broker fail-over... its just hub/spoke where the hub is the master and slave a spoke... just for clarity on the bits below. 

My central manager (which is what slave nodes connect to) has:

<beans xmlns="http://activemq.org/config/1.0";>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfi gurer"/> 
    <broker useJmx="true">
        <managementContext>
<managementContext connectorPort="5003" jmxDomainName="org.apache.activemq"/> 
        </managementContext>
        <persistenceAdapter>
<journaledJDBC journalLogFiles="5" dataDirectory="$ {gshell.home}/activemq"/> 
        </persistenceAdapter>
        <transportConnectors>
            <transportConnector uri="vm://localhost"/>
            <transportConnector uri="tcp://localhost:16161"/>
        </transportConnectors>
    </broker>
</beans>

And my slave nodes have:

<beans xmlns="http://activemq.org/config/1.0";>
<bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfi gurer"/> 
    <broker useJmx="true">
        <managementContext>
<managementContext connectorPort="5004" jmxDomainName="org.apache.activemq"/> 
        </managementContext>
        <persistenceAdapter>
<journaledJDBC journalLogFiles="5" dataDirectory="$ {gshell.home}/activemq"/> 
        </persistenceAdapter>
        <transportConnectors>
            <transportConnector uri="vm://localhost"/>
        </transportConnectors>
        <networkConnectors>
<networkConnector uri="static:(tcp://gbuild.org:16161)" failover="true"/> 
        </networkConnectors>
    </broker>
</beans>
But... for some reason this is not working... and I don't know why. Connectivity is good, as when I change the slave client's to connect with "tcp://gbuild.org:16161" instead of "vm://localhost" everything works fine.
But when the slaves use "vm://localhost" then they never see any messages, and the master node complains with "No subscriptions registered, will not dispatch message at this time" when new messages are queued... though when the slave starts I do see it connecting to gbuild.org:16161 and I see the master node create a consumer for the client (and remove it when I stop the slave). 

Not sure if this matters, but I also see these logs on the master node:

<snip>
19:54:45,283 DEBUG [Service] Async error occurred: java.lang.NullPointerException 
java.lang.NullPointerException
at edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap.hash (ConcurrentHashMap.java:154) at edu.emory.mathcs.backport.java.util.concurrent.ConcurrentHashMap.get (ConcurrentHashMap.java:759) at org.apache.activemq.broker.AbstractConnection.processAddConnection (AbstractConnection.java:616) at org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConn ection(ManagedTransportConnection.java:87) at org.apache.activemq.command.ConnectionInfo.visit (ConnectionInfo.java:121) at org.apache.activemq.broker.AbstractConnection.service (AbstractConnection.java:238) at org.apache.activemq.broker.TransportConnection$1.onCommand (TransportConnection.java:63) at org.apache.activemq.transport.ResponseCorrelator.onCommand (ResponseCorrelator.java:95) at org.apache.activemq.transport.TransportFilter.onCommand (TransportFilter.java:65) at org.apache.activemq.transport.WireFormatNegotiator.onCommand (WireFormatNegotiator.java:133) at org.apache.activemq.transport.InactivityMonitor.onCommand (InactivityMonitor.java:122) at org.apache.activemq.transport.TransportSupport.doConsume (TransportSupport.java:84) at org.apache.activemq.transport.tcp.TcpTransport.run (TcpTransport.java:136) 
        at java.lang.Thread.run(Thread.java:595)
19:54:45,284 DEBUG [Transport] Transport failed: java.io.IOException: Unknown data type: 68 
java.io.IOException: Unknown data type: 68
at org.apache.activemq.openwire.OpenWireFormat.doUnmarshal (OpenWireFormat.java:344) at org.apache.activemq.openwire.OpenWireFormat.unmarshal (OpenWireFormat.java:275) at org.apache.activemq.transport.tcp.TcpTransport.run (TcpTransport.java:135) 
        at java.lang.Thread.run(Thread.java:595)
</snip>

I'm using the latest 4.1-incubator-SNAPSHOT in m2:

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activeio-core</artifactId>
    <version>3.0-SNAPSHOT</version>
</dependency>

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-core</artifactId>
    <version>4.1-incubator-SNAPSHOT</version>
</dependency>

 * * *
I really want to get this broker network working so that the client code can be free from reconnect fluff... and just assume that the local embedded broker will handle all inter-broker connectivity issues. 

Anyone have any idea what's wrong?

Thanks,

--jason

Reply via email to