=====
Usage
=====

To use b_rabbit in a project::

    from b_rabbit.b_rabbit import BRabbit


    #first, you need to create a BRabbit instance to provide rabbitMQ connection:

    # create a parent instance which provide a global rabbitMQ connection
    rabbit = BRabbit(host='localhost', port=5672)

    # Now it is very easy to use the messaging pattern with rabbitmq
    # here is a demonstration of using the publish-subscribe


    # first create a publisher instance from the parent
    publisher = rabbit.EventPublisher(b_rabbit=rabbit,
                                        publisher_name='whatever_you_name_it')

    # now you can just publish your message:
    publisher.publish(routing_key='testing.test',
                      payload='Hello from publisher')


    # similarly subscribing is very easy to implement:
    # first a subscriber instance from the parent class
    subscriber = rabbit.EventSubscriber(
                                    b_rabbit=rabbit,
                                    routing_key='testing.test',
                                    publisher_name='name_it',
                                    event_listener=callback)

     # the callback is a function you need to define in order to do something with the received message
     def callback(msg):
        # do something with the received msg from the publisher
        print(f"msg received: {msg}")


     # after that subscribing is straightforward:
     subscriber.subscribe_on_thread()

    # take a look in the examples to see a working publish-subscribe and RPC