created

Documentation

Index

• type Consumer
  • func (consumer *Consumer) On(message *messages.Message) error
  • func (consumer *Consumer) SubscribedTo() []*messages.Queue
• type Created
  • func (created *Created) Run(event *user.CreatedSucceeded) error

Types

type Consumer

type Consumer struct {
	usecase.Created
	Queues []*messages.Queue
}

func (*Consumer) On

func (consumer *Consumer) On(message *messages.Message) error

func (*Consumer) SubscribedTo

func (consumer *Consumer) SubscribedTo() []*messages.Queue

type Created

type Created struct {
	transfers.Transfer
}

func (*Created) Run

func (created *Created) Run(event *user.CreatedSucceeded) error