Package tlib :: Package base :: Module ActiveMQHelper :: Class ActiveMQHelper
[hide private]
[frames] | no frames]

Class ActiveMQHelper

source code

object --+
         |
        ActiveMQHelper

Instance Methods [hide private]
 
__init__(self, host, port, default_queue=None)
x.__init__(...) initializes x; see help(type(x)) for signature
source code
 
connect(self)
Get configuration and connect to ActiveMQ
source code
 
disconnect(self)
If there is a connection with ActiveMQ, close it.
source code
 
subscribe(self, listener, queue)
Adds a listener with the specified name
source code
 
unsubscribe(self, listener)
Removes a listener
source code
 
send_message(self, message, queue=None)
Send message to ActiveMQ.
source code

Inherited from object: __delattr__, __format__, __getattribute__, __hash__, __new__, __reduce__, __reduce_ex__, __repr__, __setattr__, __sizeof__, __str__, __subclasshook__

Class Variables [hide private]
  _logger = None
Properties [hide private]

Inherited from object: __class__

Method Details [hide private]

__init__(self, host, port, default_queue=None)
(Constructor)

source code 

x.__init__(...) initializes x; see help(type(x)) for signature

Overrides: object.__init__
(inherited documentation)

subscribe(self, listener, queue)

source code 

Adds a listener with the specified name

:param listener: Listener that will receive messages :type listener: ActiveMQListener :param queue: Queue to subscribe to :type queue: str :raises: ValueError

unsubscribe(self, listener)

source code 

Removes a listener

:param listener: Listener that will receive messages :type listener: ActiveMQListener

send_message(self, message, queue=None)

source code 

Send message to ActiveMQ. Id queue is not provided, it uses default queue

:param: message: queue body :param: queue_destination: queue name