[rabbitmq-discuss] EOFException when messages in queue

Sun Aug 31 20:34:56 BST 2008

I'm running the AMQPExampleFunPack.actorExample scala example from:
http://github.com/dpp/liftweb/tree/master/lift-amqp/src/main/scala/net/liftweb/amqp/AMQPSender.scala

It was working great until I shutdown the client listeners and
RabbitMQ queued up 2 messages.  Now when I run the
AMQPExampleFunPack.actorExample scala example I get an EOFException.
My questions are 1) is it possible to clear a queue ("routeroute") in
RabbitMQ w/o writing code for it?  2) Is there anything obvious I need
to do to fix the exception, in the event that messages queue up in the
future?

[WARNING] Consumer com.newpers.amqp.SerializedConsumer at 337d0f method
handleDelivery for channel
AMQChannel(amqp://guest@192.168.2.1:5672/,1) threw an exception:
[WARNING] java.io.EOFException
[WARNING]       at
java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2281)
[WARNING]       at
java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2750)
[WARNING]       at
java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:780)
[WARNING]       at java.io.ObjectInputStream.<init>(ObjectInputStream.java:280)
[WARNING]       at
com.newpers.amqp.SerializedConsumer.handleDelivery(AMQPDispatcher.scala:105)
[WARNING]       at
com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:189)
[WARNING]       at
com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:146)
[WARNING]       at
com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:101)
[WARNING]       at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:440)