API Docs for: 0.8.0
Show:

MongoCommandBroker Class

Defined in: include/system/command/mongo_command_broker.js:26
Module: Session

Brokers messages using Redis as the medium. The implementation follows a publish/subscribe model that allows for listening for changes based on a a specified channel.

Constructor

MongoCommandBroker

()

Defined in include/system/command/mongo_command_broker.js:26

Methods

init

(
  • cb
)

Defined in include/system/command/mongo_command_broker.js:69

Initializes the broker by creating the connections to Redis and registering for the message event.

Parameters:

  • cb Function

    A callback that provides two parameters: cb(Error, Boolean)

onCommandReceived

(
  • channel
  • commandStr
)

Defined in include/system/command/mongo_command_broker.js:135

Called when a member of the cluster has published a command. The function inspects that it has a handler for the channel then delegates the command back to the handler.

Parameters:

  • channel String

    The channel the message was pushed to

  • commandStr String

    The message that was published

publish

(
  • channel
  • command
  • cb
)

Defined in include/system/command/mongo_command_broker.js:161

Sends a message to the specified channel

Parameters:

  • channel String

    The channel to send the message to

  • command Object

    The command to send to the cluster

  • cb Function

    A callback that takes two parameters: cb(Error, 1 on success/FALSE on failure)

shutdown

(
  • cb
)

Defined in include/system/command/mongo_command_broker.js:124

Shuts down the broker by closing the open connections to Redis.

Parameters:

  • cb Function

    A callback that provides two parameters: cb(Error, Boolean)

subscribe

(
  • channel
  • onCommandReceived
  • cb
)

Defined in include/system/command/mongo_command_broker.js:186

Registers a handler for messages on the specified channel.

Parameters:

  • channel String

    The channel to listen for messages on

  • onCommandReceived Function

    A handler function that takes two arguments: onCommandReceived(channel, message) where channel is a string and message is an object.

  • cb Function

    A callback that takes two parameters: cb(Error, [RESULT])

Properties

COMMAND_Q_COLL

String private static

Defined in include/system/command/mongo_command_broker.js:53

The collection that stores the commands

cursor

Cursor

Defined in include/system/command/mongo_command_broker.js:35

The cursor that trails the collection looking for new items

DEFAULT_MAX_SIZE

Integer

Defined in include/system/command/mongo_command_broker.js:62

The maximum size, in bytes, of the collection

SUBSCRIBERS

Object private static

Defined in include/system/command/mongo_command_broker.js:44

The hash of handlers for each channel subscribed to