|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Channel | |
com.rhi.architecture.parc | |
com.rhi.architecture.parc.adapter | |
com.rhi.architecture.parc.channel | |
com.rhi.architecture.parc.filter |
Uses of Channel in com.rhi.architecture.parc |
Classes in com.rhi.architecture.parc that implement Channel | |
class |
ArrayListQueue
Channel Implementation using ArrayList. |
class |
LinkedListQueue
LinkedListQueue - general purpose implementation of Channel. |
Methods in com.rhi.architecture.parc that return Channel | |
Channel |
AbstractPipeline.getInputChannel()
Return the inbound side of this pipeline. |
Channel |
AbstractPipeline.getOutputChannel()
Return the outbound side of this pipeline. |
Channel |
AbstractPipeline.getErrorChannel()
Return the error channel for the pipeline. |
Channel |
Pipeline.getInputChannel()
Return the input channel to which the pipe is hooked. |
Channel |
Pipeline.getOutputChannel()
Return the output channel to which the pipe is hooked up. |
Channel |
Pipeline.getErrorChannel()
Return the error channel to which the pipe is hooked up. |
Methods in com.rhi.architecture.parc with parameters of type Channel | |
void |
SerialMTPipeline.init(Channel ch)
Set the default channel |
void |
ParallelMTPipeline.init(Channel ch)
initialize the pipeline. |
void |
AbstractPipeline.init(Channel ch)
Set the default channel |
void |
AbstractPipeline.addFilter(Filter f,
Channel c)
Add a new filter to the set. |
void |
Pipeline.init(Channel ch)
Allow the framework to provide a default Channel implementation. |
void |
Pipeline.addFilter(Filter f,
Channel c)
Add a filer using the provided Channel. |
void |
OutputAdapter.setValidChannel(Channel ch)
Set valid record channel |
void |
OutputAdapter.setErrorChannel(Channel ch)
Set error record channel |
int |
InputAdapter.push(Channel ch)
Send a set of records requiring processing to the pipeline. |
void |
InputAdapter.setErrorChannel(Channel errorChannel)
set the error channel. |
Uses of Channel in com.rhi.architecture.parc.adapter |
Methods in com.rhi.architecture.parc.adapter with parameters of type Channel | |
void |
AbstractOutputAdapter.write(Channel ch,
Channel err)
Persist valid and errored records to the appropriate data store. |
void |
AbstractOutputAdapter.writeValidRecords(Channel ch)
To Improve Performance, a thread pool is created and used. |
void |
AbstractOutputAdapter.writeErrorRecords(Channel err)
To Improve Performance, a thread pool is created and used. |
void |
AbstractOutputAdapter.setErrorChannel(Channel ch)
|
void |
AbstractOutputAdapter.setValidChannel(Channel ch)
|
int |
AbstractInputAdapter.push(Channel validChannel)
Push a set of records into the pipeline. |
void |
AbstractInputAdapter.setErrorChannel(Channel errorChannel)
set the error channel. |
Uses of Channel in com.rhi.architecture.parc.channel |
Classes in com.rhi.architecture.parc.channel that implement Channel | |
class |
AbstractChannel
Abstract Channel |
Uses of Channel in com.rhi.architecture.parc.filter |
Methods in com.rhi.architecture.parc.filter with parameters of type Channel | |
void |
FilterSet.addNode(Filter f,
Channel c)
Add a new filter to the set. |
|
|||||||||||
PREV NEXT | FRAMES NO FRAMES |