amqp

func New ¶

func New(configKey string) messagebus.Client

New instantiates a new client wrapper. A call to Initialize is required before use. The configKey parameter dictates which key in the configuration file will be read during initialization. If configKey is empty, the default value of "amqp.url" will be used. The configuration can be in various formats, but the following is an example of a yaml file:

amqp:
  url: 'amqp://localhost:5672'