rabbitmq_adapter

Documentation

Index

• type RabbitMQAdapter
  • func New(url string) *RabbitMQAdapter
  • func NewConn(ch *amqp.Channel) *RabbitMQAdapter
  • func (rmq *RabbitMQAdapter) Close() error
  • func (rmq *RabbitMQAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, ...) error
  • func (rmq *RabbitMQAdapter) Publish(ctx context.Context, message discourse.Publisher) error

Types

type RabbitMQAdapter

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

func New

func New(url string) *RabbitMQAdapter

func NewConn

func NewConn(ch *amqp.Channel) *RabbitMQAdapter

func (*RabbitMQAdapter) Close

func (rmq *RabbitMQAdapter) Close() error

func (*RabbitMQAdapter) Listener

func (rmq *RabbitMQAdapter) Listener(ctx context.Context, fn func(discourse.Message) error, cfgSubcription discourse.Subscription) error

func (*RabbitMQAdapter) Publish

func (rmq *RabbitMQAdapter) Publish(ctx context.Context, message discourse.Publisher) error