Cancelling stream consumer

Lars Riis Olsen

unread,

Sep 9, 2021, 10:09:37 AM9/9/21

to rabbitmq-users

Hi,

I am trying to cancel a consumer of a stream using pika (the service needs to keep running but this particular consumer should no longer receive any data). If I do a normal basic_cancel(consumertag) I get a Not_Implemented exception.

Any suggestions?

Arnaud Cogoluègnes

unread,

Sep 9, 2021, 11:51:42 AM9/9/21

to rabbitmq-users

I tried with the AMQP Java client and don't get this message. Anything in the server logs?

Lars Riis Olsen

unread,

Sep 9, 2021, 5:25:27 PM9/9/21

to rabbitmq-users

The server log shows:

operation basic.reject caused a connection exception not_implemented: "basic.nack and basic.reject not supported by stream queues queue

Same error I get in the pika stack trace

Karl Nilsson

unread,

Sep 9, 2021, 5:32:13 PM9/9/21

to rabbitm...@googlegroups.com

Does pika automatically nack pending messages before consumer cancel? If so that feels a bit strange as you can ack messages after consumer cancel.

--
You received this message because you are subscribed to the Google Groups "rabbitmq-users" group.
To unsubscribe from this group and stop receiving emails from it, send an email to rabbitmq-user...@googlegroups.com.
To view this discussion on the web, visit https://groups.google.com/d/msgid/rabbitmq-users/d141c4c2-571e-4974-98ab-7aa6a28aaea9n%40googlegroups.com.