publisher

Documentation

Index

• type CommandPublisher
  • func New(producer meesage_broker.Producer) CommandPublisher
• type RabbitCommandPublisher
  • func (c *RabbitCommandPublisher) Publish(ctx context.Context, body interface{}, key string) error

Types

type CommandPublisher

type CommandPublisher interface {
	Publish(ctx context.Context, body interface{}, key string) error
}

func New

func New(producer meesage_broker.Producer) CommandPublisher

type RabbitCommandPublisher

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

func (*RabbitCommandPublisher) Publish

func (c *RabbitCommandPublisher) Publish(ctx context.Context, body interface{}, key string) error