rabbitmq

Documentation

Index

• type Config
• type RabbitMQ
• type RabbitMQAdapter
  • func (ra *RabbitMQAdapter) Init() error
  • func (ra *RabbitMQAdapter) Publish(ctx context.Context, m messagebroker.PublishMessage) error
  • func (ra *RabbitMQAdapter) Subscribe(ctx context.Context, name string, ...)

Types

type Config

type Config struct {
	Username string
	Password string
	Server   string
}

type RabbitMQ

type RabbitMQ struct {
	Cfg Config
}

type RabbitMQAdapter

type RabbitMQAdapter struct {
	Broker *RabbitMQ
}

func (*RabbitMQAdapter) Init

func (ra *RabbitMQAdapter) Init() error

func (*RabbitMQAdapter) Publish

func (ra *RabbitMQAdapter) Publish(ctx context.Context, m messagebroker.PublishMessage) error

func (*RabbitMQAdapter) Subscribe

func (ra *RabbitMQAdapter) Subscribe(ctx context.Context, name string, handler messagebroker.SubscribeMessageHandler)