Skip to content

Instantly share code, notes, and snippets.

@only-entertainment
Created October 31, 2012 20:42
Show Gist options
  • Save only-entertainment/3989738 to your computer and use it in GitHub Desktop.
Save only-entertainment/3989738 to your computer and use it in GitHub Desktop.
basic_nack missing from BlockingChannel in Pika 0.9.5
print "Blocking Channel:"
print type(ch)
print dir(ch)
# Works
ch.basic_reject(
delivery_tag=method.delivery_tag,
requeue=True,
)
# Does not work
#ch.basic_nack(
# delivery_tag=method.delivery_tag,
# requeue=True,
#)
# Also, does not work
#super(BlockingChannel, ch).basic_nack(
# delivery_tag=method.delivery_tag,
# requeue=True,
#)
# Prints:
Blocking Channel:
<class 'pika.adapters.blocking_connection.BlockingChannel'>
['__class__', '__delattr__', '__dict__', '__doc__', '__format__', '__getattribute__', '__hash__', '__init__', '__module__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_close', '_consumers', '_on_basic_deliver', '_on_basic_get', '_on_basic_get_empty', '_on_basic_get_ok', '_on_cancel_ok', '_on_channel_flow_ok', '_on_confirm_select_ok', '_on_flow_ok_callback', '_on_get_ok_callback', '_on_open_callback', '_on_remote_close', '_open', '_pending', 'add_callback', 'add_on_close_callback', 'add_on_return_callback', 'basic_ack', 'basic_cancel', 'basic_consume', 'basic_get', 'basic_get_', 'basic_publish', 'basic_qos', 'basic_recover', 'basic_recover_async', 'basic_reject', 'callbacks', 'channel_number', 'close', 'closing', 'confirm_delivery', 'consumer_tags', 'exchange_declare', 'exchange_delete', 'flow', 'queue_bind', 'queue_declare', 'queue_delete', 'queue_purge', 'queue_unbind', 'start_consuming', 'stop_consuming', 'transport', 'tx_commit', 'tx_rollback', 'tx_select']
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment