com.portal.pcm

Class PCPSelector

java.lang.Object

com.portal.pcm.PCPSelector

public class PCPSelector
extends java.lang.Object

PCP connections socket channel Selector. Used during asynchronous mode of opcode processing.

Author:

Copyright (c) 2011, 2015, Oracle and/or its affiliates. This material is the confidential property of Oracle Corporation or its licensors and may be used, reproduced, stored or transmitted only in accordance with a valid Oracle license or sublicense agreement.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PCPSelector() Private constructor.

Method Summary

Modifier and Type	Method and Description
void	addChangeRequestToPendingChanges(com.portal.pcm.ChangeRequest changeRequest)
void	addListener(SocketChannelListener listener, BRMListener.EventType eventType) Adds a socket channel listener to the list.
void	attach(java.nio.channels.SocketChannel socketChannel, java.lang.Object attachment) Adds an attachement to a selection key for the given socket channel.
boolean	closeSocketChannel(java.nio.channels.SocketChannel socketChannel) Close SocketChannel.
java.lang.Object	getAttachment(java.nio.channels.SocketChannel socketChannel) Returns an attachment object on a given socket channel.
static PCPSelector	getInstance() Returns a singleton PCPSelector instance.
int	getNumberOfRegisteredChannels() Returns the number of registered SocketChannels.
java.util.List<com.portal.pcm.ChangeRequest>	getPendingChanges()
boolean	isShutdown() Is selector shutdown.
void	process()
void	removeListener(SocketChannelListener listener) Removes a socket channel listener from the list.
void	shutdown() Shuts down the selector thread.
void	wakeupSelector()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PCPSelector

protected PCPSelector()
               throws java.io.IOException

Private constructor.

Throws:

java.io.IOException - ex

Method Detail

getInstance

public static PCPSelector getInstance()
                               throws java.io.IOException

Returns a singleton PCPSelector instance.

Returns:

PCPSelector

Throws:

java.io.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(java.nio.channels.SocketChannel socketChannel)
                           throws java.io.IOException

Close SocketChannel.

Parameters:

socketChannel - channel to close

Returns:

channel closed

Throws:

java.io.IOException - ex

attach

public void attach(java.nio.channels.SocketChannel socketChannel,
                   java.lang.Object attachment)
            throws java.io.IOException

Adds an attachement to a selection key for the given socket channel.

Parameters:

socketChannel - Socket channel

attachment - Attachement object

Throws:

java.io.IOException - e

getAttachment

public java.lang.Object getAttachment(java.nio.channels.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 java.util.List<com.portal.pcm.ChangeRequest> getPendingChanges()

addChangeRequestToPendingChanges

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