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 |
connectHandlerPolicy
config, 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, setConnectPolicy
addNewRemoteMember, 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, verifyToIDForSharedObjectMessage
addListener, fireContainerEvent, getPasswordFromConnectContext, removeListener
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addListener, removeListener
public 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
IOException
URISyntaxException
public TCPServerSOContainer(ISharedObjectContainerConfig config, TCPServerSOContainerGroup listener, String path, int keepAlive)
public TCPServerSOContainer(ISharedObjectContainerConfig config) throws IOException, URISyntaxException
IOException
URISyntaxException
public TCPServerSOContainer(ISharedObjectContainerConfig config, int keepAlive) throws IOException, URISyntaxException
IOException
URISyntaxException
protected int getKeepAlive()
public static String getDefaultServerURL()
protected void initialize(TCPServerSOContainerGroup listener, String path, int ka)
public void dispose()
IContainer
dispose
in interface IContainer
dispose
in class ServerSOContainer
public Serializable handleConnectRequest(Socket socket, String target, Serializable data, ISynchAsynchConnection conn)
IConnectRequestHandler
handleConnectRequest
in interface IConnectRequestHandler
socket
- 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
Exception
Copyright © 2004–2020 Eclipse Foundation. All rights reserved.