Hi

We are facing we a strange issue in an publisher/subscriber scenario, we have some queues with messages ready but not "consumed" by consumer.
The consumer seems to be up and running, the exchange and the queue are correctly linked.
Our queues and exchanges are not durable.
There are no warnings or errors in log file, how we can deeply debug that problem?
Someone else has a similar problem?

Regards
--
Andrea
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20110812/08cc17ad/attachment.htm>

Search Discussions

  • Emile Joubert at Aug 12, 2011 at 12:43 pm
    Hi Andrea,
    On 12/08/11 10:51, Rosa, Andrea wrote:
    We are facing we a strange issue in an publisher/subscriber scenario, we
    have some queues with messages ready but not ?consumed? by consumer.
    Can you describe how to you are consuming the messages - are you using
    synchronous (basic.get) or asynchronous (basic.consume) delivery?

    Are you sure the queue contains messages? What does "rabbitmqctl
    list_queues name messages_ready messages_unacknowledged consumers" return?


    -Emile
  • Rosa, Andrea at Aug 12, 2011 at 4:04 pm

    Hi Andrea,
    On 12/08/11 10:51, Rosa, Andrea wrote:
    We are facing we a strange issue in an publisher/subscriber scenario, we
    have some queues with messages ready but not "consumed" by consumer.
    Can you describe how to you are consuming the messages - are you using
    synchronous (basic.get) or asynchronous (basic.consume) delivery?
    We have asynchronous delivery.
    Are you sure the queue contains messages? What does "rabbitmqctl
    list_queues name messages_ready messages_unacknowledged consumers"
    return?
    The unack messages is equal to 0 but there are some ready messages in the queues

    -Emile
    --
    Andrea
  • Emile Joubert at Aug 12, 2011 at 4:18 pm
    Hi Andrea,
    On 12/08/11 17:04, Rosa, Andrea wrote:

    Are you sure the queue contains messages? What does "rabbitmqctl
    list_queues name messages_ready messages_unacknowledged consumers"
    return?
    The unack messages is equal to 0 but there are some ready messages in the queues
    And the last "consumers" column? How many consumers does the broker
    think are subscribed? If the client receives messages asynchronously
    then the number should be 1 or greater.

    Something else to check is whether the consumer has asserted channel
    flow. That will prevent the broker from delivering messages on the
    channel. You can confirm this with
    "rabbitmqctl list_channels client_flow_blocked"


    -Emile
  • Rosa, Andrea at Aug 12, 2011 at 5:45 pm

    Hi Andrea,
    On 12/08/11 17:04, Rosa, Andrea wrote:

    Are you sure the queue contains messages? What does "rabbitmqctl
    list_queues name messages_ready messages_unacknowledged consumers"
    return?
    The unack messages is equal to 0 but there are some ready messages in
    the queues

    And the last "consumers" column? How many consumers does the broker
    think are subscribed? If the client receives messages asynchronously
    then the number should be 1 or greater.
    Ok I verified that the consumers number is equal to 0 so I guess that the problem is not
    rabbitmq but with our consumers that for some reasons lose the connection
    and don't manage properly the reconnection with the server.
    Something else to check is whether the consumer has asserted channel
    flow. That will prevent the broker from delivering messages on the
    channel. You can confirm this with
    "rabbitmqctl list_channels client_flow_blocked"
    For that the value is False

    -Emile
    Thanks for your help
    --
    andrea

Related Discussions

Discussion Navigation
viewthread | post
Discussion Overview
grouprabbitmq-discuss @
categoriesrabbitmq
postedAug 12, '11 at 9:51a
activeAug 12, '11 at 5:45p
posts5
users2
websiterabbitmq.com
irc#rabbitmq

2 users in discussion

Rosa, Andrea: 3 posts Emile Joubert: 2 posts

People

Translate

site design / logo © 2023 Grokbase