Package | Description |
---|---|
org.ogf.saga.stream |
The streams package provides a simple mechanism for setting up
connections to remote components.
|
Modifier and Type | Method and Description |
---|---|
static StreamServer |
StreamFactory.createStreamServer()
Creates a StreamServer using the default session.
|
static StreamServer |
StreamFactory.createStreamServer(Session session)
Creates a StreamServer.
|
static StreamServer |
StreamFactory.createStreamServer(Session session,
URL name)
Creates a StreamServer.
|
static StreamServer |
StreamFactory.createStreamServer(String sagaFactoryClassname)
Creates a StreamServer using the default session.
|
static StreamServer |
StreamFactory.createStreamServer(String sagaFactoryClassname,
Session session)
Creates a StreamServer.
|
static StreamServer |
StreamFactory.createStreamServer(String sagaFactoryClassname,
Session session,
URL name)
Creates a StreamServer.
|
static StreamServer |
StreamFactory.createStreamServer(String sagaFactoryClassname,
URL name)
Creates a StreamServer using the default session.
|
static StreamServer |
StreamFactory.createStreamServer(URL name)
Creates a StreamServer using the default session.
|
protected abstract StreamServer |
StreamFactory.doCreateStreamServer(Session session,
URL name)
Creates a StreamServer.
|
Modifier and Type | Method and Description |
---|---|
Task<StreamServer,Void> |
StreamServer.close(TaskMode mode)
Obtains a task that closes a stream server.
|
Task<StreamServer,Void> |
StreamServer.close(TaskMode mode,
float timeoutInSeconds)
Obtains a task that closes a stream server.
|
Task<StreamServer,Stream> |
StreamServer.connect(TaskMode mode)
Returns a task that establishes a connection to the stream server.
|
Task<StreamServer,Stream> |
StreamServer.connect(TaskMode mode,
float timeoutInSeconds)
Returns a task that establishes a connection to the stream server.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode)
Creates a task that creates a StreamServer using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode,
Session session)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode,
Session session,
URL name)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(String sagaFactoryClassname,
TaskMode mode,
URL name)
Creates a task that creates a StreamServer using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode)
Creates a task that creates a StreamServer using the default session.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode,
Session session)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode,
Session session,
URL name)
Creates a task that creates a StreamServer.
|
static Task<StreamFactory,StreamServer> |
StreamFactory.createStreamServer(TaskMode mode,
URL name)
Creates a task that creates a StreamServer using the default session.
|
protected abstract Task<StreamFactory,StreamServer> |
StreamFactory.doCreateStreamServer(TaskMode mode,
Session session,
URL name)
Creates a task that creates a StreamServer.
|
Task<StreamServer,URL> |
StreamServer.getUrl(TaskMode mode)
Obtains a task to obtain the URL to be used to connect to this server.
|
Task<StreamServer,Stream> |
StreamServer.serve(TaskMode mode)
Obtains a task that waits for incoming client connections (like an accept
of a serversocket).
|
Task<StreamServer,Stream> |
StreamServer.serve(TaskMode mode,
float timeoutInSeconds)
Obtains a task that waits for incoming client connections (like an accept
of a serversocket).
|
Copyright © 2016 Open Grid Forum. All rights reserved.