Class StreamInputWorker

    • Constructor Detail

      • StreamInputWorker

        public StreamInputWorker()
    • Method Detail

      • work

        public void work()
                  throws IOException
        Description copied from class: NodeWorker
        Implement this method to let the node perform some useful work.

        Implementors are free to throw whatever exception they see fit. If any Throwable is thrown from this method, the failure manager is notified about the fatal failure of the whole pipeline.

        Specified by:
        work in class NodeWorker<StreamInputNode>
        Throws:
        IOException
      • doAbort

        protected void doAbort()
        Description copied from class: NodeWorker
        NodeWorker implementations can provide here own logic that shall be performed when an abort is triggered.
        Overrides:
        doAbort in class NodeWorker<StreamInputNode>
      • doAbortNow

        protected void doAbortNow()
        Description copied from class: NodeWorker
        NodeWorker implementations can provide here own logic that shall be performed when an immediate abort is triggered.

        jadice server 5.5.0.0

        Overrides:
        doAbortNow in class NodeWorker<StreamInputNode>