Hey Jason, Not sure what those errors are about, but first off... if network connections are only defined from the remote brokers to the central broker, then only messages can sent to the central broker. The central broker will not be able to send message back to the remote broker.
Regards, Hiram On 10/15/06, Jason Dillon <[EMAIL PROTECTED]> wrote:
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
-- Regards, Hiram Blog: http://hiramchirino.com
