使用spring amqp模板清除rabbitmq队列？

我在spring批处理项目编写器中使用spring amqp模板将消息添加到rabbitmq队列中。

public class AmqpAsynchRpcItemWriter<T> implements ItemWriter<T> {

    protected String exchange;
    protected String routingKey;
    protected String queue;
    protected String replyQueue;
    protected RabbitTemplate template;
    BlockingQueue<Object> blockingQueue;


    public void onMessage(Object msgContent) {

        try {
            blockingQueue.put(msgContent);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }


    }

    @Override
    public void write(List<? extends T> items) throws Exception {

        for (T item : items) {

            Message message = MessageBuilder
                    .withBody(item.toString().getBytes())
                    .setContentType(MessageProperties.CONTENT_TYPE_TEXT_PLAIN)
                    .setReplyTo(this.replyQueue)
                    .setCorrelationId(item.toString().getBytes()).build();

            template.send(this.exchange, this.routingKey, message);

        }

        for (T item : items) {

            Object msg = blockingQueue.poll(60, TimeUnit.SECONDS);

            if (msg instanceof Exception) {
                throw (Exception) msg;
            } else if (msg == null) {
                System.out.println("reply timeout...");
                break;
            } 

        }
    }

}

消息将在不同的远程服务器上处理。 我试图处理用例，如果我的消息处理失败（由于某些例外），步骤执行将会停止。

我想清除该队列中剩余的所有消息，以便队列中剩余的消息不应被消耗和处理，因为它们也会失败。

如果步骤失败，我的项目编写器将再次排队所有消息，所以我需要清除所有其他消息。

我如何使用spring amqp清除队列？

---

我可以使用它

admin.purgeQueue（this.queue，true）;

---

我会用RabbitAdmin代替

http://docs.spring.io/autorepo/docs/spring-amqp-dist/1.3.4.RELEASE/api/org/springframework/amqp/rabbit/core/RabbitAdmin.html#purgeQueue%28java.lang.String， ％20boolean 29％

@Autowired私人RabbitAdmin管理员;

...

admin.purgeQueue（“queueName”，false）;

---

您可以使用

AMQP.Queue.PurgeOk queuePurge(java.lang.String queue)

“请参阅queuePurge：

http://www.rabbitmq.com/amqp-0-9-1-quickref.html#queue.purge”

链接地址: http://www.djcxy.com/p/59645.html

上一篇: purge rabbitmq queue using spring amqp template?

下一篇: Different dead