ds.granules.communication.direct

Class ChannelToStreamDeMultiplexer

java.lang.Object

ds.granules.communication.direct.ChannelToStreamDeMultiplexer

public class ChannelToStreamDeMultiplexer
extends Object

DeMultiplexing data from a Channel to the appropriate Stream.

Author:

Thilina Buddhika

Method Summary

Methods

Modifier and Type	Method and Description
void	dispatch(byte[] message)
static ChannelToStreamDeMultiplexer	getInstance()
void	registerCallback(String topic, ChannelReaderCallback callback)
void	triggerCallbacks(String topic, byte[] message)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getInstance

public static ChannelToStreamDeMultiplexer getInstance()

registerCallback

public void registerCallback(String topic,
                    ChannelReaderCallback callback)

triggerCallbacks

public void triggerCallbacks(String topic,
                    byte[] message)

dispatch

public void dispatch(byte[] message)