amqp

func NewAMQPEventEmitter ¶

func NewAMQPEventEmitter(conn *amqp.Connection, exchange string) (msgqueue.EventEmitter, error)

NewAMQPEventEmitter creates a new event emitter. It will need an AMQP connection passed as parameter and use this connection to create its own channel (note: AMQP channels are not thread-safe, so just accepting the connection as a parameter and then creating our own private channel is the safest way to ensure this).

func NewAMQPEventEmitterFromEnvironment ¶

func NewAMQPEventEmitterFromEnvironment() (msgqueue.EventEmitter, error)

NewAMQPEventEmitterFromEnvironment will create a new event emitter from the configured environment variables. Important variables are:

• AMQP_URL; the URL of the AMQP broker to connect to
• AMQP_EXCHANGE; the name of the exchange to bind to

For missing environment variables, this function will assume sane defaults.

func NewAMQPEventListener ¶

func NewAMQPEventListener(conn *amqp.Connection, exchange string, queue string) (msgqueue.EventListener, error)

NewAMQPEventListener creates a new event listener. It will need an AMQP connection passed as parameter and use this connection to create its own channel (note: AMQP channels are not thread-safe, so just accepting the connection as a parameter and then creating our own private channel is the safest way to ensure this).

func NewAMQPEventListenerFromEnvironment ¶

func NewAMQPEventListenerFromEnvironment() (msgqueue.EventListener, error)

NewAMQPEventListenerFromEnvironment will create a new event listener from the configured environment variables. Important variables are:

• AMQP_URL; the URL of the AMQP broker to connect to
• AMQP_EXCHANGE; the name of the exchange to bind to
• AMQP_QUEUE; the name of the queue to bind and subscribe

For missing environment variables, this function will assume sane defaults.