pulsar.messaging package

Submodules

pulsar.messaging.bind_amqp module

pulsar.messaging.bind_amqp.bind_manager_to_queue(manager, queue_state, connection_string, conf)

pulsar.messaging.bind_amqp.get_exchange(connection_string, manager_name, conf)

pulsar.messaging.bind_amqp.start_kill_consumer(exchange, target)

pulsar.messaging.bind_amqp.start_setup_consumer(exchange, target)

pulsar.messaging.bind_amqp.start_status_consumer(exchange, target)

pulsar.messaging.bind_amqp.start_status_update_ack_consumer(exchange, target)

Module contents

This module contains the server-side only code for interfacing with message queues. Code shared between client and server can be found in submodules of pulsar.client.

class pulsar.messaging.QueueState

Bases: object

Passed through to event loops, should be “non-zero” while queues should be active.

deactivate()

join(timeout=None)

pulsar.messaging.bind_app(app, queue_id, conf=None)