amqp_queue

type ExchangeDeclare struct {
	Name       string // name
	Kind       string // type
	Durable    bool   // durable
	AutoDelete bool   // auto-deleted
	Internal   bool   // internal

	Args map[string]interface{} // args
	// contains filtered or unexported fields
}

type Queue interface {
	Connect() error
	NewChannel() (*amqp.Channel, error)
	NotifyState(receiver chan string)
	GetState() string
	PublishOnQueue(message []byte, queueName string) error
	PublishOnExchange(message []byte, exchange *ExchangeDeclare, routingKey string) error
	SubscribeToQueue(queueName string, consumerName string, handleFunc func(delivery amqp.Delivery)) error
}

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