connection_closed: sentinel for consumer fifos connection.recv_loop(): try/finally, notify consumers connection.unpack_frame():   allow per-channel consumer fifo   unpack frame header flags with 'H'   handle frame header properties   collect properties and deliver them to fifos connection.make_default_consumer(): make per-channel consumer fifo notify_consumers_of_close(): new nowait: when nowait=true, don't wait for an xxx_ok reply. channel.basic_publish():   implement message properties new methods:   channel.basic_ack()   channel.get_ack()   channel.close()   channel.make_default_consumer() pack_properties() unpack_properties()
connection_closed: sentinel for consumer fifos
connection.recv_loop(): try/finally, notify consumers
connection.unpack_frame():
  allow per-channel consumer fifo
  unpack frame header flags with 'H'
  handle frame header properties
  collect properties and deliver them to fifos
connection.make_default_consumer(): make per-channel consumer fifo
notify_consumers_of_close(): new
nowait: when nowait=true, don't wait for an xxx_ok reply.
channel.basic_publish():
  implement message properties
new methods:
  channel.basic_ack()
  channel.get_ack()
  channel.close()
  channel.make_default_consumer()
pack_properties()
unpack_properties()

mkushnir/amqp-shrapnel