Constructor Detail

• ORemoteConnectionPool

  public ORemoteConnectionPool(int iMaxResources,
                               boolean createAsyncListener)

Method Detail

• createNetworkConnection

  protected OChannelBinaryAsynchClient createNetworkConnection(String iServerURL,
                                                               OContextConfiguration clientConfiguration,
                                                               Map<String,Object> iAdditionalArg)
                                                        throws OIOException

  Throws:

  OIOException

• createNewResource

  public OChannelBinaryAsynchClient createNewResource(String iKey,
                                                      Object... iAdditionalArgs)

  Description copied from interface: OResourcePoolListener
  Creates a new resource to be used and to be pooled when the client finishes with it.

  Specified by:

  createNewResource in interface OResourcePoolListener<String,OChannelBinaryAsynchClient>

  Returns:

  The new resource

• reuseResource

  public boolean reuseResource(String iKey,
                               Object[] iAdditionalArgs,
                               OChannelBinaryAsynchClient iValue)

  Description copied from interface: OResourcePoolListener
  Reuses the pooled resource.

  Specified by:

  reuseResource in interface OResourcePoolListener<String,OChannelBinaryAsynchClient>

  Returns:

  true if can be reused, otherwise false. In this case the resource will be removed from the pool

• getPool

  public OResourcePool<String,OChannelBinaryAsynchClient> getPool()

• onChannelClose

  public void onChannelClose(OChannel channel)

  Specified by:

  onChannelClose in interface OChannelListener

• acquire

  public OChannelBinaryAsynchClient acquire(String iServerURL,
                                            long timeout,
                                            OContextConfiguration clientConfiguration,
                                            Map<String,Object> iConfiguration,
                                            OStorageRemoteAsynchEventListener iListener)