javax.jms.JMSException: Wire format negociation timeout: peer did not send his w

在应用activemq 过程中 ，进行压力测试一段时间后出现，javax.jms.JMSException: Wire format negociation timeout: peer did not send his wire format.
javax.jms.JMSException: Wire format negociation timeout: peer did not send his wire format.
at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:58)
at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1185)
at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1263)
at org.apache.activemq.ActiveMQConnection.start(ActiveMQConnection.java:449)

错误。

我的spring 相关配置文件为
<bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="failover://(tcp://127.0.0.1:61676)?initialReconnectDelay=30000&amp;maxReconnectAttempts=15" />
<property name="userName" value="" />
<property name="password" value="" />
</bean>
</property>
</bean>

=========================
官方提faq已对这个问题进行描述
出现这个问题有三种
1.确定能连通到mq
  You're connecting to the port not used by ActiveMQ TCP transport
Make sure to check that you're connecting to the appropriate host:port
2.说的是关于日志的
这个我没细看
3.在网络不稳定的情况需要加上wireFormat.maxInactivityDurationInitalDelay
我把spring 配置文件更改为
<bean id="connectionFactory" class="org.apache.activemq.pool.PooledConnectionFactory" destroy-method="stop">
<property name="connectionFactory">
<bean class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="tcp://127.0.0.1:61676?wireFormat.maxInactivityDurationInitalDelay=30000" />
<property name="userName" value="" />
<property name="password" value="" />
</bean>
</property>
</bean>

在测试ok

评论

1 楼 wo1769815 2015-01-12  

压力测试用的什么工具，求教！