activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From savaki <matt...@gmail.com>
Subject exception from Stomp
Date Thu, 06 Apr 2006 23:28:40 GMT

I'm using the ruby stomp client (stomp-1.0.1) to connect to ActiveMQ-4.0-M4
and am getting the following exception when I try to send a message to AMQ.  

Here's a minimal client that reproduces the problem:

#!/usr/bin/env ruby -w

require 'rubygems'
require 'stomp'

client = Stomp::Client.open
client.subscribe "/queue/sample" do |message|
    puts msg.inspect
end
client.send "/queue/sample", "hello world"
gets
client.close

And here's the stack trace from the ActiveMQ server:

- Async error occurred: java.io.IOException: Message body is write-only
java.io.IOException: Message body is write-only
	at
org.apache.activemq.util.IOExceptionSupport.create(IOExceptionSupport.java:42)
	at
org.apache.activemq.transport.stomp.StompWireFormat.marshal(StompWireFormat.java:298)
	at
org.apache.activemq.transport.tcp.TcpTransport.oneway(TcpTransport.java:117)
	at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
	at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:54)
	at
org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:212)
	at
org.apache.activemq.broker.AbstractConnection.iterate(AbstractConnection.java:551)
	at
org.apache.activemq.thread.SimpleTaskRunner.runTask(SimpleTaskRunner.java:110)
	at
org.apache.activemq.thread.SimpleTaskRunner.access$100(SimpleTaskRunner.java:25)
	at
org.apache.activemq.thread.SimpleTaskRunner$1.run(SimpleTaskRunner.java:43)
	at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:650)
	at
edu.emory.mathcs.backport.java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:675)
	at java.lang.Thread.run(Thread.java:613)
Caused by: javax.jms.MessageNotReadableException: Message body is write-only
	at
org.apache.activemq.command.ActiveMQBytesMessage.checkWriteOnlyBody(ActiveMQBytesMessage.java:706)
	at
org.apache.activemq.command.ActiveMQBytesMessage.initializeReading(ActiveMQBytesMessage.java:711)
	at
org.apache.activemq.command.ActiveMQBytesMessage.getBodyLength(ActiveMQBytesMessage.java:151)
	at
org.apache.activemq.transport.stomp.Subscription.receive(Subscription.java:78)
	at
org.apache.activemq.transport.stomp.StompWireFormat.writeCommand(StompWireFormat.java:143)
	at
org.apache.activemq.transport.stomp.StompWireFormat.marshal(StompWireFormat.java:294)
--
View this message in context: http://www.nabble.com/exception-from-Stomp-t1409177.html#a3795119
Sent from the ActiveMQ - User forum at Nabble.com.


Mime
View raw message