rabbitmq

配置

asjard:
  stores:
    amqp:
      clients:
        default:
          ## url受cipherName保护
          url: ""
          vhost: ""
          ## 解密组件名称
          cipherName: ""
          cipherParams: {}
        options:
          channelMax: 0
          frameSize: 0
          heartBeat: 1s

使用

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

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