Sha256: f36dc63c6896b9851405272c85be9f99999b58029f4ecda7413d7d6ae0473ff0
Contents?: true
Size: 1.17 KB
Versions: 3
Compression:
Stored size: 1.17 KB
Contents
- breaks with header values that are nil (deleting nil headers in Exchange#publish for now) - generate amqp/spec.rb from original xml spec - add peek and pop to queues - use rabbitmq generated consumer tag from basic.consume-ok reply - allow temporary queues with amq.queue(nil) syntax (use uuids) - use as temp queue in rpc - use uuids for message ids in rpc - add ack/completed responses for messages - deleting queues/bindings/exchanges + queue.unbind - queue.remove or queue.close or queue.delete - exchange.remove - rpc.remove - handle errors and exceptions binding to a non-existent (or not yet created in clock.rb) exchange #<AMQP::Protocol::Channel::Close:0x11d35d4 @class_id=50, @debug=1, @method_id=20, @reply_code=404, @reply_text="NOT_FOUND - no exchange 'clock' in vhost '/'">>] - handle connection.redirect during connect (for rabbitmq in distributed mode) [or just set insist to true] - add amq.queue('name').size{ |num| "#{num} messages in the queue" } (send declare passive, look at declare-ok response) - clean up MQ.default on disconnect - add proper handling of Basic::Return (:immediate and :mandatory flags)
Version data entries
3 entries across 3 versions & 2 rubygems
Version | Path |
---|---|
ivanvanderbyl-amqp-0.6.13.1 | TODO |
arvicco-amqp-0.6.13 | TODO |
arvicco-amqp-0.6.11 | TODO |