NewPublisher creates and starts a new Publisher that receives new messages via a string channel that can be address has the format: localhost:5672.

NewSubscriber creates and starts a new subscriber that can Consume from a single of ConsumeMany queues.

Message is a simple struct that allows to publish to different topics with a single publisher client connection.

Subscriber wraps the amqp client that is subscribed to one or more specific queues You can subscribe to different topics, but MUST NOT subscribe to the same topic multiple times, e.g.