The Perl Toolchain Summit needs more sponsors. If your company depends on Perl, please support this very important event.
 / 
Crixa-0.11
River stage zero No dependents
6 ++

Changes for version 0.11 - 2015-01-19

  • ENHANCEMENTS
    • Implemented Crixa::Queue->consume(), a blocking API for waiting until messages are received. Unlike the wait_for_message() method, this method does not use a busy loop. Internally, it uses the poll() system call, so it should be much kinder on your CPU.
    • Added a Crixa::Message->consumer_tag() attribute. This will be set for messages received via the new Crixa::Queue->consume() API.
  • CHANGES
    • Crixa::Message->message_count() is no longer set for all messages, since messages received via consume() have no message count.
  • BUG FIXES
    • The docs said that the queue "auto_delete" parameter defaulted to false, but it was actually defaulting to true. This was largely irrelevant given that there past releases had no support for the consume()/recv() interface in Crixa::Queue, but if you made a queue with Crixa and then used the underlying mq object to call consume(), this would've been a problem.

Modules

Crixa
A Cleaner API for Net::AMQP::RabbitMQ
Crixa::Channel
A Crixa Channel
Crixa::Exchange
A Crixa Exchange
Crixa::HasMQ
For internal use only
Crixa::Message
A Crixa Message
Crixa::Queue
A Crixa Queue

Examples

Other files