cfmessagebus

type DefaultLogger struct{}

type Logger interface {
	Fatal(string)
	Error(string)
	Warn(string)
	Info(string)
	Debug(string)

	Fatald(map[string]interface{}, string)
	Errord(map[string]interface{}, string)
	Warnd(map[string]interface{}, string)
	Infod(map[string]interface{}, string)
	Debugd(map[string]interface{}, string)
}

type MessageBus interface {
	Configure(host string, port int, user string, password string)
	Connect() error
	Subscribe(subject string, callback func(payload []byte)) error
	UnsubscribeAll() error
	Publish(subject string, message []byte) error
	Request(subject string, message []byte, callback func(response []byte)) error
	Ping() bool
	RespondToChannel(subject string, callback func(request []byte) []byte) error
	OnConnect(func())
	SetLogger(Logger)
}

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

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

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