amqp

Documentation

Index

• func NewPostCreatedEventSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber
• func NewProfileFollowingCreatedEventSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber
• func NewProfileFollowingDeletedEventSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber
• func NewUpdateNewsLinesCommandSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber
• type Set
  • func New(endpoints endpoints.Set, logger *logrus.Entry) Set
  • func (s Set) Subscribe(channel *amqp.Channel) error

Functions

func NewPostCreatedEventSubscriber

func NewPostCreatedEventSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber

func NewProfileFollowingCreatedEventSubscriber

func NewProfileFollowingCreatedEventSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber

func NewProfileFollowingDeletedEventSubscriber

func NewProfileFollowingDeletedEventSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber

func NewUpdateNewsLinesCommandSubscriber

func NewUpdateNewsLinesCommandSubscriber(e endpoint.Endpoint, logger *logrus.Entry) *kitamqp.Subscriber

Types

type Set

type Set struct {
	PostCreatedEventHandler             *kitamqp.Subscriber
	ProfileFollowingCreatedEventHandler *kitamqp.Subscriber
	ProfileFollowingDeletedEventHandler *kitamqp.Subscriber
	UpdateNewsLinesCommandHandler       *kitamqp.Subscriber
}

func New

func New(endpoints endpoints.Set, logger *logrus.Entry) Set

func (Set) Subscribe

func (s Set) Subscribe(channel *amqp.Channel) error