issues

type BrokerController interface {
	// AttachLogger attaches a logger that will log operations on broker controller
	AttachLogger(logger Logger)

	// Publish a message to the broker
	Publish(channel string, mw UniversalMessage) error

	// Subscribe to messages from the broker
	Subscribe(channel string) (msgs chan UniversalMessage, stop chan interface{}, err error)

	// SetQueueName sets the name of the queue that will be used by the broker
	SetQueueName(name string)
}

type ChatMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

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

type ClientSubscriber interface {
	// Chat
	Chat(msg ChatMessage, done bool)

	// Status
	Status(msg StatusMessage, done bool)
}

type Error struct {
	Channel string
	Err     error
}

type Logger interface {
	// Info logs information based on a message and key-value elements
	Info(msg string, keyvals ...interface{})

	// Error logs error based on a message and key-value elements
	Error(msg string, keyvals ...interface{})
}

type Message struct {
	// Payload will be inserted in the message payload
	Payload string
}

type MessageWithCorrelationID interface {
	CorrelationID() string
}

type StatusMessage struct {
	// Payload will be inserted in the message payload
	Payload string
}

type UniversalMessage struct {
	CorrelationID *string
	Payload       []byte
}