[rabbitmq-discuss] EOFException when messages in queue

[lahiru gunathilake]

Hi Bradford,

Yes this would be a feature in RabbitMQ Management, other than that you'll
be able to delete message by message and move one message from one queue to
another, view message content and view message headers.

Cheers
Lahiru

On Mon, Sep 1, 2008 at 1:04 AM, bradford <fingermark at gmail.com> wrote:

> 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)
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20080901/d87ae9b0/attachment.htm