Module RuoteAMQP
In: lib/ruote-amqp.rb
lib/ruote-amqp/receiver.rb
lib/ruote-amqp/launchitem_listener.rb
lib/ruote-amqp/version.rb
lib/ruote-amqp/workitem_listener.rb
lib/ruote-amqp/participant.rb

AMQP participant and listener pair for ruote.

Documentation

See RuoteAMQP::Listener and RuoteAMQP::Participant for detailed documentation on using each of them.

AMQP Notes

RuoteAMQP uses durable queues and persistent messages by default, to ensure no messages get lost along the way and that running expressions doesn‘t have to be restarted in order for messages to be resent.

Methods

start!   started?   stop!   use_persistent_messages?  

Classes and Modules

Class RuoteAMQP::LaunchitemListener
Class RuoteAMQP::Participant
Class RuoteAMQP::ParticipantProxy
Class RuoteAMQP::Receiver
Class RuoteAMQP::WorkitemListener

Constants

VERSION = '2.1.11'

Attributes

use_persistent_messages  [W] 

Public Class methods

start!() {|if block_given?| ...}

Ensure the AMQP connection is started

started?()

Check whether the AMQP connection is started

stop!()

Close down the AMQP connections

use_persistent_messages?()

Whether or not to use persistent messages (true by default)

[Validate]