Message Queue

Queue - abstraction of a message queue

Synopsis

Example:

import messaging.queue as queue

mq = queue.new(type="Foo", ... options ...);
# is identical too
mq = queue.foo.Foo(... options ...);

Description

This module provides an abstraction of a message queue. Its only purpose is to offer a unified method to create a new queue. The functionality is implemented in child modules such as messaging.queue.dq.DQ.

Copyright (C) 2012 CERN

messaging.queue.new(option)

Create a new message queue object; options must contain the type of queue (which is the name of the child class), see above.

Project Versions

Table Of Contents

Previous topic

Message Generator

Next topic

Stomppy helper

This Page