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.PropertyPlacehold
erConfi
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.PropertyPlacehold
erConfi
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.processAddConnectio
n
(AbstractConnection.java:616)
at
org.apache.activemq.broker.jmx.ManagedTransportConnection.process
AddConn
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
