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(user *event.CreatedSucceeded) (types.Empty, error)

Types

type Consumer

type Consumer struct {
	models.UseCase[*event.CreatedSucceeded, types.Empty]
	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 {
	models.Transport
}

func (*Created) Run

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