activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Tim Bain <tb...@alumni.duke.edu>
Subject Re: ActiveMQ: How to retain inflight messages post consumer restart
Date Wed, 07 Jun 2017 05:35:20 GMT
Unsubscribing a topic consumer means that the broker should discard all
messages for that consumer, and not retain any future messages for it. If
the consumer later subscribes again, that is a new subscription that starts
at that time, so only messages sent after that point will be delivered to
the consumer. Messages are not being lost; rather, your consumer is saying
that it doesn't want them.

The behavior you describe sounds like expected behavior in all three cases
you described (hard kill, graceful shutdown with unsubscription, and
graceful shutdown without unsubscription).

Tim

On Jun 6, 2017 11:16 PM, "khandelwalanuj" <anuj.cool.khandelwal@gmail.com>
wrote:

> > That sounds like the remaining inflight messages are getting acknowledged
> > during the process of shutting down gracefully; even though your consumer
> > never received them. Is that accurate? If so, that still sounds like a
> > bug.
>
> My durable consumer received them in client ack mode and didn't acknowledge
> them. So those messages are getting lost(Getting lost mean the consumer
> won't get them back when it come back online) if I gracefully shutdown the
> consumer. In my case gracefully shutdown means I will unsubscribe the
> durable consumer from the topic during shutdown.
>
> If I don't unsubscribe the subscription, the broker mark the consumer as
> inactive durable subscriber and the consumer will get the messages again
> when it subscribe again.
>
> That's an expected behavior I think.
>
> Thanks,
> Anuj
>
>
>
>
> --
> View this message in context: http://activemq.2283324.n4.
> nabble.com/ActiveMQ-How-to-retain-inflight-messages-post-consumer-restart-
> tp4727027p4727134.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message