rabbitmq

Documentation

Index

• Constants
• type RabbitMq
  • func NewRabbitMq(ch *amqp.Channel) *RabbitMq
  • func (s *RabbitMq) CreatedFriendship(ctx context.Context, friendship internal.Friendship) error
  • func (s *RabbitMq) CreatedPerson(ctx context.Context, person *internal.Person) error
  • func (s *RabbitMq) DeletedPerson(ctx context.Context, id int64) error

Constants

const (
	MesssagePersonCreated    = "person.created"
	MessagePersonDeleted     = "person.deleted"
	MessageFriendshipCreated = "friendship.created"
)

types for: https://www.rabbitmq.com/publishers.html#message-properties

Types

type RabbitMq

type RabbitMq struct {
	// contains filtered or unexported fields
}

func NewRabbitMq

func NewRabbitMq(ch *amqp.Channel) *RabbitMq

func (*RabbitMq) CreatedFriendship

func (s *RabbitMq) CreatedFriendship(ctx context.Context, friendship internal.Friendship) error

func (*RabbitMq) CreatedPerson

func (s *RabbitMq) CreatedPerson(ctx context.Context, person *internal.Person) error

func (*RabbitMq) DeletedPerson

func (s *RabbitMq) DeletedPerson(ctx context.Context, id int64) error