src/ClusterHop/receiver.js
function deliverMessage (handle, topic, payload) {
  if (handle === 'broadcast') {
    const channel = ChannelsManager.resolve(topic)

    if (!channel) {
      return debug('broadcast topic %s cannot be handled by any channel', topic)
    }

    channel.clusterBroadcast(topic, payload)
    return
  }

  debug('dropping packet, since %s handle is not allowed', handle)
}
function deliverMessage (handle, topic, payload) {
  if (handle === 'broadcast') {
    const channel = ChannelsManager.resolve(topic)

    if (!channel) {
      return debug('broadcast topic %s cannot be handled by any channel', topic)
    }

    channel.clusterBroadcast(topic, payload)
    return
  }

  debug('dropping packet, since %s handle is not allowed', handle)
}
function deliverMessage ( handle , topic , payload ) { if ( handle === 'broadcast' ) { const channel = ChannelsManager . resolve ( topic ) if ( ! channel ) { return debug ( 'broadcast topic %s cannot be handled by any channel' , topic ) } channel . clusterBroadcast ( topic , payload ) return } debug ( 'dropping packet, since %s handle is not allowed' , handle ) }
Delivers the message from process to the channel

@method deliverMessage

@param  {String}       handle
@param  {String}       topic
@param  {String}       payload

@return {void}
Delivers the message from process to the channel