Listeners

pymco.listeners

stomp.py listeners for python-mcollective.

class pymco.listener.CurrentHostPortListener(*args, **kwargs)

Listener tracking current host and port.

Some connectors, like ActiveMQ connector, may provide different user and password for each host, so we need track the current host and port in order to be able to get the right user and password when logging.

get_host()

Return current host.

Returns:current host.

get_port()

Return current host.

Returns:current port.

on_connecting(host_and_port)

Track current host and port.

Parameters:host_and_port – A two-tuple with host as first element and port as the second.

class pymco.listener.ResponseListener(config, connector, count, timeout=30, condition=None, logger=<logging.Logger object>)

Listener that waits for a message response.

Parameters:

• config – pymco.config.Config instance.
• count – number of expected messages.
• timeout – seconds we should wait for messages.
• condition – by default a threading.Condition object for synchronization purposes, but you can use any object implementing the wait() method and accepting a timeout argument.

on_message(headers, body)

Received messages hook.

Parameters:

• headers – message headers.
• body – message body.

security

Security provider property

wait_on_message()

Wait until we get a message.

Returns:self.