Package org.globus.gram
Class CallbackHandler
- java.lang.Object
-
- org.globus.net.BaseServer
-
- org.globus.gram.CallbackHandler
-
- All Implemented Interfaces:
java.lang.Runnable
public class CallbackHandler extends BaseServer
TheServerclass acts as a basic multi-threaded HTTPS server.- Version:
- $Revision: 1.31 $
-
-
Field Summary
-
Fields inherited from class org.globus.net.BaseServer
_server, accept, authorization, credentials, deactivator, gssMode, SO_TIMEOUT, timeout, url
-
-
Constructor Summary
Constructors Constructor Description CallbackHandler()Construct a GRAM callback handler with default user credentials.CallbackHandler(org.ietf.jgss.GSSCredential cred, int port)Construct a GRAM callback handler with specifed credentials and given port.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected GramJobgetJob(java.lang.String url)intgetRegisteredJobsSize()Returns number of registered jobsjava.lang.StringgetURL()Returns url of this serverprotected voidhandleConnection(java.net.Socket socket)This method needs to be implemented by subclasses.voidregisterJob(GramJob job)Registers gram job to listen for status updatesvoidunregisterJob(GramJob job)Unregisters gram job from listening to status updates-
Methods inherited from class org.globus.net.BaseServer
getCredentials, getHost, getHostname, getPort, getProtocol, getTimeout, initialize, registerDefaultDeactivator, run, setAuthorization, setGssMode, setTimeout, shutdown, start, unregisterDefaultDeactivator, wrapSocket
-
-
-
-
Constructor Detail
-
CallbackHandler
public CallbackHandler() throws java.io.IOExceptionConstruct a GRAM callback handler with default user credentials. Port will be dynamically assigned.- Throws:
java.io.IOException
-
CallbackHandler
public CallbackHandler(org.ietf.jgss.GSSCredential cred, int port) throws java.io.IOExceptionConstruct a GRAM callback handler with specifed credentials and given port.- Parameters:
cred- credentials to use. if null default user credentials will be usedport- server port to listen on. if set to 0 the port will be dynamically assigned- Throws:
java.io.IOException
-
-
Method Detail
-
registerJob
public void registerJob(GramJob job)
Registers gram job to listen for status updates- Parameters:
job- gram job
-
unregisterJob
public void unregisterJob(GramJob job)
Unregisters gram job from listening to status updates- Parameters:
job- gram job
-
getJob
protected GramJob getJob(java.lang.String url)
-
getRegisteredJobsSize
public int getRegisteredJobsSize()
Returns number of registered jobs- Returns:
- int number of jobs
-
getURL
public java.lang.String getURL()
Description copied from class:BaseServerReturns url of this server- Overrides:
getURLin classBaseServer- Returns:
- url of this server
-
handleConnection
protected void handleConnection(java.net.Socket socket)
Description copied from class:BaseServerThis method needs to be implemented by subclasses. Optimmaly, it should be a non-blocking call starting a separate thread to handle the client. Note that to start an SSL handshake, you need to call socket.getInput(Output) stream().- Specified by:
handleConnectionin classBaseServer
-
-