Methods
(async) connect(hostopt)
Parameters:
| Name | Type | Attributes | Description |
|---|---|---|---|
host |
string |
<optional> |
default is process.env.RMQ_HOST || 'amqp://rabbitmq:5672' |
Exchange(name, typeopt, optionsopt)
Parameters:
| Name | Type | Attributes | Description |
|---|---|---|---|
name |
string | Name of the exchange |
|
type |
string |
<optional> |
'direct', 'fanout' etc, default is 'direct' |
options |
object |
<optional> |
amqp channel.assertExchange options object |