rabbitmq

type HandlerFunc func(routingKey string, msg []byte)

type Rabbit struct {
	Connection *amqp.Connection
	Channel    *amqp.Channel
}

type RabbitConnection struct {
	URL  string
	Port string
	User string
	Pass string
}

type RabbitEmitMessage struct {
	RoutingKey string
	Body       string
}

type RabbitMessageBody struct {
	Data  string //data being posted
	Query string //Query parameters for mongodb or elastic
	Ctx   string //Context id
}

type TopicSubscription struct {
	RoutingKey string
	Handler    HandlerFunc
}