rabbitmq

type Message struct {
	// contains filtered or unexported fields
}

type Queue struct {
	// contains filtered or unexported fields
}

type QueueOption struct {
	// Connection the connection is used to receive and send messages
	Connection *amqp.Connection
	// URL is a string in the AMQP URI format,
	// if you do not provide the Connection parameter,
	// we will try to create a new connection from the URL
	URL string
	// Codec is using for marshal and unmarshal messages
	// default is gob codec with s2 compression
	Codec encoding.Codec
}

type Worker struct {
	// contains filtered or unexported fields
}