amqp

Documentation

Index

• func NewAMQPPub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Publisher, error)
• func NewAMQPSub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Subscriber, error)
• func NewAmqpEngine(conf interface{}, serviceId string, logger *logrus.Entry) (eventbus.EventBusEngine, error)
• func Register()
• type AmqpEngine
  • func (e *AmqpEngine) Publisher() (message.Publisher, error)
  • func (e *AmqpEngine) Subscriber() (message.Subscriber, error)

Functions

func NewAMQPPub

func NewAMQPPub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Publisher, error)

func NewAMQPSub

func NewAMQPSub(conf config.AMQPConnection, serviceID string, logger *logrus.Entry) (message.Subscriber, error)

func NewAmqpEngine

func NewAmqpEngine(conf interface{}, serviceId string, logger *logrus.Entry) (eventbus.EventBusEngine, error)

func Register

func Register()

Types

type AmqpEngine

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

func (*AmqpEngine) Publisher

func (e *AmqpEngine) Publisher() (message.Publisher, error)

func (*AmqpEngine) Subscriber

func (e *AmqpEngine) Subscriber() (message.Subscriber, error)