2012-10-09 30 views
0

我製作了一些tutorialish腳本來解決RabbitMQ/Haskell綁定,並且發生了一個奇怪的消息丟失。與突發長度無關,接收端會丟棄少量排隊的消息。我覺得消費者「感覺」數據爆發的結束並放棄是非常令人難以置信的,但這就是我看起來的樣子。接下來的爆發開始愉快,沒有拉入「未接受」的東西。代碼和樣品結果:https://gist.github.com/3859009AMQP失去隊列尾巴?

那裏沒什麼特別,只有一個消費者和一個生產者。我試圖刷新標準輸出,但沒有成功。

+1

您應該顯示其中一個失敗的輸出文件的頭部和尾部。另外,在運行「listen」命令查看隊列深度之前,您應該使用'rabbitmqctl list_queues'。這會讓你知道是否發送或接收失敗。 –

回答

3

跟蹤插件日誌顯示它實際上是一個發送問題。

檢查/var/log/rabbitmq/[email protected]取得了一些警告有關掉線:

=WARNING REPORT==== 10-Oct-2012::10:21:45 === 
closing AMQP connection <0.21203.0> (127.0.0.1:58180 -> 127.0.0.1:5672): 
connection_closed_abruptly 

我已經簽出我的代碼,也的確沒有closeConnection conn在doFlood常規。添加它解決了問題。