Package org.globus.gram
Class CallbackHandler
- java.lang.Object
-
- org.globus.net.BaseServer
-
- org.globus.gram.CallbackHandler
-
- All Implemented Interfaces:
Runnable
public class CallbackHandler extends BaseServer
TheServer
class 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(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 GramJob
getJob(String url)
int
getRegisteredJobsSize()
Returns number of registered jobsString
getURL()
Returns url of this serverprotected void
handleConnection(Socket socket)
This method needs to be implemented by subclasses.void
registerJob(GramJob job)
Registers gram job to listen for status updatesvoid
unregisterJob(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 IOException
Construct a GRAM callback handler with default user credentials. Port will be dynamically assigned.- Throws:
IOException
-
CallbackHandler
public CallbackHandler(GSSCredential cred, int port) throws IOException
Construct 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:
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
-
getRegisteredJobsSize
public int getRegisteredJobsSize()
Returns number of registered jobs- Returns:
- int number of jobs
-
getURL
public String getURL()
Description copied from class:BaseServer
Returns url of this server- Overrides:
getURL
in classBaseServer
- Returns:
- url of this server
-
handleConnection
protected void handleConnection(Socket socket)
Description copied from class:BaseServer
This 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:
handleConnection
in classBaseServer
-
-