messagebus

Documentation

Index

• type Messagebus
• type Subscription

Types

type Messagebus

type Messagebus interface {
	SendMessage(message []byte, queue string) error
	SendMessageWithHeaders(message []byte, queue string, headers map[string]string) error
	ReceiveMessage(message chan<- string, queue string) (Subscription, error)
	Close() error
}

type Subscription

type Subscription interface {
	Close() error
}