|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.geronimo.remoting.transport.async.ChannelPool
a ChannelPool represents a logical connection to a remote uri. - It handles decomposing synchronous requests into async requests. - It pools AsychChannel connections to be able concurrently do multiple asyc sends.
Constructor Summary | |
ChannelPool(URI uri,
Router dispatcher)
|
Method Summary | |
void |
associate(Channel c)
Associate a channel to the pool. |
void |
dispatchDatagram(URI to,
Msg data,
ChannelPool source)
A ChannelPool will receive data from a Channel and if it is new request, it will forward it to the AsynchChannelServer for it to dispatch the work the appropriate subsystem. |
void |
dispatchRequest(URI to,
AsyncMsg data,
ChannelPool source)
A ChannelPool will receive data from a Channel and if it is new request, it will forward it to the AsynchChannelServer for it to dispatch the work the appropriate subsystem. |
void |
dispose()
|
void |
expireIdleConnections(long connectionTimeout)
Expires idle connections |
URI |
getBackConnectURI()
|
int |
getCreatedChannelCount()
|
org.apache.geronimo.remoting.transport.async.ChannelPool.PooledAsynchChannel |
getNextAvailable()
Return the next available AsynchChannel object for a given invocation session. |
void |
sendDatagram(URI to,
Msg data)
Sends a datagram message. |
Msg |
sendRequest(URI to,
Msg data)
Sends a request message to the other end. |
void |
sendResponse(Msg data,
int requestId)
|
void |
setBackConnectURI(URI backConnectURI)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public ChannelPool(URI uri, Router dispatcher)
uri
- Method Detail |
public void dispose()
public void associate(Channel c) throws TransportException
TransportException
public void expireIdleConnections(long connectionTimeout)
public org.apache.geronimo.remoting.transport.async.ChannelPool.PooledAsynchChannel getNextAvailable() throws TransportException
RemotingException
TransportException
public void dispatchDatagram(URI to, Msg data, ChannelPool source)
data
- source
- - the channel pool that the datagram came over.public void dispatchRequest(URI to, AsyncMsg data, ChannelPool source)
data
- source
- - the channel pool that the request came over.public void sendDatagram(URI to, Msg data) throws TransportException
Router
sendDatagram
in interface Router
data
-
TransportException
public Msg sendRequest(URI to, Msg data) throws TransportException
Router
sendRequest
in interface Router
data
-
TransportException
public void sendResponse(Msg data, int requestId) throws TransportException
TransportException
public int getCreatedChannelCount()
public URI getBackConnectURI()
public void setBackConnectURI(URI backConnectURI)
backConnectURI
- The backConnectURI to set.
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |