Documentation
¶
Index ¶
Constants ¶
View Source
const (
MessageQueueTypeNATS = "nats"
)
Message queue type constants
Variables ¶
View Source
var (
ErrorMessageQueueTypeUnsupported = errors.New("unsupported message queue type")
)
Functions ¶
This section is empty.
Types ¶
type MQClient ¶
type MQClient interface {
Publish(string, interface{}) error
Subscribe(string, func(interface{})) (int64, error)
SubscribeWithGroup(string, string, func(interface{})) (int64, error)
Unsubscribe(int64) error
Group(int64) (string, error)
Close() error
}
func NewNATSClient ¶
NewNATSClient return MessageQueueClient
Source Files
Click to show internal directories.
Click to hide internal directories.