broker

Documentation

Index

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

Functions

func New

func New(producer meesage_broker.Producer) publisher.CommandPublisher

Types

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