public class PCPSelector extends Object
Modifier | Constructor and Description |
---|---|
protected |
PCPSelector()
Private constructor.
|
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(SocketChannel socketChannel,
Object attachment)
Adds an attachement to a selection key for the given socket channel.
|
boolean |
closeSocketChannel(SocketChannel socketChannel)
Close SocketChannel.
|
Object |
getAttachment(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.
|
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() |
protected PCPSelector() throws IOException
IOException
- expublic static PCPSelector getInstance() throws IOException
IOException
- expublic void addListener(SocketChannelListener listener, BRMListener.EventType eventType)
listener
- listener to socket channel events.eventType
- event typepublic void removeListener(SocketChannelListener listener)
listener
- listener to socket channel events.public void shutdown()
public int getNumberOfRegisteredChannels()
public void process()
public boolean closeSocketChannel(SocketChannel socketChannel) throws IOException
socketChannel
- channel to closeIOException
- expublic void attach(SocketChannel socketChannel, Object attachment) throws IOException
socketChannel
- Socket channelattachment
- Attachement objectIOException
- epublic Object getAttachment(SocketChannel socketChannel)
socketChannel
- SocketChannelpublic boolean isShutdown()
public void wakeupSelector()
public List<com.portal.pcm.ChangeRequest> getPendingChanges()
public void addChangeRequestToPendingChanges(com.portal.pcm.ChangeRequest changeRequest)
Copyright © 2003, 2023, Oracle and/or its affiliates.