pubsub

type PubSuber interface {
	//ConnectToBroker(connectionString string)
	Publish(ctx context.Context, body []byte, queueName string) error
	//PublishOnQueue(msg []byte, queueName string) error
	Subscribe(ctx context.Context, queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error
	//SubscribeToQueue(queueName string, consumerName string, handlerFunc func(amqp.Delivery)) error
	Close()
}