メッセージが公開されているかどうか、RabbitMQのステータスを確認しますか？

Question

最終的にメッセージをRabbitMQの交換に公開するイベントで実行される1つのresqueジョブがあります。メッセージが正常に公開されたかどうかをバニー（Rabbit MQ ruby​​クライアント）で確認するにはどうすればいいですか？

謝辞などを使用していますか？

ありがとうございます！

Answer 1

publishメソッドが返されると、メッセージはキューに公開されます。メッセージを公開するための遅延アクションはありません。

Answer 2

publishを実行すると、メッセージがキューに公開されているかどうかわかりません。

必ず使用する必要がある場合は、publish confirmまたはtx transactionを使用する必要があります。

http://www.rabbitmq.com/blog/2011/02/10/introducing-publisher-confirms/

（注）この記事を読む：デフォルトでは、クライアントは任意のHAポリシーを持っていない、あなたはそれを実装する必要があります。

private volatile SortedSet<Long> unconfirmedSet = 

    Collections.synchronizedSortedSet(new TreeSet()); 

... 

ch.setConfirmListener(new ConfirmListener() { 
    public void handleAck(long seqNo, boolean multiple) { 
     if (multiple) { 
      unconfirmedSet.headSet(seqNo+1).clear(); 
     } else { 
      unconfirmedSet.remove(seqNo); 
     } 
    } 
    public void handleNack(long seqNo, boolean multiple) { 
     // handle the lost messages somehow 
    } 
}); 

注2：セクションStreaming Lightweight Publisher Confirmsを参照してくださいメッセージが交換の内部に、常にキュー内の「置く」ことはありません。