Module: Qup

Defined in:

lib/qup.rb,
lib/qup/adapter.rb,
lib/qup/message.rb,
lib/qup/session.rb,
lib/qup/consumer.rb,
lib/qup/producer.rb,
lib/qup/publisher.rb,
lib/qup/queue_api.rb,
lib/qup/topic_api.rb,
lib/qup/subscriber.rb

Defined Under Namespace

Modules: QueueAPI, TopicAPI Classes: Adapter, Consumer, Error, Message, Producer, Publisher, Session, Subscriber

Constant Summary

VERSION =

The Current Version of the library

'1.2.0'

KNOWN_ADAPTERS =

{
  # require => gem
  'maildir' => 'maildir',
  'kestrel' => 'kestrel-client',
  'redis'   => 'redis'
}

Adapters =

The list of registered Adapters

Hash.new

Class Method Summary

• .open(uri, &block) ⇒ Object

  Public: Create a new Session using the given provider URI.

Class Method Details

.open(uri, &block) ⇒ Object

Public: Create a new Session using the given provider URI

uri - the String representing the provider to talk to

Yields the created Session. When the block returns, the session is closed

Examples

session = Qup.open( 'kestrel://localhost:22133' )
session = Qup.open( 'maildir:///tmp/qup' )

Returns a Session.

# File 'lib/qup.rb', line 19

def self.open( uri, &block )
  Qup::Session.open( uri, &block )
end