Class NioReceiver

    • Field Detail

      • sm

        protected static final StringManager sm
        The string manager for this package.
      • events

        protected final java.util.Deque<java.lang.Runnable> events
      • lastCheck

        protected long lastCheck
    • Constructor Detail

      • NioReceiver

        public NioReceiver()
    • Method Detail

      • bind

        protected void bind()
      • addEvent

        public void addEvent​(java.lang.Runnable event)
      • events

        public void events()
      • cancelledKey

        public static void cancelledKey​(java.nio.channels.SelectionKey key)
      • socketTimeouts

        protected void socketTimeouts()
      • listen

        protected void listen()
                       throws java.lang.Exception
        Get data from channel and store in byte array send it to cluster
        Throws: - IO error
      • registerChannel

        protected void registerChannel​(java.nio.channels.Selector selector,
                                       java.nio.channels.SelectableChannel channel,
                                       int ops,
                                       java.lang.Object attach)
                                throws java.lang.Exception
        Register the given channel with the given selector for the given operations of interest
        selector - The selector to use
        channel - The channel
        ops - The operations to register
        attach - Attachment object
        java.lang.Exception - IO error with channel
      • run

        public void run()
        Start thread and listen
        Specified by:
        run in interface java.lang.Runnable
      • readDataFromSocket

        protected void readDataFromSocket​(java.nio.channels.SelectionKey key)
                                   throws java.lang.Exception
        Sample data handler method for a channel with data ready to read.
        key - A SelectionKey object associated with a channel determined by the selector to be ready for reading. If the channel returns an EOF condition, it is closed here, which automatically invalidates the associated key. The selector will then de-register the channel on the next select call.
        java.lang.Exception - IO error with channel