from queuing_hub.publisher import Publisher

pub = Publisher()
# Send a message to all queues accessible by default
response = pub.push(topic_list=pub.topic_list, body='Hello world!')

from queuing_hub.subscriber import Subscriber

sub = Subscriber()
# Receive messages with list ascending priority from queues accessible by default
response = sub.pull(sub_list=sub.sub_list, max_num=1, ack=True)

from queuing_hub.forwarder import Forwarder

fwd = Forwarder(sub=sub.sub_list[0], topic=pub.topic_list[0], max_num=1)
# copy message
response_0 = fwd.pass_through()
# move message
response_1 = fwd.transport()