rabbitmq

Configuration

asjard:
  stores:
    amqp:
      clients:
        default:
          ## url protected by cipherName
          url: ""
          vhost: ""
          ## Decryption component name
          cipherName: ""
          cipherParams: {}
        options:
          channelMax: 0
          frameSize: 0
          heartBeat: 1s

Use

import "github.com/asjard/asjard/pkg/stores/xamqp"

client, err := xamqp.Client()
if err != nil {
	return err
}