RABBITMQ

Install

go get github.com/aacfactory/fns-contrib/message-queues/rabbit

Usage

app.Deploy(rabbit.Service())

Config

rabbitmq:
  uri: "amqp://"
  producers:
    foo:
      exchange: "exchange"
      confirmMode: true
      key: ""
      mandatory: false
      immediate: false
      size: 8
  consumers:
    bar:
      handler: default
      queue: ""
      autoAck: false
      exclusive: false
      noLocal: false
      noWait: false

Use user consumer handler

consumers:
  bar:
    handler: user_consumer
    handlerOptions:
      userId: "userId"

As proxy

published, publishErr := rabbit.Publish(ctx, rabbit.PublishArgument{
	Name: "producer name", 
	Body: json.RawMessage([]byte("{}"))
})