Return-Path: 
 <users-return-10130-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org>
Delivered-To: apmail-activemq-users-archive@www.apache.org
Received: (qmail 99588 invoked from network); 3 Aug 2007 17:44:29 -0000
Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2)
  by minotaur.apache.org with SMTP; 3 Aug 2007 17:44:29 -0000
Received: (qmail 5105 invoked by uid 500); 3 Aug 2007 17:44:29 -0000
Delivered-To: apmail-activemq-users-archive@activemq.apache.org
Received: (qmail 4802 invoked by uid 500); 3 Aug 2007 17:44:28 -0000
Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@activemq.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@activemq.apache.org>
List-Post: <mailto:users@activemq.apache.org>
List-Id: <users.activemq.apache.org>
Reply-To: users@activemq.apache.org
Delivered-To: mailing list users@activemq.apache.org
Received: (qmail 4793 invoked by uid 99); 3 Aug 2007 17:44:28 -0000
Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Aug 2007 10:44:28 -0700
X-ASF-Spam-Status: No, hits=2.6 required=10.0
	tests=DNS_FROM_OPENWHOIS,SPF_HELO_PASS,SPF_PASS,WHOIS_MYPRIVREG
X-Spam-Check-By: apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158)
    by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 03 Aug 2007 17:44:01 +0000
Received: from isper.nabble.com ([192.168.236.156])
	by kuber.nabble.com with esmtp (Exim 4.63)
	(envelope-from <lists@nabble.com>)
	id 1IH1Bt-0002hT-MX
	for users@activemq.apache.org; Fri, 03 Aug 2007 10:43:57 -0700
Message-ID: <11987990.post@talk.nabble.com>
Date: Fri, 3 Aug 2007 10:43:57 -0700 (PDT)
From: j0llyr0g3r <timo.roessner@wincor-nixdorf.com>
To: users@activemq.apache.org
Subject: openwire ok, but when using stomp i get: Wire format negociation
 timeout: peer did not send his wire format.
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit
X-Nabble-From: timo.roessner@wincor-nixdorf.com
X-Virus-Checked: Checked by ClamAV on apache.org


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.