Package com.tibco.ep.tcs.runtime.engine
This package contains classes that implement the TIBCO Cloud Streaming flow engine. There are a set of runtime state classes corresponding to the elements of a TCS flow:
A factory
class produces
flow modules
from external textual representations, configuration
interfaces, or configuration classes, after validating them.
A flow engine
is responsible for using a flow factory to produce
flow modules, which it can then run.
A flow engine embeds a TIBCO Streaming StreamBase server runner
, which is responsible for running the flow.
Flow modules and server runners share a TIBCO Streaming StreamBase server
environment
, abstracting the runtime environment used by
typecheck and during module execution.
Finally, a block tester
and a
flow tester
are also provided so you can test blocks and flows
from within Java unit test environments.
-
Interface Summary Interface Description FlowTester.ITupleInitializer A callback class to initialize a tuple produced byFlowTester.enqueueTuple(java.lang.String, com.tibco.ep.tcs.runtime.engine.FlowTester.ITupleInitializer)
. -
Class Summary Class Description BlockTester Test infrastructure for TIBCO Cloud Streaming flow blocks.FlowTester Test infrastructure for TIBCO Cloud Streaming flows.