Documentation ¶
Overview ¶
Package subscription deals with subscriptions.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Subscription ¶
type Subscription struct { common.Common // Func is the function to call when a message is received. It handles the // message. Func Func `json:"-"` // Channel is the channel to receive messages. Channel chan *message.Message `json:"-"` }
Subscription is a subscription to a topic.
func MustNew ¶ added in v1.0.14
func MustNew(topic, queue string, callback Func) *Subscription
MustNew creates a new subscription, panicking if there's an error.
Click to show internal directories.
Click to hide internal directories.