pulsar.messaging package¶
Submodules¶
pulsar.messaging.bind_amqp module¶
-
pulsar.messaging.bind_amqp.
bind_manager_to_queue
(manager, queue_state, connection_string, conf)[source]¶
-
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
.