broker

type Broker struct {
	Producer
	Consumer
	TopicAccountBE, TopicAccountCUD   string
	TopicProductBE, TopicProductCUD   string
	TopicOrderBE, TopicOrderCUD       string
	TopicDeliveryBE, TopicDeliveryCUD string
	TopicBillingBE, TopicBillingCUD   string
}

type BrokerConsume struct {
	TopicAccountBE, TopicAccountCUD   string
	TopicProductBE, TopicProductCUD   string
	TopicOrderBE, TopicOrderCUD       string
	TopicDeliveryBE, TopicDeliveryCUD string
	TopicBillingBE, TopicBillingCUD   string
	// contains filtered or unexported fields
}

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

type Consumer interface {
	Subscribe() error
	ProcessEvent(event domain.Event)
}

type Producer interface {
	Produce(evetType domain.EventType, eventTopic string, eventPayload interface{}) error
}