com.streambase.sb.unittest

Interface SBServerManager

public interface SBServerManager

SBServerManager provides control and access to a StreamBase server. Obtain one via ServerManagerFactory.

Since:

6.6

Method Summary

Modifier and Type	Method and Description
void	drain() Wait for processing to complete on all currently enqueued tuples.
Dequeuer	getDequeuer(String path) Get the dequeuer for this stream
Enqueuer	getEnqueuer(String path) Get the enqueuer for this stream
TableAccessor	getTableAccessor(String tablePath) Return a TableAccessor suitable for manipulating this table.
TableAccessor	getTableAccessor(String tablePath, CaptureTransformStrategy captureStrategy) Return a TableAccessor suitable for manipulating this table.
TimeService	getTimeService() Return the current TimeService implementation used by StreamBase server
StreamBaseURI	getURI() return the URI of the server
void	loadApp(String appFile) Load an application into the default container.
void	loadApp(String appFile, String container) Load an application into the specified container.
void	loadAppString(String appString, String container) Load an application (from a String) into the specified container.
void	loadDeploy(String deployFile) Load the given StreamBase deployment file.
void	setTimeService(TimeService timeService) Set a TimeService for the StreamBase Server managed by this Manager.
void	shutdownServer() Shutdown the server, blocking until the server is finished shutting down
void	startContainers() Start all the containers for this server.
void	startContainers(Set<String> containersSuspendedOnStartup) Start all but the specified containers for this server.
void	startContainers(Set<String> containersSuspendedOnStartup, boolean deferSubscriptions) Start all but the specified containers for this server
void	startServer() Start the server, blocking until the server will accept connections
void	stopContainers() Stop all containers in this server
void	subscribe(String streamPath) Subscribes to a stream.
void	subscribeAll() Subscribes to all streams

Method Detail

getEnqueuer

Enqueuer getEnqueuer(String path)
              throws StreamBaseException

Get the enqueuer for this stream

Parameters:

path - the path to the stream. If this is not a full dotted path, assumes the stream has the given name and is in the default container.

Throws:

StreamBaseException

getDequeuer

Dequeuer getDequeuer(String path)
              throws StreamBaseException

Get the dequeuer for this stream

Parameters:

path - the path to the stream. If this is not a full dotted path, assumes the stream has the given name and is in the default container.

Throws:

StreamBaseException

startServer

void startServer()
          throws InterruptedException,
                 StreamBaseException

Start the server, blocking until the server will accept connections

Throws:

InterruptedException

StreamBaseException

shutdownServer

void shutdownServer()
             throws InterruptedException,
                    StreamBaseException

Shutdown the server, blocking until the server is finished shutting down

Throws:

InterruptedException

StreamBaseException

loadApp

void loadApp(String appFile)
      throws StreamBaseException

Load an application into the default container. The server must be started prior to his call. Note that the application container will not be started (and thus no enqueues can be made to it) until a call to SBServerManager.startContainers() (or similar methods) is made.

Parameters:

appFile - The file name to be loaded. This must be a simple name, that is resolved against the server's module search path.

Throws:

StreamBaseException - on failure to load the given application

See Also:

SBServerManager.startServer(), SBServerManager.startContainers()

loadApp

void loadApp(String appFile,
             String container)
      throws StreamBaseException

Load an application into the specified container. The server must be started prior to his call. Note that the application container will not be started (and thus no enqueues can be made to it) until a call to SBServerManager.startContainers() (or similar methods) is made.

Parameters:

appFile - The file name to be loaded. This must be a simple name, that is resolved against the server's module search path.

container - The container name

Throws:

StreamBaseException - on failure to load the given application

See Also:

SBServerManager.startServer(), SBServerManager.startContainers()

loadAppString

void loadAppString(String appString,
                   String container)
            throws StreamBaseException

Load an application (from a String) into the specified container. The server must be started prior to his call. Note that the application container will not be started (and thus no enqueues can be made to it) until a call to SBServerManager.startContainers() (or similar methods) is made.

Parameters:

appString - A string which contains the text of an application (Eventflow or SSQL).

container - The container name

Throws:

StreamBaseException - on failure to load the given application

Since:

7.0

See Also:

SBServerManager.startServer(), SBServerManager.startContainers()

loadDeploy

void loadDeploy(String deployFile)
         throws StreamBaseException

Load the given StreamBase deployment file. The server must be started prior to this call. Note that the application containers will not be started until a call to SBServerManager.startContainers() (or similar methods) is made.

Throws:

StreamBaseException

Since:

7.0

startContainers

void startContainers()
              throws StreamBaseException

Start all the containers for this server. If no stream subscriptions have yet been specified, subscribes to all streams. To avoid this behavior, and instead subscribe to no streams, use SBServerManager.startContainers(Set, boolean) with a false argument instead.

Throws:

StreamBaseException

See Also:

SBServerManager.startContainers(Set, boolean), SBServerManager.subscribe(String)

startContainers

void startContainers(Set<String> containersSuspendedOnStartup)
              throws StreamBaseException

Start all but the specified containers for this server. If subscriptions have previously been declared using calls to subscribe(), will only subscribe to the declared subscriptions. Otherwise, if no stream subscriptions have yet been specified, subscribes to all streams. To avoid this behavior, and instead subscribe to no streams, call startContainers(containersSuspendedOnStartup, true)

Parameters:

containersSuspendedOnStartup - The containers to leave suspended, if null all containers will be started

Throws:

StreamBaseException

See Also:

SBServerManager.startContainers(Set, boolean)

startContainers

void startContainers(Set<String> containersSuspendedOnStartup,
                     boolean deferSubscriptions)
              throws StreamBaseException

Start all but the specified containers for this server

Parameters:

containersSuspendedOnStartup - The containers to leave suspended, if null all containers will be started

deferSubscriptions - when true, no output streams will be subscribed to

Throws:

StreamBaseException

subscribeAll

void subscribeAll()
           throws StreamBaseException

Subscribes to all streams

Throws:

StreamBaseException

subscribe

void subscribe(String streamPath)
        throws StreamBaseException

Subscribes to a stream. This method is used to pre-declare the streams you are interested in prior to calling startContainers().

Parameters:

streamPath - the path to the stream. If this is not a full dotted path, assumes the stream has the given name and is in the default container.

Throws:

StreamBaseException

stopContainers

void stopContainers()
             throws StreamBaseException

Stop all containers in this server

Throws:

StreamBaseException

drain

void drain()
    throws StreamBaseException

Wait for processing to complete on all currently enqueued tuples.

A call to this method blocks until any tuples that were already enqueued in the server have run through to completion, to the best effort of the server. Upon return, any tuples that have reached output streams will be available for dequeue from Dequeuer.dequeue(int).

Note that for applications containing concurrent modules or operators, this method makes attempts to ensure it returns once all processing has completed, but does not guarantee this behavior.

Throws:

StreamBaseException - if an error occurs while draining; no guarantees are made about the state of pending tuples.

Since:

7.0.6

getURI

StreamBaseURI getURI()

return the URI of the server

Returns:

URI of the server

Since:

7.0

getTableAccessor

TableAccessor getTableAccessor(String tablePath)
                        throws StreamBaseException

Return a TableAccessor suitable for manipulating this table. This may only work with embedded servers. Capture fields in the table will be flattened.

Parameters:

tablePath - Path to the table.

Returns:

the TableAccessor

Throws:

NotImplementedException - if table accessors are not supported by this server implementation.

StreamBaseException - if there is no table at that path, or if the table is inaccessible for any other reason.

SemanticValidationException - if the table is inaccessible because of a capture field naming conflict. In that case, call with CaptureTransformStrategy.NEST

Since:

7.3

getTableAccessor

TableAccessor getTableAccessor(String tablePath,
                               CaptureTransformStrategy captureStrategy)
                        throws StreamBaseException

Return a TableAccessor suitable for manipulating this table. This may only work with embedded servers.

Parameters:

tablePath - Path to the table.

captureStrategy - Strategy for handling any capture fields in the table, either FLATTEN or NEST.

Returns:

the TableAccessor

Throws:

NotImplementedException - if table accessors are not supported by this server implementation.

StreamBaseException - if there is no table at that path, or if the table is inaccessible for any other reason.

SemanticValidationException - if the table is inaccessible because of a capture field naming conflict. In that case, call with CaptureTransformStrategy.NEST

Since:

7.3

setTimeService

void setTimeService(TimeService timeService)

Set a TimeService for the StreamBase Server managed by this Manager. If this call succeeds the timeService object will be set as the current Server-wide time service so it will be shared by all the containers and modules in this server

Thread safety note: you can call this method from any thread but you should make sure that it is not called from more than one thread at the same time. Otherwise the result is unpredictable.

Parameters:

timeService - a TimeService instance or null. If this is a valid TimeService instance it will be set as the current time service for the entire StreamBase server if this is null then StreamBase server will use the WallClockTimeService, which is the default TimeService implementation You should obtain a valid TimeService instance via TimeServiceFactory

Throws:

UnsupportedOperationException - if there was a problem setting the server-wide time service

Since:

7.4

getTimeService

TimeService getTimeService()
                    throws StreamBaseException

Return the current TimeService implementation used by StreamBase server

Thread safety note: you can call this method from any thread but you should make sure that it is not called from more than one thread at the same time and while this method is called no other thread calls setTimeService method. Otherwise the result is unpredictable.

Returns:

the current TimeService

Throws:

StreamBaseException - if there was a problem retrieving the current server-wide time service

Since:

7.4