This is a resend of a previous submission with more information.
When I get 3 ActiveMQ servers running in each its own ServiceMIX instance
(separate ports ) with Zookeeper structure of 3 to manage them each running
from a Java command prompt in separate folders ( separate ports ). They form
a Master with Slave A and Slave B.
The activemq.xml and zookeeper config files are attached.
Slave B tries to connect to Master Causing Slave A to disconnect,
then Slave A does a retry connection which causes Slave B to disconnect,
they keep thrashing back-and-forth spitting out exceptions every 2 seconds:
activemq-osgi - 5.10.0 | Using the pure java LevelDB implementation.
activemq-osgi - 5.10.0 | Attaching to master: tcp://localhost:64054
activemq-osgi - 5.10.0 | Slave started
activemq-osgi - 5.10.0 | Attaching... Downloaded 0.00/0.00 kb and 1/1 files
activemq-osgi - 5.10.0 | Attached
activemq-osgi - 5.10.0 | Unexpected session error: java.io.IOException: An
existing connection was forcibly closed by the remote host
activemq-osgi - 5.10.0 | Using the pure java LevelDB implementation.
activemq-osgi - 5.10.0 | Attaching to master: tcp://localhost:64054
activemq-osgi - 5.10.0 | Attaching... Downloaded 0.00/0.00 kb and 1/1 files
activemq-osgi - 5.10.0 | Attached
The Master just says this:
activemq-osgi - 5.10.0 | Slave has connected:
0538866c-63a7-459a-a9ee-c1a8c641b6ab
activemq-osgi - 5.10.0 | Slave has connected:
0538866c-63a7-459a-a9ee-c1a8c641b6ab
activemq-osgi - 5.10.0 | Slave has connected:
0538866c-63a7-459a-a9ee-c1a8c641b6ab
activemq-osgi - 5.10.0 | Slave has connected:
0538866c-63a7-459a-a9ee-c1a8c641b6ab
Must be some sort of port contention to the Master?
I assume this is not the way it is supposed to work.
Craig
<!--
Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE file distributed with
this work for additional information regarding copyright ownership.
The ASF licenses this file to You under the Apache License, Version 2.0
(the "License"); you may not use this file except in compliance with
the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
-->
<beans
xmlns="http://www.springframework.org/schema/beans";
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core.xsd";>
<broker xmlns="http://activemq.apache.org/schema/core";
brokerName="${broker-name}"
dataDirectory="${data}"
start="false">
<destinationPolicy>
<policyMap>
<policyEntries>
<policyEntry topic=">" >
<pendingMessageLimitStrategy>
<constantPendingMessageLimitStrategy limit="1000"/>
</pendingMessageLimitStrategy>
</policyEntry>
</policyEntries>
</policyMap>
</destinationPolicy>
<managementContext>
<managementContext createConnector="false"/>
</managementContext>
<persistenceAdapter>
<replicatedLevelDB
directory="activemq-data"
replicas="3"
bind="tcp://0.0.0.0:61001"
zkAddress="localhost:2191,localhost:2192,localhost:2193"
zkPassword="password"
zkSessionTmeout="200000"
zkPath="/activemq-data/leveldb-stores" hostname="192.168.100.119" />
</persistenceAdapter>
<plugins>
<jaasAuthenticationPlugin configuration="karaf" />
</plugins>
<systemUsage>
<systemUsage>
<memoryUsage>
<memoryUsage percentOfJvmHeap="70"/>
</memoryUsage>
<storeUsage>
<storeUsage limit="100 gb"/>
</storeUsage>
<tempUsage>
<tempUsage limit="50 gb"/>
</tempUsage>
</systemUsage>
</systemUsage>
<transportConnectors>
<!-- DOS protection, limit concurrent connections to 1000 and frame size to 100MB -->
<transportConnector name="openwire" uri="tcp://0.0.0.0:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600"/>
</transportConnectors>
</broker>
</beans>
