Package com.portal.pcm

Class PCPSelector

java.lang.Object
com.portal.pcm.PCPSelector
public class PCPSelector extends Object
PCP connections socket channel Selector. Used during asynchronous mode of opcode processing.

  • Constructor Details

  • Method Details

    • getInstance

      public static PCPSelector getInstance() throws IOException
      Returns a singleton PCPSelector instance.
      Returns:
      PCPSelector
      Throws:
      IOException - ex

    • addListener

      public void addListener(SocketChannelListener listener, BRMListener.EventType eventType)
      Adds a socket channel listener to the list.
      Parameters:
      listener - listener to socket channel events.
      eventType - event type

    • removeListener

      public void removeListener(SocketChannelListener listener)
      Removes a socket channel listener from the list.
      Parameters:
      listener - listener to socket channel events.

    • shutdown

      public void shutdown()
      Shuts down the selector thread.

    • getNumberOfRegisteredChannels

      public int getNumberOfRegisteredChannels()
      Returns the number of registered SocketChannels.
      Returns:
      number of registered channels

    • process

      public void process()

    • closeSocketChannel

      public boolean closeSocketChannel(SocketChannel socketChannel) throws IOException
      Close SocketChannel.
      Parameters:
      socketChannel - channel to close
      Returns:
      channel closed
      Throws:
      IOException - ex

    • attach

      public void attach(SocketChannel socketChannel, Object attachment) throws IOException
      Adds an attachement to a selection key for the given socket channel.
      Parameters:
      socketChannel - Socket channel
      attachment - Attachement object
      Throws:
      IOException - e

    • getAttachment

      public Object getAttachment(SocketChannel socketChannel)
      Returns an attachment object on a given socket channel.
      Parameters:
      socketChannel - SocketChannel
      Returns:
      Attachment object

    • isShutdown

      public boolean isShutdown()
      Is selector shutdown.
      Returns:
      boolean

    • wakeupSelector

      public void wakeupSelector()

    • getPendingChanges

      public List<com.portal.pcm.ChangeRequest> getPendingChanges()

    • addChangeRequestToPendingChanges

      public void addChangeRequestToPendingChanges(com.portal.pcm.ChangeRequest changeRequest)