1. Extract the attached tar ball 2. mvn install (pom is set up with 5.11.0.redhat-621084) 3. Start up a broker 4. By default, the client connects to broker @ localhost:61616 as admin:admin. Will optionally read in ACTIVEMQ_HOST, ACTIVEMQ_PORT, ACTIVEMQ_USER, and ACTIVEMQ_PASSWORD env vars 5. Run the following: $ for i in {1..20}; do runp; sleep 1; done It may take a bit, but you will see the EOFExceptions in both client and broker. $ for i in {1..20}; do runp; sleep 1; done INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 226 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 229 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 231 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 225 WARN | Transport (tcp: //localhost:61616) failed, attempting to automatically reconnect java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang. Thread .run( Thread .java:745) INFO | Successfully reconnected to tcp: //localhost:61616 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 224 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 231 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 225 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 298 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 227 WARN | Transport (tcp: //localhost:61616) failed, attempting to automatically reconnect java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang. Thread .run( Thread .java:745) INFO | Successfully reconnected to tcp: //localhost:61616 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 231 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 226 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 242 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 230 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 231 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 238 WARN | Transport (tcp: //localhost:61616) failed, attempting to automatically reconnect java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang. Thread .run( Thread .java:745) INFO | Successfully reconnected to tcp: //localhost:61616 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 231 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 240 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 227 WARN | Transport (tcp: //localhost:61616) failed, attempting to automatically reconnect java.io.EOFException at java.io.DataInputStream.readInt(DataInputStream.java:392) at org.apache.activemq.openwire.OpenWireFormat.unmarshal(OpenWireFormat.java:258) at org.apache.activemq.transport.tcp.TcpTransport.readCommand(TcpTransport.java:221) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:213) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang. Thread .run( Thread .java:745) INFO | Successfully reconnected to tcp: //localhost:61616 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 229 INFO | Successfully connected to tcp: //localhost:61616 .Message sent. Milliseconds to create JMS session and send message: 276