Glassfish Server和ActiveMQ的问题：对等方未发送其有线格式

Question

我在尝试设置JMSPublisher和JMSSubscriber时遇到此错误

jndi.properties

java.naming.factory.initial = org.apache.activemq.jndi.ActiveMQInitialContextFactory
java.naming.provider.url = tcp://localhost:4848?wireFormat.maxInactivityDurationInitalDelay=30000
topic.topic/flightStatus = flightStatus

Glassfish服务器正在运行：http://localhost:4848

发布者：

JmsPublisher publisher= new JmsPublisher("ConnectionFactory", "topic/flightStatus");

...

public JmsPublisher(String factoryName, String topicName) throws JMSException, NamingException {
    Context jndiContext = new InitialContext();
    TopicConnectionFactory factory = (TopicConnectionFactory) jndiContext.lookup(factoryName);
    Topic topic = (Topic) jndiContext.lookup(topicName);
    this.connect = factory.createTopicConnection();
    this.session = connect.createTopicSession(false, Session.AUTO_ACKNOWLEDGE);
    this.publisher = session.createPublisher(topic);
}

Exception：

Exception in thread "main" 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:1395)
    at org.apache.activemq.ActiveMQConnection.ensureConnectionInfoSent(ActiveMQConnection.java:1481)
    at org.apache.activemq.ActiveMQConnection.createSession(ActiveMQConnection.java:323)
    at org.apache.activemq.ActiveMQConnection.createTopicSession(ActiveMQConnection.java:1112)
    at com.mycompany.testejms.JmsPublisher.<init>(JmsPublisher.java:34)
    at com.mycompany.testejms.JmsPublisher.main(JmsPublisher.java:51)
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:98)
    at org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:68)
    at org.apache.activemq.transport.ResponseCorrelator.asyncRequest(ResponseCorrelator.java:81)
    at org.apache.activemq.transport.ResponseCorrelator.request(ResponseCorrelator.java:86)
    at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1366)
    ... 5 more

Answer 1

错误表明ActiveMQ客户端实际上没有与ActiveMQ代理进行通信。 Glassfish可能正在监听http://localhost:4848，但显然不是ActiveMQ代理正在监听连接的地方。据我了解，端口4848是Glassfish Web管理控制台用来监听连接的位置。请注意您提供的URL中的http。默认情况下，ActiveMQ侦听端口61616。