Hi,
I have a network of 4 brokers, statically configured (<networkConnector
uri="static:(tcp://IP1:61617,tcp://IP2:61617,tcp://IP3:61617)"
networkTTL="-1" decreaseNetworkConsumerPriority="true" />). Each broker has
a list if IPs, excluding its own.
It is expected that not all brokers are running at the same time (they can,
but don't have to).
I have (java) clients that run on the same machines as the brokers and
connect to their localhost broker and I have clients that are running on
separate machines, connecting to one of the 4 (remote) brokers.
1. The activemq log files are being spammed with exceptions that the
connection to the brokers (that are down) fail (see below). This was not the
case with older versions (it was only a warning, I believe). I cannot use
dynamic discovery because multicast is not allowed on the network. I am not
sure if my setup is incorrect or if I just need to change the log4j to not
log these exceptions. Like I said, it's expected that not all brokers are
running at all times. Suppressing the exceptions via log4j seems not really
correct to me.
2. The remote brokers use a list of IPs with
failover:(IPs)?randomize=true&backup=true...
This seems to be working fine, except for if one of the IPs is not
reachable. This does not always happen, but if I for example add as the
first IP some bogus IP, the remote client will not communicate with the
remote broker at all. Lets say I have BOGUS_IP, CORRECT_IP in the list, I
can see it says it connects to the CORRECT_IP, but does not send or receive
any messages. The clients have multiple consumers and producers and on some
producers the session seems to be null and other weird behavior is
happening.
In the admin console of the broker that is running, I do see the connections
from the remote client though. Any ideas what that could be?
Thanks in advance.
<code>
WARN | Could not start network bridge between: vm://SRV1 and:
tcp://IP3:61617 due to: Connection timed out: connect
INFO | Establishing network connection from vm://SRV1 to tcp://IP2:61617
INFO | Connector vm://SRV1 started
INFO | Establishing network connection from vm://SRV1 to tcp://IP1:61617
INFO | Establishing network connection from vm://SRV1 to tcp://IP3:61617
INFO | SRV1 Shutting down NC
WARN | Could not start network bridge between: vm://SRV1 and:
tcp://IP1:61617 due to: Connection refused: connect
INFO | SRV1 bridge to Unknown stopped
INFO | error with pending local brokerInfo on: vm://SRV1#222
org.apache.activemq.transport.TransportDisposedIOException: peer
(vm://SRV1#223) stopped.
at
org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:233)[activemq-broker-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1193)[activemq-broker-5.15.2.jar:5.15.2]
at
org.apache.activemq.broker.TransportConnection$4.run(TransportConnection.java:1159)[activemq-broker-5.15.2.jar:5.15.2]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_152]
INFO | SRV1 Shutting down NC
WARN | Could not start network bridge between: vm://SRV1 and:
tcp://IP2:61617 due to: Connection refused: connect
INFO | SRV1 bridge to Unknown stopped
INFO | error with pending local brokerInfo on: vm://SRV1#224
org.apache.activemq.transport.TransportDisposedIOException: peer
(vm://SRV1#225) stopped.
at
org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:233)[activemq-broker-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1193)[activemq-broker-5.15.2.jar:5.15.2]
at
org.apache.activemq.broker.TransportConnection$4.run(TransportConnection.java:1159)[activemq-broker-5.15.2.jar:5.15.2]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_152]
INFO | SRV1 Shutting down NC
INFO | SRV1 bridge to Unknown stopped
INFO | error with pending local brokerInfo on: vm://SRV1#220
org.apache.activemq.transport.TransportDisposedIOException: peer
(vm://SRV#221) stopped.
at
org.apache.activemq.transport.vm.VMTransport.stop(VMTransport.java:233)[activemq-broker-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.TransportFilter.stop(TransportFilter.java:72)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.transport.ResponseCorrelator.stop(ResponseCorrelator.java:132)[activemq-client-5.15.2.jar:5.15.2]
at
org.apache.activemq.broker.TransportConnection.doStop(TransportConnection.java:1193)[activemq-broker-5.15.2.jar:5.15.2]
at
org.apache.activemq.broker.TransportConnection$4.run(TransportConnection.java:1159)[activemq-broker-5.15.2.jar:5.15.2]
at java.lang.Thread.run(Thread.java:748)[:1.8.0_152]
INFO | Connector vm://SRV1 stopped
</code>
--
Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html
