Modifier and Type | Field and Description |
---|---|
static int |
QueueSize |
static String |
ServerLookupName |
static String |
SyncLookupName |
static String |
SyncQueueName |
Constructor and Description |
---|
OASyncServer(int port) |
OASyncServer(Package packagex,
int port) |
Modifier and Type | Method and Description |
---|---|
protected void |
_runLoadDataInBackground() |
protected void |
afterInvokeRemoteMethod(RequestInfo ri) |
Object |
createBroadcast(String bindName,
Class interfaceClass,
String queueName,
int queueSize) |
Object |
createBroadcast(String bindName,
Object callback,
Class interfaceClass,
String queueName,
int queueSize) |
void |
createLookup(String name,
Object obj,
Class interfaceClass) |
void |
createLookup(String name,
Object obj,
Class interfaceClass,
String queueName,
int queueSize) |
Object |
createSyncBroadcast(String bindName,
Class interfaceClass) |
Object |
createSyncBroadcast(String bindName,
Object callback,
Class interfaceClass) |
void |
createSyncLookup(String name,
Object obj,
Class interfaceClass)
use the same queue that is used by sync remote object.
|
ClientInfo |
getClientInfo() |
String |
getDisplayMessage() |
String |
getInvalidConnectionMessage(String defaultMsg) |
protected String |
getLogFileName() |
MultiplexerServer |
getMultiplexerServer()
Used to manage multiplexed socket connections from client computers.
|
protected RemoteClientInterface |
getRemoteClient(ClientInfo ci) |
protected RemoteClientInterface |
getRemoteClientForServer() |
RemoteMultiplexerServer |
getRemoteMultiplexerServer() |
RemoteServerImpl |
getRemoteServer() |
protected RemoteSessionInterface |
getRemoteSession(ClientInfo ci,
RemoteClientCallbackInterface callback) |
protected RemoteSessionInterface |
getRemoteSessionForServer() |
RemoteSyncImpl |
getRemoteSync() |
ServerFile |
getServerFile() |
ServerInfo |
getServerInfo() |
int |
getSessionCount() |
Socket |
getSocket(int connectionId) |
protected void |
loadDataInBackground(OAObject obj,
String property)
called when props or sibling data cant be loaded for client getDetail request, because of timeout.
|
protected void |
logRequest(RequestInfo ri) |
protected void |
onClientConnect(Socket socket,
int connectionId) |
protected void |
onClientDisconnect(int connectionId) |
protected void |
onClientException(ClientInfo ci,
String msg,
Throwable ex) |
protected void |
onSessionCreated(int connectionId,
Socket socket) |
protected void |
onSessionRemoved(int connectionId) |
void |
onUpdate(ClientInfo ci)
This can be overwritten to capture info about the server and client connections.
|
void |
performDGC() |
void |
saveCache(OACascade cascade,
int iCascadeRule)
Saved serverSide cached objects from clients.
|
void |
setInvalidConnectionMessage(String msg) |
void |
start() |
protected void |
startLoadDataInBackgroundThread() |
void |
startUpdateThread(int seconds)
updates ClientInfo
|
void |
stop() |
public static final String ServerLookupName
public static final String SyncLookupName
public static final String SyncQueueName
public static final int QueueSize
public OASyncServer(int port)
public OASyncServer(Package packagex, int port)
public RemoteSyncImpl getRemoteSync()
public RemoteServerImpl getRemoteServer()
public ClientInfo getClientInfo()
protected RemoteSessionInterface getRemoteSessionForServer()
protected RemoteClientInterface getRemoteClientForServer()
protected RemoteSessionInterface getRemoteSession(ClientInfo ci, RemoteClientCallbackInterface callback)
public void startUpdateThread(int seconds)
public void onUpdate(ClientInfo ci)
protected RemoteClientInterface getRemoteClient(ClientInfo ci)
public void saveCache(OACascade cascade, int iCascadeRule)
public ServerInfo getServerInfo()
public void setInvalidConnectionMessage(String msg)
public MultiplexerServer getMultiplexerServer()
protected void onClientConnect(Socket socket, int connectionId)
protected void onClientDisconnect(int connectionId)
public Socket getSocket(int connectionId)
protected void onClientException(ClientInfo ci, String msg, Throwable ex)
public String getDisplayMessage()
public RemoteMultiplexerServer getRemoteMultiplexerServer()
public int getSessionCount()
protected void onSessionCreated(int connectionId, Socket socket)
protected void onSessionRemoved(int connectionId)
public void createSyncLookup(String name, Object obj, Class interfaceClass)
public void createLookup(String name, Object obj, Class interfaceClass, String queueName, int queueSize)
public Object createBroadcast(String bindName, Class interfaceClass, String queueName, int queueSize)
public Object createBroadcast(String bindName, Object callback, Class interfaceClass, String queueName, int queueSize)
public Object createSyncBroadcast(String bindName, Object callback, Class interfaceClass)
protected void afterInvokeRemoteMethod(RequestInfo ri)
protected void logRequest(RequestInfo ri) throws Exception
Exception
protected String getLogFileName()
public void performDGC()
public ServerFile getServerFile()
protected void loadDataInBackground(OAObject obj, String property)
protected void startLoadDataInBackgroundThread() throws Exception
Exception
protected void _runLoadDataInBackground()
Copyright © 1999–2019 ViaOA. All rights reserved.