I have experienced an issue with the above: in the case that the
FailoverTransport attempts to connect to a broker configured for SSL using tcp:
scheme it loops forever seeking to (re-)establish a connection .
I am concerned at the impact this may have on our product, in that it is
consumed and configured by others.
Sorry, I have not attempted a fix for this at this time because of the
complexity of the code and the implied risks.
Details
Configure Broker to support Openwire/ssl:
<transportConnector name="openwire"
uri="ssl://0.0.0.0:61616?transport.enabledProtocols=TLSv1.2;maximumConnections=1000&wireFormat.maxFrameSize=104857600&transport.keepAliveResponseRequired=true"/>
Connect client to:
failover:tcp://ServerFQDN:61616?connection.useCompression=true&connectionTimeout=1000&startupMaxReconnectAttempts=2&maxReconnectAttempts=2&initialReconnectDelay=100&requestTimeout=2000
Or
failover:(tcp://ServerFQDN:61616?connection.useCompression=true&connectionTimeout=1000&startupMaxReconnectAttempts=2&maxReconnectAttempts=2&initialReconnectDelay=100&requestTimeout=2000)
behaviour is the same
.
WireShark shows
173 2875.699885 {Client IP Addr} {Server IP Addr} TCP 66 51094 → 61616
[SYN] Seq=0 Win=8192 Len=0 MSS=1460 WS=256 SACK_PERM=1
174 2875.726665 {Server IP Addr} {Client IP Addr} TCP 66 61616 → 51094
[SYN, ACK] Seq=0 Ack=1 Win=65535 Len=0 MSS=1350 WS=256 SACK_PERM=1
175 2875.726791 {Client IP Addr} {Server IP Addr} TCP 54 51094 → 61616
[ACK] Seq=1 Ack=1 Win=66048 Len=0
176 2875.729875 {Client IP Addr} {Server IP Addr} OpenWire 276
WireFormatInfo
177 2875.757213 {Server IP Addr} {Client IP Addr} TCP 61 61616 → 51094
[PSH, ACK] Seq=1 Ack=223 Win=262400 Len=7 [TCP segment of a reassembled PDU]
178 2875.757213 {Server IP Addr} {Client IP Addr} TCP 60 61616 → 51094
[FIN, ACK] Seq=8 Ack=223 Win=262400 Len=0
Log output
2021-05-28 15:34:13.7334|INFO|ActiveMq|Connecting to:
failover:tcp://ServerFQDN:61616?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:13.7334|DEBUG|ActiveMq|Searching Assembly:
Apache.NMS.ActiveMQfor factory of the id: failover
2021-05-28 15:34:13.8004|DEBUG|ActiveMq|Found the Factory of type
Apache.NMS.ActiveMQ.Transport.Failover.FailoverTransportFactory for id: failover
2021-05-28 15:34:13.8114|DEBUG|ActiveMq|Reconnect was triggered but transport
is not started yet. Wait for start to connect the transport.
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|FailoverTransport Started.
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|FailoverTransport not connected, start
is reconnecting.
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|Waking up reconnect task
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|Uri connection list:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
from:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|Attempting 0th connect to:
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|Searching Assembly:
Apache.NMS.ActiveMQfor factory of the id: tcp
2021-05-28 15:34:14.0964|DEBUG|ActiveMq|Found the Factory of type
Apache.NMS.ActiveMQ.Transport.Tcp.TcpTransportFactory for id: tcp
2021-05-28 15:34:14.1054|DEBUG|ActiveMq|Opening socket to: ServerFQDN on port:
61616
2021-05-28 15:34:14.2384|DEBUG|ActiveMq|Connected to ServerFQDN:61616 using
InterNetwork protocol.
2021-05-28 15:34:14.2534|DEBUG|ActiveMq|Creating Inactivity Monitor: 1
2021-05-28 15:34:14.3274|DEBUG|ActiveMq|Connection established
2021-05-28
15:34:14.3274|DEBUG|ActiveMq|Connection[ID:ClientName-58739-637578128539854785-1:0]:
Transport has resumed normal operation.Connection resumed
2021-05-28 15:34:14.3274|INFO|ActiveMq|Successfully connected to
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:14.3894|DEBUG|ActiveMq|Exception received in the Inactivity
Monitor: Unable to read beyond the end of the stream.
2021-05-28 15:34:14.3894|DEBUG|ActiveMq|InactivityMonitor[1]: Stopped Monitor
Threads.
2021-05-28 15:34:14.4254|DEBUG|ActiveMq|InactivityMonitor[1]: Stopped Monitor
Threads.
2021-05-28 15:34:14.4324|DEBUG|ActiveMq|Send Oneway attempt: 0 failed: Message
= Channel was inactive for too long:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:14.4324|DEBUG|ActiveMq|Failed Message Was: ConnectionInfo[
commandId = 1, responseRequired = True, ConnectionId =
ID:ClientName-58739-637578128539854785-1:0, ClientId = Client id 27, Password =
{password}, UserName = {username}, BrokerPath = , BrokerMasterConnector =
False, Manageable = False, ClientMaster = False, FaultTolerant = True,
FailoverReconnect = False, ClientIp = ]
2021-05-28 15:34:14.4324|WARN|ActiveMq|Transport failed to
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2,
attempting to automatically reconnect due to: Unable to read beyond the end of
the stream.
2021-05-28
15:34:14.4324|DEBUG|ActiveMq|Connection[ID:ClientName-58739-637578128539854785-1:0]:
Transport has been Interrupted.
2021-05-28
15:34:14.4324|DEBUG|ActiveMq|Connection[ID:ClientName-58739-637578128539854785-1:0]:
Transport interrupted, dispatchers: 0Connection interrupted
2021-05-28 15:34:14.4324|DEBUG|ActiveMq|Uri connection list:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
from:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:14.4484|DEBUG|ActiveMq|Waiting 10 ms before attempting
connection.
2021-05-28 15:34:14.4484|DEBUG|ActiveMq|Attempting 0th connect to:
2021-05-28 15:34:14.4484|DEBUG|ActiveMq|Opening socket to: ServerFQDN on port:
61616
2021-05-28 15:34:14.4874|DEBUG|ActiveMq|Connected to ServerFQDN:61616 using
InterNetwork protocol.
2021-05-28 15:34:14.4874|DEBUG|ActiveMq|Creating Inactivity Monitor: 2
2021-05-28 15:34:14.4874|INFO|ActiveMq|Restoring previous transport connection.
2021-05-28 15:34:14.5324|DEBUG|ActiveMq|Exception received in the Inactivity
Monitor: Unable to read beyond the end of the stream.
2021-05-28 15:34:14.5324|DEBUG|ActiveMq|InactivityMonitor[2]: Stopped Monitor
Threads.
2021-05-28 15:34:14.5594|DEBUG|ActiveMq|Connect fail to:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2,
reason:Channel was inactive for too long:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:14.5594|DEBUG|ActiveMq|InactivityMonitor[2]: Stopped Monitor
Threads.
2021-05-28 15:34:14.5594|DEBUG|ActiveMq|Waiting 10 ms before attempting
connection
2021-05-28 15:34:14.5754|DEBUG|ActiveMq|Uri connection list:
tcp://ServerFQDN:61616/?initialreconnectdelay=100&maxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
from:cp://ServerFQDN:61616/?initialreconnectdelay=100&mxreconnectattempts=2&requesttimeout=2000&connectiontimeout=1000&startupmaxreconnectattempts=2
2021-05-28 15:34:14.5754|DEBUG|ActiveMq|Waiting 20 ms before attempting
connection.
2021-05-28 15:34:14.5964|DEBUG|ActiveMq|Attempting 1th connect to:2021-05-28
15:34:14.5964|DEBUG|ActiveMq|Opening socket to: ServerFQDN on port: 61616
2021-05-28 15:34:14.6194|DEBUG|ActiveMq|Connected to ServerFQDN:61616 using
InterNetwork protocol.
2021-05-28 15:34:14.6194|DEBUG|ActiveMq|Creating Inactivity Monitor: 3
2021-05-28 15:34:14.6194|INFO|ActiveMq|Restoring previous transport connection.
2021-05-28 15:34:14.6624|DEBUG|ActiveMq|Exception received in the Inactivity
Monitor: Unable to read beyond the end of the stream.
… this continues, apparently indefinitely
Thank you,
Julian
_________________________________________________________________________________________________________________________________________________________________________________________________________________________________
\x93This message is for information purposes only, it is not a recommendation,
advice, offer or solicitation to buy or sell a product or service nor an
official confirmation of any transaction. It is directed at persons who are
professionals and is not intended for retail customer use. Intended for
recipient only. This message is subject to the terms at:
www.barclays.com/emaildisclaimer.
For important disclosures, please see:
www.barclays.com/salesandtradingdisclaimer regarding market commentary from
Barclays Sales and/or Trading, who are active market participants;
https://www.investmentbank.barclays.com/disclosures/barclays-global-markets-disclosures.html
regarding our standard terms for the Investment Bank of Barclays where we
trade with you in principal-to-principal wholesale markets transactions; and in
respect of Barclays Research, including disclosures relating to specific
issuers, please see http://publicresearch.barclays.com.\x94
_________________________________________________________________________________________________________________________________________________________________________________________________________________________________
If you are incorporated or operating in Australia, please see
https://www.home.barclays/disclosures/importantapacdisclosures.html for
important disclosure.
_________________________________________________________________________________________________________________________________________________________________________________________________________________________________
How we use personal information see our privacy notice
https://www.investmentbank.barclays.com/disclosures/personalinformationuse.html
_________________________________________________________________________________________________________________________________________________________________________________________________________________________________
