rabbit

type ConsumeMessage struct {
	EventType string      `json:"event_type"`
	Payload   interface{} `json:"payload"`
}

type EventProcessor struct {
	Message   []byte
	EventBus  *event.EventBus
	StoreInDB bool
}

type RabbitRepository interface {
	QueueConnector(interface{}) error
	Publish(string) error
	Consume(*event.EventBus)
}

type RabbitRepositoryImpl struct {
	Chan  *amqp.Channel
	Queue amqp.Queue
}