com.intel.icecp.node.channels.ndn

Class NdnChannelProvider

java.lang.Object

com.intel.icecp.node.channels.ndn.NdnChannelProvider

All Implemented Interfaces:

ChannelProvider

public class NdnChannelProvider
extends Object
implements ChannelProvider

Build an NDN channel; note that while we test different ways to send messages with NDN we will expose different channel types. These are configurable in the ndn.json configuration file along with:

• channel-type: notification (default), chronosync (experimental)
• uri: localhost (default)--the location of the NFD to use for routing

Field Summary

Fields

Modifier and Type	Field and Description
static String	SCHEME

Constructor Summary

Constructors

Constructor and Description
NdnChannelProvider() Default constructor used for SPI loading; the loading class must call the start(ScheduledExecutorService, Configuration) method
NdnChannelProvider(String identityPrefix, net.named_data.jndn.Face prefixFace, net.named_data.jndn.Face interestFace, ScheduledExecutorService eventLoop) Specific constructor with default channel type; equivalent to calling start(ScheduledExecutorService, Configuration)
NdnChannelProvider(String identityPrefix, net.named_data.jndn.Face prefixFace, net.named_data.jndn.Face interestFace, ScheduledExecutorService eventLoop, String channelType) Specific constructor; equivalent to calling start(ScheduledExecutorService, Configuration)
NdnChannelProvider(String identityPrefix, String hostName, ScheduledExecutorService pool)

Method Summary

Modifier and Type	Method and Description
<T extends Message> Channel<T>	build(URI uri, Pipeline pipeline, Persistence persistence, Metadata... metadata) TODO fix unchecked warnings in this method
String	scheme()
void	start(ScheduledExecutorService pool, Configuration configuration)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

SCHEME

public static final String SCHEME

See Also:

Constant Field Values

Constructor Detail

NdnChannelProvider

public NdnChannelProvider()

Default constructor used for SPI loading; the loading class must call the start(ScheduledExecutorService, Configuration) method

NdnChannelProvider

public NdnChannelProvider(String identityPrefix,
                          net.named_data.jndn.Face prefixFace,
                          net.named_data.jndn.Face interestFace,
                          ScheduledExecutorService eventLoop)

Specific constructor with default channel type; equivalent to calling start(ScheduledExecutorService, Configuration)

Parameters:

identityPrefix - the name used for signature creation (e.g. /intel/node/...)

prefixFace - a face used for registering prefixes for consumers to retrieve data on

interestFace - a face used for sending interests; this is different from the prefixFace so that a channel can retrieve its own published messages

eventLoop - the thread pool used for event processing

NdnChannelProvider

public NdnChannelProvider(String identityPrefix,
                          net.named_data.jndn.Face prefixFace,
                          net.named_data.jndn.Face interestFace,
                          ScheduledExecutorService eventLoop,
                          String channelType)

Specific constructor; equivalent to calling start(ScheduledExecutorService, Configuration)

Parameters:

identityPrefix - the name used for signature creation (e.g. /intel/node/...)

prefixFace - a face used for registering prefixes for consumers to retrieve data on

interestFace - a face used for sending interests; this is different from the prefixFace so that a channel can retrieve its own published messages

eventLoop - the thread pool used for event processing

channelType - since NDN channels are actively developed, this allows users to choose between different implementation

NdnChannelProvider

public NdnChannelProvider(String identityPrefix,
                          String hostName,
                          ScheduledExecutorService pool)

Parameters:

identityPrefix - the name used for signature creation (e.g. /intel/node/...)

hostName - the host name used for the faces

pool - the thread pool used for event processing

Method Detail

start

public void start(ScheduledExecutorService pool,
                  Configuration configuration)

Specified by:

start in interface ChannelProvider

scheme

public String scheme()

Specified by:

scheme in interface ChannelProvider

stop

public void stop()

Specified by:

stop in interface ChannelProvider

build

public <T extends Message> Channel<T> build(URI uri,
                                            Pipeline pipeline,
                                            Persistence persistence,
                                            Metadata... metadata)
                                     throws ChannelLifetimeException

TODO fix unchecked warnings in this method

Specified by:

build in interface ChannelProvider

Throws:

ChannelLifetimeException