You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by j0llyr0g3r <ti...@wincor-nixdorf.com> on 2007/08/03 19:43:57 UTC
openwire ok, but when using stomp i get: Wire format negociation
timeout: peer did not send his wire format.
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.
Re: openwire ok, but when using stomp i get: Wire format
negociation timeout: peer did not send his wire format.
Posted by Timothy Bish <ti...@sensis.com>.
> Now i added a new connector on a different port like you said:
>
> <transportConnector name="stomp" uri="stomp://localhost:61613"/>
>
> But if i use a connector like that one, isn't specifying the wireFormat in
>
> tcp://172.18.117.126:61613?wireFormat=stomp&transport.useAsyncSend=false
>
> redundant? Because i already specified the wireFormat in the url-connection
> "stomp://" ?
>
>
No, its not. The transport connector that you added to the broker is
known to the broker but not to the client software. ActiveMQ-CPP
doesn't read your brokers xml config file, and there is no magic that
happens when it connects to figure out what protocol is used. You have
to tell it what language to speak that that it can understand the broker
and the broker can understand it.
By default amqcpp uses the openwire protocol, so you don't actually have
to specify it in the URL if you don't want to, but if you are going to
connect to a broker that on a stomp channel, then you need to tell it
that since it can't know ahead of time what protocol is in use at that
URL.
Regards
Tim
Re: openwire ok, but when using stomp i get: Wire format
negociation timeout: peer did not send his wire format.
Posted by j0llyr0g3r <ti...@wincor-nixdorf.com>.
Hi Tim,
thx for the hint.
I don't know why, but somehow i thought that activemq would use some kind
auto-negotiation mechanism.....:-)
Now i added a new connector on a different port like you said:
<transportConnector name="stomp" uri="stomp://localhost:61613"/>
But if i use a connector like that one, isn't specifying the wireFormat in
tcp://172.18.117.126:61613?wireFormat=stomp&transport.useAsyncSend=false
redundant? Because i already specified the wireFormat in the url-connection
"stomp://" ?
Tim Bish wrote:
>
> You need to add a transport connector to the broker for stomp
>
> <transportConnector name="stomp" uri="stomp://localhost:61613"/>
>
> Different protocols don't exist on the same port in the broker, each is
> configured to its own port in the xml file as seen above.
>
> Then connect using the correct uri via the c++ client
> tcp://172.18.117.126:61613?wireFormat=stomp&transport.useAsyncSend=false
>
> j0llyr0g3r wrote:
>> 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#a12012765
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: openwire ok, but when using stomp i get: Wire format negociation
timeout: peer did not send his wire format.
Posted by Timothy Bish <ta...@twcny.rr.com>.
You need to add a transport connector to the broker for stomp
<transportConnector name="stomp" uri="stomp://localhost:61613"/>
Different protocols don't exist on the same port in the broker, each is
configured to its own port in the xml file as seen above.
Then connect using the correct uri via the c++ client
tcp://172.18.117.126:61613?wireFormat=stomp&transport.useAsyncSend=false
j0llyr0g3r wrote:
> 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.
>
>