amqp10-transport-ws

node-amqp10-transport-ws

Provides a Websocket implementation for the transport layer for node-amqp10.

The amqp10 library exports a TransportProvider class that is used to manage and inject new transports for the library to use. Each transport should expose a register method that takes the TransportProvider as an argument, allowing any transport to register a new protocol to be used.

In the present case the protocol registered is wss (webocket transport using the node-websocket library).

Usage

var amqp10 = require('amqp10');
var wsTransport = require('amqp10-transport-ws');
 
wsTransport.register(amqp10.TransportProvider);

Once registered, any URI starting with wss:// given to the connect method of amqp10.Client will be handled by the websocket transport.