RedisFanout

engine/websocket_fanout~ RedisFanout

Redis pub/sub fan-out bridge.

Constructor

new RedisFanout(options, logger, handlers)

Parameters:

Name Type Description

options object normalizeFanout result

logger object

handlers

object

Properties

Name	Type	Description
`onRoom`	function	(appName, room, data)
`onApp`	function	(appName, data)

Methods

(async) publishApp(appName, data) → {Promise.<void>}

Parameters:

Name	Type	Description
`appName`	string
`data`	*

Returns:

Type: Promise.<void>

(async) publishRoom(appName, room, data) → {Promise.<void>}

Parameters:

Name	Type	Description
`appName`	string
`room`	string
`data`	*

Returns:

Type: Promise.<void>

(async) start() → {Promise.<void>}

Returns:

Type: Promise.<void>