AppServerConnectionPool (P2J - Progress 4GL to Java Conversion and Runtime)

java.lang.Object
- com.goldencode.p2j.main.AppServerConnectionPool

Direct Known Subclasses:

RemoteAppServerConnectionPool
```
public class AppServerConnectionPool
extends java.lang.Object
```
Provides a pool of workers, which have a FWD context as configured in the client's type (directory's soap, rest, web app node).
The workers are automatically connected when the first task is received. The workers should have a 1-to-1 mapping between them and the agents, and the pool size should never be configured larger than the number of agents available.

Field Summary

Fields
Modifier and Type	Field and Description
`private boolean`	`forWebService` Flag indicating if this worker pool is for web services managed by FWD.
`protected boolean`	`initialized` Flag indicating if the pool has initialized.
`private static CentralLogger`	`LOG` Anonymous log instance.
`private long`	`nextSessionId` The session ID generator.
`private int`	`poolSize` The number of `workers` started in this pool.
`private int`	`timeout` The timeout for a service call, defaults to 10 seconds.
`private java.lang.String`	`type` The directory node from where to read the configuration (rest, soap, WebHandler, someWebApp).
`private java.util.concurrent.PriorityBlockingQueue<LegacyServiceWorker>`	`workers` The pool of workers dedicated to executing legacy services.
`private java.util.Map<java.lang.String,LegacyServiceWorker>`	`workersByConnection` Mapping of workers by their connection ID.

Constructor Summary

Constructors
Constructor and Description

AppServerConnectionPool(java.lang.String type)
Create a new pool.

Constructors
Constructor and Description
`AppServerConnectionPool(java.lang.String type)` Create a new pool.

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`broadcast(LegacyAppServerWork work)` Broadcast a task to all the workers.
`boolean`	`dispatch(java.lang.String connectionID, LegacyAppServerWork work, java.lang.String target)` Code to process appserver requests.
`private void`	`doInitialize()` Initialize this pool.
`java.lang.String`	`getAppserver()` Get the target appserver name.
`int`	`getTimeout()` Get the `timeout`.
`java.lang.String`	`getType()` Get the service handler's `type`.
`void`	`initialize()` Initialize the connection pool, in a separate thread.
`boolean`	`isInitialized()` Get the state of the `initialized` flag.
`protected boolean`	`isSessionFree()` Check if the appserver connection must be in session-free mode.
`boolean`	`isWebService()` Check if this pool is for web services ran from within FWD.
`long`	`nextSessionId()` Get the next session ID.
`protected void`	`registerWorker(java.lang.String connectionID, LegacyServiceWorker worker)` Register the worker with the specified connection ID.
`void`	`setWebService()` Mark this pool as used internally by FWD, for web services.
`int`	`size()` Get the size of the pool.
`void`	`terminateWorkers()` Terminate the service worker threads.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - initialized
```
protected volatile boolean initialized
```
    Flag indicating if the pool has initialized.
  - LOG
```
private static final CentralLogger LOG
```
    Anonymous log instance.
  - workers
```
private java.util.concurrent.PriorityBlockingQueue<LegacyServiceWorker> workers
```
    The pool of workers dedicated to executing legacy services.
  - workersByConnection
```
private java.util.Map<java.lang.String,LegacyServiceWorker> workersByConnection
```
    Mapping of workers by their connection ID.
  - timeout
```
private volatile int timeout
```
    The timeout for a service call, defaults to 10 seconds.
  - type
```
private final java.lang.String type
```
    The directory node from where to read the configuration (rest, soap, WebHandler, someWebApp).
  - nextSessionId
```
private long nextSessionId
```
    The session ID generator.
  - forWebService
```
private volatile boolean forWebService
```
    Flag indicating if this worker pool is for web services managed by FWD.
  - poolSize
```
private int poolSize
```
    The number of workers started in this pool.
- Constructor Detail
  - AppServerConnectionPool
```
public AppServerConnectionPool(java.lang.String type)
```
    Create a new pool.
    
    Parameters:
    
    type - The directory node from where to read the configuration.
- Method Detail
  - nextSessionId
```
public long nextSessionId()
```
    Get the next session ID.
    
    Returns:
    
    See above.
  - setWebService
```
public void setWebService()
```
    Mark this pool as used internally by FWD, for web services.
  - isWebService
```
public boolean isWebService()
```
    Check if this pool is for web services ran from within FWD.
    
    Returns:
    
    See above.
  - isInitialized
```
public boolean isInitialized()
```
    Get the state of the initialized flag.
    
    Returns:
    
    See above.
  - broadcast
```
public void broadcast(LegacyAppServerWork work)
```
    Broadcast a task to all the workers.
    
    Parameters:
    
    work - The work to perform the request.
  - dispatch
```
public boolean dispatch(java.lang.String connectionID,
                        LegacyAppServerWork work,
                        java.lang.String target)
```
    Code to process appserver requests.
    
    Parameters:
    
    connectionID - When not-null, force to use the worker with the specified connection ID.
    
    work - The work to perform the request.
    
    target - The target path.
    
    Returns:
    
    true if the request was processed by a worker.
  - terminateWorkers
```
public void terminateWorkers()
```
    Terminate the service worker threads.
  - initialize
```
public void initialize()
```
    Initialize the connection pool, in a separate thread.
  - doInitialize
```
private void doInitialize()
```
    Initialize this pool.
  - getType
```
public java.lang.String getType()
```
    Get the service handler's type.
    
    Returns:
    
    The service type.
  - getTimeout
```
public int getTimeout()
```
    Get the timeout.
    
    Returns:
    
    See above.
  - size
```
public int size()
```
    Get the size of the pool.
    
    Returns:
    
    The pool size.
  - getAppserver
```
public java.lang.String getAppserver()
```
    Get the target appserver name.
    
    Returns:
    
    See above.
  - isSessionFree
```
protected boolean isSessionFree()
```
    Check if the appserver connection must be in session-free mode.
    
    Returns:
    
    See above.
  - registerWorker
```
protected void registerWorker(java.lang.String connectionID,
                              LegacyServiceWorker worker)
```
    Register the worker with the specified connection ID.
    
    Parameters:
    
    connectionID - The connection ID.
    
    worker - The service worker.

Class AppServerConnectionPool

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

initialized

LOG

workers

workersByConnection

timeout

type

nextSessionId

forWebService

poolSize

Constructor Detail

AppServerConnectionPool

Method Detail

nextSessionId

setWebService

isWebService

isInitialized

broadcast

dispatch

terminateWorkers

initialize

doInitialize

getType

getTimeout

size

getAppserver

isSessionFree

registerWorker