public class LocalDataSource extends DataSource
| Constructor and Description |
|---|
LocalDataSource()
Creates a new data source.
|
LocalDataSource(boolean zeroInitialization)
Deprecated.
do not use zero initialization of local variable: does not work for non numeric variables
|
| Modifier and Type | Method and Description |
|---|---|
protected String |
channelHandlerLookupName(String channelName)
Returns the lookup name to use to find the channel handler in
the cache.
|
void |
connectRead(ReadRecipe readRecipe)
Connects to a set of channels based on the given recipe.
|
void |
connectWrite(WriteRecipe writeRecipe)
Prepares the channels defined in the write recipe for writes.
|
protected ChannelHandler |
createChannel(String channelName)
Creates a channel handler for the given name.
|
channelHandlerRegisterName, close, disconnectRead, disconnectWrite, getChannels, isWriteable, writepublic LocalDataSource()
@Deprecated public LocalDataSource(boolean zeroInitialization)
zeroInitialization - whether to initialize variable to 0protected ChannelHandler createChannel(String channelName)
DataSourcecreateChannel in class DataSourcechannelName - the name for a new channelprotected String channelHandlerLookupName(String channelName)
DataSourcechannelHandlerLookupName in class DataSourcechannelName - the channel namepublic void connectRead(ReadRecipe readRecipe)
DataSourceThe data source must update the value caches relative to each channel. Before updating any cache, it must lock the collector relative to that cache and after any update it must notify the collector.
connectRead in class DataSourcereadRecipe - the instructions for the data connectionpublic void connectWrite(WriteRecipe writeRecipe)
DataSourceIf these are channels over the network, it will create the network connections with the underlying libraries.
connectWrite in class DataSourcewriteRecipe - the recipe that will contain the write dataCopyright © 2010–2015. All rights reserved.