Hi, I have setup the jms to work on the master/slave architecture. It works fine on localhost Windows machine on 2 different ports. But i have the errors when i run on 2 separate linux machine on the same port on both the master and slave nodes.
The following is the configuration that i hCoave used: <broker xmlns="http://activemq.org/config/1.0"; brokerName="mq02" dataDirectory="${activemq.base}/data"> <!-- Destination specific policies using destination names or wildcards --> <destinationPolicy> <policyMap> <policyEntries> <policyEntry topic="FOO.>" producerFlowControl="false" memoryLimit="1mb"> <dispatchPolicy> <strictOrderDispatchPolicy/> </dispatchPolicy> <subscriptionRecoveryPolicy> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <!-- The transport connectors ActiveMQ will listen to --> <transportConnectors> <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/> <transportConnector name="ssl" uri="ssl://localhost:61617"/> <transportConnector name="stomp" uri="stomp://localhost:61613"/> <transportConnector name="xmpp" uri="xmpp://localhost:61222"/> </transportConnectors> <!-- The store and forward broker networks ActiveMQ will listen to --> <networkConnectors> <!-- by default just auto discover the other brokers --> <networkConnector name="host1 and host2" uri="static://(tcp://localhost:61616,tcp://host1:61616)" /> </networkConnectors> <!-- Or if you want to use pure JDBC without a journal --> <persistenceAdapter> <jdbcPersistenceAdapter dataSource="#mysql-ds"/> </persistenceAdapter> <!-- Use the following to set the broker memory limit <systemUsage> <systemUsage> <memoryUsage> <memoryUsage limit="10 mb" percentUsageMinDelta="20"/> </memoryUsage> <tempUsage> <tempUsage limit="100 mb"/> </tempUsage> <storeUsage> <storeUsage limit="1 gb" name="foo"/> </storeUsage> </systemUsage> </systemUsage> --> <!-- Use the following to configure how ActiveMQ is exposed in JMX <managementContext> <managementContext connectorPort="1099" jmxDomainName="org.apache.activemq"/> </managementContext> --> </broker> <!-- lets create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic --> <commandAgent xmlns="http://activemq.org/config/1.0"/> <!-- An embedded servlet engine for serving up the Admin console --> <jetty xmlns="http://mortbay.com/schemas/jetty/1.0";> <connectors> <nioConnector port="8161" /> </connectors> <handlers> <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" /> <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" /> </handlers> </jetty> <!-- MySql DataSource Sample Setup --> <bean id="mysql-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close"> <property name="driverClassName" value="com.mysql.jdbc.Driver"/> <property name="url" value="jdbc:mysql://dbhost/activemq?relaxAutoCommit=true"/> <property name="username" value="activemq"/> <property name="password" value="activemq"/> <property name="poolPreparedStatements" value="true"/> </bean> Slave Node: ERROR TransportConnector - Could not accept connection : Peer (vm://mq01#14) disposed. ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe Master Node: INFO BrokerService - Using Persistence Adapter: JDBCPersistenceAdaptor([EMAIL PROTECTED]) INFO BrokerService - ActiveMQ 5.0.0 JMS Message Broker (mq02) is starting INFO BrokerService - For help or more information please see: http://activemq.apache.org/ INFO ManagementContext - JMX consoles can connect to service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi INFO JDBCPersistenceAdapter - Database driver recognized: [mysql-ab_jdbc_driver] INFO DefaultDatabaseLocker - Attempting to acquire the exclusive lock to become the Master broker INFO DefaultDatabaseLocker - Becoming the master on dataSource: [EMAIL PROTECTED] INFO TransportServerThreadSupport - Listening for connections at: tcp://host2:61616 INFO TransportConnector - Connector openwire Started INFO TransportServerThreadSupport - Listening for connections at: ssl://host2:61617 INFO TransportConnector - Connector ssl Started INFO TransportServerThreadSupport - Listening for connections at: stomp://host2:61613 INFO TransportConnector - Connector stomp Started INFO TransportServerThreadSupport - Listening for connections at: xmpp://host2:61222 INFO TransportConnector - Connector xmpp Started INFO DiscoveryNetworkConnector - Establishing network connection between from vm://mq02 to tcp://localhost:61616 INFO TransportConnector - Connector vm://mq02 Started INFO DiscoveryNetworkConnector - Establishing network connection between from vm://mq02 to tcp://host1:61616 INFO NetworkConnector - Network Connector [EMAIL PROTECTED] Started INFO BrokerService - ActiveMQ JMS Message Broker (mq02, ID:host2-38833-1198747174283-0:0) started INFO DemandForwardingBridge - Disconnecting loop back connection. INFO DemandForwardingBridge - mq02 bridge to mq02 stopped org.apache.activemq.transport.TransportDisposedIOException: Transport disposed. at org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76) at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) at org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:59) at org.apache.activemq.network.DemandForwardingBridgeSupport.serviceRemoteCommand(DemandForwardingBridgeSupport.java:392) at org.apache.activemq.network.DemandForwardingBridgeSupport$2.onCommand(DemandForwardingBridgeSupport.java:149) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:134) at org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:138) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:185) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:172) at java.lang.Thread.run(Thread.java:619) WARN BrokerRegistry - Broker localhost not started so using mq02 instead INFO TransportConnector - Connector vm://localhost Started INFO DemandForwardingBridge - Network connection between vm://mq02#2 and tcp:///host1:61616(mq01) has been established. INFO log - Logging to org.slf4j.impl.JCLLoggerAdapter(org.mortbay.log) via org.mortbay.log.Slf4jLog INFO log - jetty-6.1.4 WARN log - Can't reuse /tmp/Jetty_0_0_0_0_8161_admin__admin__9l5s6p, using /tmp/Jetty_0_0_0_0_8161_admin__admin__9l5s6p_235 INFO WebConsoleStarter - ActiveMQ WebConsole initialized. INFO /admin - Initializing Spring FrameworkServlet 'dispatcher' INFO log - ActiveMQ Console at http://0.0.0.0:8161/admin WARN log - Can't reuse /tmp/Jetty_0_0_0_0_8161_demo__demo__uj3swb, using /tmp/Jetty_0_0_0_0_8161_demo__demo__uj3swb_236 INFO log - ActiveMQ Web Demos at http://0.0.0.0:8161/demo INFO log - Started [EMAIL PROTECTED]:8161 ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe ERROR Service - Async error occurred: javax.jms.JMSException: Durable consumer is in use for client: NC_mq01_inboundmq02 and subscriptionName: [EMAIL PROTECTED] javax.jms.JMSException: Durable consumer is in use for client: NC_mq01_inboundmq02 and subscriptionName: [EMAIL PROTECTED] at org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:75) at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:338) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85) at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:80) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:85) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:95) at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:525) at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:334) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202) at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36) INFO DemandForwardingBridge - Network connection between vm://mq02#6 and tcp:///host1:61616 shutdown due to a local error: javax.jms.JMSException: Durable consumer is in use for client: NC_mq01_inboundmq02 and subscriptionName: [EMAIL PROTECTED] ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe ERROR TransportConnector - Could not accept connection : Broken pipe -- View this message in context: http://www.nabble.com/Master-Slave-Connection-and-Synchronization-Error-tp14511158s2354p14511158.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
