<div dir="ltr">Hi Bradford,<br>
<br>
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.<br>
<br>
Cheers<br>
Lahiru<br><br><div class="gmail_quote">On Mon, Sep 1, 2008 at 1:04 AM, bradford <span dir="ltr"><<a href="mailto:fingermark@gmail.com">fingermark@gmail.com</a>></span> wrote:<br><blockquote class="gmail_quote" style="border-left: 1px solid rgb(204, 204, 204); margin: 0pt 0pt 0pt 0.8ex; padding-left: 1ex;">
I'm running the AMQPExampleFunPack.actorExample scala example from:<br>
<a href="http://github.com/dpp/liftweb/tree/master/lift-amqp/src/main/scala/net/liftweb/amqp/AMQPSender.scala" target="_blank">http://github.com/dpp/liftweb/tree/master/lift-amqp/src/main/scala/net/liftweb/amqp/AMQPSender.scala</a><br>
<br>
It was working great until I shutdown the client listeners and<br>
RabbitMQ queued up 2 messages. Now when I run the<br>
AMQPExampleFunPack.actorExample scala example I get an EOFException.<br>
My questions are 1) is it possible to clear a queue ("routeroute") in<br>
RabbitMQ w/o writing code for it? 2) Is there anything obvious I need<br>
to do to fix the exception, in the event that messages queue up in the<br>
future?<br>
<br>
[WARNING] Consumer com.newpers.amqp.SerializedConsumer@337d0f method<br>
handleDelivery for channel<br>
AMQChannel(amqp://<a href="http://guest@192.168.2.1:5672/,1" target="_blank">guest@192.168.2.1:5672/,1</a>) threw an exception:<br>
[WARNING] java.io.EOFException<br>
[WARNING] at<br>
java.io.ObjectInputStream$PeekInputStream.readFully(ObjectInputStream.java:2281)<br>
[WARNING] at<br>
java.io.ObjectInputStream$BlockDataInputStream.readShort(ObjectInputStream.java:2750)<br>
[WARNING] at<br>
java.io.ObjectInputStream.readStreamHeader(ObjectInputStream.java:780)<br>
[WARNING] at java.io.ObjectInputStream.<init>(ObjectInputStream.java:280)<br>
[WARNING] at<br>
com.newpers.amqp.SerializedConsumer.handleDelivery(AMQPDispatcher.scala:105)<br>
[WARNING] at<br>
com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:189)<br>
[WARNING] at<br>
com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:146)<br>
[WARNING] at<br>
com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:101)<br>
[WARNING] at<br>
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:440)<br>
<br>
_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
</blockquote></div><br></div>