messagequeue

Documentation

Index

• func Subscribe(s app.UserService, subscriber message.Subscriber, topics *TopicConfig) (err error)
• type TopicConfig

Functions

func Subscribe

func Subscribe(s app.UserService, subscriber message.Subscriber, topics *TopicConfig) (err error)

Types

type TopicConfig

type TopicConfig struct {
	FollowingAdded   string `json:"following_added"    required:"true"`
	FollowingRemoved string `json:"following_removed"  required:"true"`
}