activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j0llyr0g3r <timo.roess...@wincor-nixdorf.com>
Subject openwire ok, but when using stomp i get: Wire format negociation timeout: peer did not send his wire format.
Date Fri, 03 Aug 2007 17:43:57 GMT

Hi folks, 

i get the above error message and i am absolutely clueless about what to do.
I googled a lot, many hits deal with the same error message but with a quite
different situation (in most cases the error occurs when the broker shuts
down)

The situation:

I got activemq running with one single, simple Broker:

<beans>

  <!-- Allows us to use system properties as variables in this configuration
file -->
  <bean
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"/>

  <broker brokerName="singleBroker" useJmx="true"
xmlns="http://activemq.org/config/1.0">

    <!-- Use the following to configure how ActiveMQ is exposed in JMX -->
    <managementContext>
       <managementContext connectorPort="4444"
jmxDomainName="org.apache.activemq"/>
    </managementContext>


    <!-- In ActiveMQ 4, you can setup destination policies -->
    <destinationPolicy>
      <policyMap><policyEntries>

          <policyEntry topic="ice">
            <dispatchPolicy>
              <strictOrderDispatchPolicy />
            </dispatchPolicy>
            <subscriptionRecoveryPolicy>
              <lastImageSubscriptionRecoveryPolicy />
            </subscriptionRecoveryPolicy>
          </policyEntry>

      </policyEntries></policyMap>
    </destinationPolicy>

    <transportConnectors>
       <transportConnector uri="tcp://localhost:61616"
discoveryUri="multicast://default"/>
    </transportConnectors>

  </broker>
</beans>

Now i have a simple Consumer and Producer based on activmq-cpp and the
example source-code they provide.

Both consumer and producer work well but __only__ if i use openwire.

If i start the consumer/ producer with a URL like:

tcp://172.18.117.126:61618?wireFormat=openwire&transport.useAsyncSend=false

everything is fine and i see that the consumer receives the messages sent to
him by the producer.

But if i alter the URL to use stomp as wireformat:

tcp://172.18.117.126:61618?wireFormat=stomp&transport.useAsyncSend=false

I get the following errors when i start the consumer:

=====================================================
Starting the Demo-Consumer:
-----------------------------------------------------
Broker URI:
tcp://172.18.117.126:61618?wireFormat=stomp&transport.useAsyncSend=false
useTopic: true
WARNING: activemq::io::SocketInputStream::read - The connection is broken
        FILE: activemq/network/SocketInputStream.cpp, LINE: 147
        FILE: activemq/io/BufferedInputStream.cpp, LINE: 199
        FILE: activemq/io/BufferedInputStream.cpp, LINE: 83
        FILE: activemq/connector/stomp/StompCommandReader.cpp, LINE: 216
        FILE: activemq/connector/stomp/StompCommandReader.cpp, LINE: 120
        FILE: activemq/connector/stomp/StompCommandReader.cpp, LINE: 71
        FILE: activemq/transport/IOTransport.cpp, LINE: 175
 - tid: 3075550096
response from futureResponse was invalid
        FILE: activemq/transport/ResponseCorrelator.cpp, LINE: 145
        FILE: activemq/transport/ResponseCorrelator.cpp, LINE: 152
        FILE: activemq/connector/stomp/StompConnector.cpp, LINE: 256
        FILE: activemq/connector/stomp/StompConnector.cpp, LINE: 165
        FILE: activemq/core/ActiveMQConnectionFactory.cpp, LINE: 190

These are the same error messages when i start up the producer:

=====================================================
Starting the Demo-Producer:
-----------------------------------------------------
Broker URI:
tcp://172.18.117.126:61616?wireFormat=stomp&transport.useAsyncSend=true
useTopic: false
WARNING: activemq::io::SocketInputStream::read - The connection is broken
        FILE: activemq/network/SocketInputStream.cpp, LINE: 147
        FILE: activemq/io/BufferedInputStream.cpp, LINE: 199
        FILE: activemq/io/BufferedInputStream.cpp, LINE: 83
        FILE: activemq/connector/stomp/StompCommandReader.cpp, LINE: 216
        FILE: activemq/connector/stomp/StompCommandReader.cpp, LINE: 120
        FILE: activemq/connector/stomp/StompCommandReader.cpp, LINE: 71
        FILE: activemq/transport/IOTransport.cpp, LINE: 175
 - tid: 3075644304
response from futureResponse was invalid
        FILE: activemq/transport/ResponseCorrelator.cpp, LINE: 145
        FILE: activemq/transport/ResponseCorrelator.cpp, LINE: 152
        FILE: activemq/connector/stomp/StompConnector.cpp, LINE: 256
        FILE: activemq/connector/stomp/StompConnector.cpp, LINE: 165
        FILE: activemq/core/ActiveMQConnectionFactory.cpp, LINE: 190
-----------------------------------------------------
Finished with the demo ignore errors from this
point on as the sockets breaks when we shutdown.
=====================================================

Meanwhile activemq prints out:

ERROR TransportConnector             - Could not accept connection from
/172.18.103.79:55128: java.io.IOException: Wire format negociation timeout:
peer did not send his wire format.
java.io.IOException: Wire format negociation timeout: peer did not send his
wire format.
        at
org.apache.activemq.transport.WireFormatNegotiator.oneway(WireFormatNegotiator.java:88)
        at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:47)
        at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1138)
        at
org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:805)
        at
org.apache.activemq.broker.TransportConnection.start(TransportConnection.java:885)
        at
org.apache.activemq.broker.TransportConnector$1.onAccept(TransportConnector.java:148)
        at
org.apache.activemq.transport.tcp.TcpTransportServer.run(TcpTransportServer.java:167)
        at java.lang.Thread.run(Thread.java:595)

Especially this line is interesting:

Wire format negociation timeout: peer did not send his wire format.

But i do send the wireFormat, why do i keep getting that error?

Thx for every help folks...

P.S. 

All software (activemq + activemq-cpp) is up-to-date, meaning the current
stable version. 

-- 
View this message in context: http://www.nabble.com/openwire-ok%2C-but-when-using-stomp-i-get%3A-Wire-format-negociation-timeout%3A-peer-did-not-send-his-wire-format.-tf4213918s2354.html#a11987990
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message