Uses of Class
com.swiftmq.impl.streams.Stream

Packages that use Stream

Package	Description
com.swiftmq.impl.streams
com.swiftmq.impl.streams.comp.jdbc

Uses of Stream in com.swiftmq.impl.streams

Fields in com.swiftmq.impl.streams declared as Stream

Modifier and Type	Field	Description
Stream	StreamContext.stream

Methods in com.swiftmq.impl.streams that return Stream

Modifier and Type	Method	Description
Stream	Stream.current(Message current)	Sets/overwrites the currently processed Message.
Stream	Stream.executeCallback(FunctionCallback functionCallback, Object context)	Executes a function callback in the Stream's event queue.
Stream	Stream.onException(ExceptionCallback runnable)	Sets the onException callback.
Stream	Stream.onMessage(Runnable runnable)	Sets the onMessage callback.
Stream	Stream.onStart(Runnable runnable)	Sets the onStart callback.
Stream	Stream.onStop(Runnable runnable)	Sets the onStop callback.
Stream	Stream.purgeOutputs()	Closes all Outputs that were not used between the last and this call to this method.
Stream	Stream.removeInput(Input input)	Internal use only
Stream	Stream.removeJDBCLookup(String name)	Internal use only
Stream	Stream.removeMailServer(String name)	Internal use only
Stream	Stream.removeOutput(String name)	Internal use only
Stream	Stream.removeTempQueue(TempQueue tempQueue)	Internal use only
Stream	Stream.removeTimer(Timer timer)	Internal use only

Methods in com.swiftmq.impl.streams with parameters of type Stream

Modifier and Type	Method	Description
static Object	AsyncProxy.newInstance(Stream stream, String interfaceClassName, Object obj)

Uses of Stream in com.swiftmq.impl.streams.comp.jdbc

Methods in com.swiftmq.impl.streams.comp.jdbc with parameters of type Stream

Modifier and Type	Method	Description
static Memory	Util.query(Stream stream, Connection connection, String sql)