Hi,
We are using ActiveMQ 5.1 (with Spring JMSTemplate) and have faced this
problem for the first time and are unable to find the reason for this issue.
Let me relate the scenario first.
We have two applications running which interact with each other to send and
receive messages.
The first application maintains 2 local queues for reading and writing data
respectively. The second app too maintains such queues. Now, the first
application opens up a jms connector bridge to the second applications
queues to read/write data.
We are using the spring JMSTemplate for publish/subscribe and have created
wrappers around it. Also, we are injecting the default
ActiveMQConnectionFactory, and not using the PooledConnectionFactory.
Below is the log when the second app (which does not establish the bridge)
tries to read/write data from its local queues.
[ERROR] 10:18:46 queue - Unexpected error reading from
queues.gateway.inbound.persistent.queue
org.springframework.jms.UncategorizedJmsException: Uncategorized exception
occured during JMS processing; nested exception is javax.jms.JMSException:
Wire format negotiation timeout: peer did not send his wire format.; nested
exception is java.io.IOException: Wire format negotiation timeout: peer did
not send his wire format.
javax.jms.JMSException: Wire format negotiation timeout: peer did not send
his wire format.
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1206)
at
org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1289)
at
org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:456)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:422)
at
org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:619)
at
org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:606)
at com.iris.ogdgateway.jms.Receiver.run(Receiver.java:133)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.io.IOException: Wire format negotiation timeout: peer did
not send his wire format.
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:94)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:74)
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:79)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1195)
... 7 more
[ INFO] 10:18:46 queue - Sleeping for 60,000 ms
[ERROR] 10:18:51 queue - Unexpected error reading from
queues.gateway.inbound.info.queue
org.springframework.jms.UncategorizedJmsException: Uncategorized exception
occured during JMS processing; nested exception is javax.jms.JMSException:
Wire format negotiation timeout: peer did not send his wire format.; nested
exception is java.io.IOException: Wire format negotiation timeout: peer did
not send his wire format.
javax.jms.JMSException: Wire format negotiation timeout: peer did not send
his wire format.
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1206)
at
org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1289)
at
org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:456)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:422)
at
org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:619)
at
org.springframework.jms.core.JmsTemplate.receive(JmsTemplate.java:606)
at com.iris.ogdgateway.jms.Receiver.run(Receiver.java:133)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.io.IOException: Wire format negotiation timeout: peer did
not send his wire format.
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:94)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:74)
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:79)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1195)
... 7 more
[FATAL] 10:18:51 OGDMessageProducer - Failed sending message
org.springframework.jms.UncategorizedJmsException: Uncategorized exception
occured during JMS processing; nested exception is javax.jms.JMSException:
Wire format negotiation timeout: peer did not send his wire format.; nested
exception is java.io.IOException: Wire format negotiation timeout: peer did
not send his wire format.
javax.jms.JMSException: Wire format negotiation timeout: peer did not send
his wire format.
at
org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:62)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1206)
at
org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1289)
at
org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:295)
at
org.springframework.jms.core.JmsTemplate.createSession(JmsTemplate.java:771)
at
org.springframework.jms.core.JmsTemplate.execute(JmsTemplate.java:424)
at org.springframework.jms.core.JmsTemplate.send(JmsTemplate.java:486)
at com.iris.ogdgateway.jms.Sender.onMessage(Sender.java:74)
at
com.iris.ogdgateway.impl.OGDMessageProducer.processMessage(OGDMessageProducer.java:155)
at
com.iris.ogdgateway.impl.OGDMessageProducer.run(OGDMessageProducer.java:116)
at java.lang.Thread.run(Thread.java:619)
Caused by: java.io.IOException: Wire format negotiation timeout: peer did
not send his wire format.
at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:94)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40)
at
org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:74)
at
org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:79)
at
org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1195)
... 9 more
[ INFO] 10:18:51 queue - Sleeping for 60,000 ms
The above exception trace keeps repeating.
We have done some browsing and found that there is an existing issue which
has been logged and which is slated to be fixed in version 5.3.
https://issues.apache.org/activemq/browse/AMQ-1473
Could anyone help us out with the above?
Thanks
Kaustubh
--
View this message in context:
http://www.nabble.com/Wire-format-negotiation-timeout%3A-peer-did-not-send-his-wire-format-tp22491499p22491499.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
