|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectix.iserve.ipc.IServeCommServer
ix.iserve.ipc.sl.IServeSLCommServer
public class IServeSLCommServer
Handles messages for a IServeCommStrategy
.
Nested Class Summary | |
---|---|
(package private) class |
IServeSLCommServer.Awakener
|
(package private) class |
IServeSLCommServer.SLChatbotTestServlet
Sends a ChatMessage to whatever agent has registered
as "chat-service". |
protected class |
IServeSLCommServer.SLIdentityChecker
|
protected class |
IServeSLCommServer.SLIdentityCheckerFactory
|
(package private) class |
IServeSLCommServer.SLNextMessageServlet
|
(package private) class |
IServeSLCommServer.SLRegistrationServelt
|
(package private) class |
IServeSLCommServer.SLReplyServlet
Sends a reply to whoever sent the last message the replying agent has received. |
(package private) class |
IServeSLCommServer.SLSendServlet
|
Field Summary | |
---|---|
(package private) java.util.List<SLHttpHeader> |
headerProperties
|
(package private) SLRpc |
rpcClient
|
(package private) java.util.concurrent.ExecutorService |
wakeupPool
|
Fields inherited from class ix.iserve.ipc.IServeCommServer |
---|
userNameToUserMap |
Constructor Summary | |
---|---|
IServeSLCommServer()
|
|
IServeSLCommServer(IServe containingAgent)
Constructor used when making an IXAgentExtension . |
Method Summary | |
---|---|
protected void |
addServlets()
|
protected IServeCommServer.User |
ensureSLUser(java.lang.String name)
|
protected java.lang.String |
getHeaderAnnotation(MessageWrapper w,
SLHttpHeader h)
|
static void |
main(java.lang.String[] argv)
|
protected MessageWrapper |
makeMessageWrapper(IServeCommServer.Command command,
javax.servlet.http.HttpServletRequest req)
|
(package private) void |
maybeSendWakeup(IServeCommServer.User user)
|
protected void |
processCommandLineArguments()
|
protected void |
setHeaderAnnotation(MessageWrapper w,
SLHttpHeader h,
java.lang.String value)
|
(package private) void |
tryToWakeup(IServeCommServer.User user,
java.util.Date now)
|
Methods inherited from class ix.iserve.ipc.IServeCommServer |
---|
addServlet, agoTime, do_main, ensureIXUser, ensureUser, fillInRequestInfo, getListenPort, getName, getUser, getUsers, installExtension, makeServerStatus, recordUser, removeUser, removeUser, requireCommand, requireUser, start |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
final java.util.List<SLHttpHeader> headerProperties
java.util.concurrent.ExecutorService wakeupPool
SLRpc rpcClient
Constructor Detail |
---|
public IServeSLCommServer()
public IServeSLCommServer(IServe containingAgent)
IXAgentExtension
.
Method Detail |
---|
public static void main(java.lang.String[] argv)
protected void processCommandLineArguments()
processCommandLineArguments
in class IServeCommServer
protected void addServlets()
addServlets
in class IServeCommServer
protected MessageWrapper makeMessageWrapper(IServeCommServer.Command command, javax.servlet.http.HttpServletRequest req) throws HttpRequestException
HttpRequestException
protected void setHeaderAnnotation(MessageWrapper w, SLHttpHeader h, java.lang.String value)
protected java.lang.String getHeaderAnnotation(MessageWrapper w, SLHttpHeader h)
protected IServeCommServer.User ensureSLUser(java.lang.String name)
void maybeSendWakeup(IServeCommServer.User user)
void tryToWakeup(IServeCommServer.User user, java.util.Date now)
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES All Classes | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |