public class TCPServerSOContainer extends ServerSOContainer implements IConnectRequestHandler
| Modifier and Type | Field and Description |
|---|---|
static boolean |
DEFAULT_FALLBACK_PORT |
static String |
DEFAULT_HOST |
static int |
DEFAULT_KEEPALIVE |
static String |
DEFAULT_NAME |
static int |
DEFAULT_PORT |
static String |
DEFAULT_PROTOCOL |
protected TCPServerSOContainerGroup |
group |
protected boolean |
isSingle |
protected int |
keepAlive |
connectHandlerPolicyconfig, DEFAULT_OBJECT_ARG_KEY, DEFAULT_OBJECT_ARGTYPES_KEY, groupManager, isClosing, loadingThreadGroup, policy, receiver, sharedObjectManager, sharedObjectMessageSerializer, sharedObjectThreadGroup| Constructor and Description |
|---|
TCPServerSOContainer(ISharedObjectContainerConfig config) |
TCPServerSOContainer(ISharedObjectContainerConfig config,
InetAddress bindAddress,
int keepAlive) |
TCPServerSOContainer(ISharedObjectContainerConfig config,
int keepAlive) |
TCPServerSOContainer(ISharedObjectContainerConfig config,
int port,
InetAddress bindAddress,
String path,
int keepAlive) |
TCPServerSOContainer(ISharedObjectContainerConfig config,
TCPServerSOContainerGroup grp,
int keepAlive) |
TCPServerSOContainer(ISharedObjectContainerConfig config,
TCPServerSOContainerGroup listener,
String path,
int keepAlive) |
| Modifier and Type | Method and Description |
|---|---|
void |
dispose()
Dispose this IContainer instance.
|
protected Serializable |
getConnectDataFromInput(Serializable input) |
static String |
getDefaultServerURL() |
protected int |
getKeepAlive() |
static String |
getServerURL(String host,
String name) |
Serializable |
handleConnectRequest(Socket socket,
String target,
Serializable data,
ISynchAsynchConnection conn)
Handle a connect request from remote client
|
protected void |
initialize(TCPServerSOContainerGroup listener,
String path,
int ka) |
acceptNewClient, checkJoin, connect, disconnect, ejectAllGroupMembers, ejectGroupMember, forwardExcluding, forwardToRemote, getConnectedID, getConnectionForID, getIDForConnection, getSynchConnectionForID, handleLeaveGroupMessage, handleViewChangeMessage, isGroupManager, processDisconnect, queueContainerMessage, setConnectPolicyaddNewRemoteMember, addSharedObject0, addSharedObjectAndWait, addSharedObjectWrapper, addToLoading, checkRemoteCreate, createContainerPropertiesForSharedObject, createRemoteSharedObjectConfig, createRemoteSharedObjectContext, createRemoteSharedObjectWrapper, createSharedObjectConfig, createSharedObjectContext, createSharedObjectWrapper, debug, defaultDeserializeSharedObjectMessage, defaultSerializeSharedObjectMessage, deserializeContainerMessage, deserializeSharedObjectMessage, destroySharedObject, disconnect, fireDelegateContainerEvent, forward, getAdapter, getArgsFromProperties, getArgTypesFromProperties, getClassLoaderForContainer, getClassLoaderForSharedObject, getConfig, getConnectNamespace, getGroupMemberIDs, getGroupMembershipLock, getID, getMaxGroupMembers, getMessageReceiver, getNewSharedObjectThread, getNextSequenceNumber, getOtherMemberIDs, getReceiver, getSharedObject, getSharedObjectIDs, getSharedObjectManager, getSharedObjectMessageSerializer, getSharedObjectWrapper, handleAsynchIOException, handleCreateMessage, handleCreateResponseMessage, handleLeave, handleSharedObjectDisposeMessage, handleSharedObjectMessage, handleUndeliveredSharedObjectMessage, handleUnidentifiedMessage, isClosing, load, moveFromLoadingToActive, notifySharedObjectActivated, notifySharedObjectDeactivated, printToSystemError, processAsynch, processSynch, removeFromLoading, removeRemoteMember, removeSharedObject, sendCreate, sendCreateResponse, sendCreateResponseSharedObjectMessage, sendCreateSharedObjectMessage, sendDispose, sendDisposeSharedObjectMessage, sendMessage, sendMessage, sendSharedObjectMessage, serialize, serializeSharedObjectMessage, setMaxGroupMembers, setRemoteAddPolicy, setSharedObjectMessageSerializer, traceStack, validateContainerMessage, verifySharedObjectMessageTarget, verifyToIDForSharedObjectMessageaddListener, fireContainerEvent, getPasswordFromConnectContext, removeListenerclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddListener, removeListenerpublic static final String DEFAULT_PROTOCOL
public static final int DEFAULT_PORT
public static final int DEFAULT_KEEPALIVE
public static final String DEFAULT_NAME
public static String DEFAULT_HOST
public static final boolean DEFAULT_FALLBACK_PORT
protected int keepAlive
protected TCPServerSOContainerGroup group
protected boolean isSingle
public TCPServerSOContainer(ISharedObjectContainerConfig config, int port, InetAddress bindAddress, String path, int keepAlive) throws IOException
config - configport - portbindAddress - bind addresspath - pathkeepAlive - keep aliveIOException - if some problem creatingpublic TCPServerSOContainer(ISharedObjectContainerConfig config, InetAddress bindAddress, int keepAlive) throws IOException, URISyntaxException
config - configbindAddress - bind addresskeepAlive - keep aliveIOException - if some problem creatingURISyntaxException - if some problem creatingpublic TCPServerSOContainer(ISharedObjectContainerConfig config, TCPServerSOContainerGroup grp, int keepAlive) throws IOException, URISyntaxException
IOExceptionURISyntaxExceptionpublic TCPServerSOContainer(ISharedObjectContainerConfig config, TCPServerSOContainerGroup listener, String path, int keepAlive)
public TCPServerSOContainer(ISharedObjectContainerConfig config) throws IOException, URISyntaxException
IOExceptionURISyntaxExceptionpublic TCPServerSOContainer(ISharedObjectContainerConfig config, int keepAlive) throws IOException, URISyntaxException
IOExceptionURISyntaxExceptionprotected int getKeepAlive()
public static String getDefaultServerURL()
protected void initialize(TCPServerSOContainerGroup listener, String path, int ka)
public void dispose()
IContainerdispose in interface IContainerdispose in class ServerSOContainerpublic Serializable handleConnectRequest(Socket socket, String target, Serializable data, ISynchAsynchConnection conn)
IConnectRequestHandlerhandleConnectRequest in interface IConnectRequestHandlersocket - the Socket that the request came in ontarget - the target that the request is intended fordata - any data that was sent along with request (e.g. password or
other authentication data)conn - the connection instance that received the requestprotected Serializable getConnectDataFromInput(Serializable input) throws Exception
ExceptionCopyright © 2004–2020 Eclipse Foundation. All rights reserved.