amqp

type Consumer struct {
	Uri          string //amqp://guest:guest@localhost:5672/
	ExchangeName string // "test-exchange"
	ExchangeType string // "direct", "Exchange type - direct|fanout|topic|x-custom"
	QueueName    string //("test-key", "AMQP routing key"
	BindingKey   string
	ReceiveFunc  func(data []byte)
	// contains filtered or unexported fields
}

type Producer struct {
	Uri          string //amqp://guest:guest@localhost:5672/
	ExchangeName string // "test-exchange"
	ExchangeType string // "direct", "Exchange type - direct|fanout|topic|x-custom"
	RoutingKey   string //("test-key", "AMQP routing key"
	Reliable     bool
	SuccessFunc  func(confirms *amqp.Confirmation) // "Wait for the publisher confirmation before exiting"
	FailFunc     func(confirms *amqp.Confirmation)
	// contains filtered or unexported fields
}