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, write
public LocalDataSource()
@Deprecated public LocalDataSource(boolean zeroInitialization)
zeroInitialization
- whether to initialize variable to 0protected ChannelHandler createChannel(String channelName)
DataSource
createChannel
in class DataSource
channelName
- the name for a new channelprotected String channelHandlerLookupName(String channelName)
DataSource
channelHandlerLookupName
in class DataSource
channelName
- the channel namepublic void connectRead(ReadRecipe readRecipe)
DataSource
The 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 DataSource
readRecipe
- the instructions for the data connectionpublic void connectWrite(WriteRecipe writeRecipe)
DataSource
If these are channels over the network, it will create the network connections with the underlying libraries.
connectWrite
in class DataSource
writeRecipe
- the recipe that will contain the write dataCopyright © 2010–2015. All rights reserved.