Package org.apache.catalina.tribes.transport

Class AbstractRxTask

  • All Implemented Interfaces:
    java.lang.Runnable
    Direct Known Subclasses:
    NioReplicationTask
    public abstract class AbstractRxTask
extends java.lang.Object
implements java.lang.Runnable
    Abstract base class for receive tasks in the Catalina Tribes framework.

    • Field Detail

      • OPTION_DIRECT_BUFFER

        public static final int OPTION_DIRECT_BUFFER
        Option flag for using direct buffers.
        See Also:
        Constant Field Values

      • useBufferPool

        protected boolean useBufferPool
        Whether to use the buffer pool.

    • Constructor Detail

      • AbstractRxTask

        public AbstractRxTask​(ListenCallback callback)
        Constructs a new AbstractRxTask.
        Parameters:
        callback - The callback

    • Method Detail

      • setTaskPool

        public void setTaskPool​(RxTaskPool pool)
        Sets the task pool.
        Parameters:
        pool - The task pool

      • setOptions

        public void setOptions​(int options)
        Sets the options.
        Parameters:
        options - The options

      • setCallback

        public void setCallback​(ListenCallback callback)
        Sets the callback.
        Parameters:
        callback - The callback

      • getTaskPool

        public RxTaskPool getTaskPool()
        Gets the task pool.
        Returns:
        The task pool

      • getOptions

        public int getOptions()
        Gets the options.
        Returns:
        The options

      • getCallback

        public ListenCallback getCallback()
        Gets the callback.
        Returns:
        The callback

      • close

        public void close()
        Closes this task.

      • setUseBufferPool

        public void setUseBufferPool​(boolean usebufpool)
        Sets whether to use the buffer pool.
        Parameters:
        usebufpool - true to use the buffer pool

      • getUseBufferPool

        public boolean getUseBufferPool()
        Gets whether the buffer pool is being used.
        Returns:
        true if the buffer pool is being used