package broker

type MockMessageBroker struct {
}

func (broker *MockMessageBroker) Start() {
}

func (broker *MockMessageBroker) Stop() {
}

func (broker *MockMessageBroker) Publish(topicName string, id string, body MessageBrokerBody) error {
	return nil
}

func (broker *MockMessageBroker) Subscribe(topicName, queueName string, fn ConsumeFn) {
}

func (broker *MockMessageBroker) connect() error {
	return nil
}

func (broker *MockMessageBroker) reconnect() {
}