pubsub

Documentation

Index

• type PubSuber

Types

type PubSuber

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()
}

PubSuber ...