Class StreamProcessor

java.lang.Object

com.swiftmq.impl.streams.processor.StreamProcessor

All Implemented Interfaces:

POStreamVisitor, com.swiftmq.tools.pipeline.POVisitor

public class StreamProcessor
extends Object
implements POStreamVisitor

Constructor Summary

Constructors

Constructor	Description
StreamProcessor(StreamContext ctx, StreamController controller)

Method Summary

Modifier and Type	Method	Description
void	close()
void	dispatch(com.swiftmq.tools.pipeline.POObject po)
String	toString()
void	visit(POClose po)
void	visit(POCollect po)
void	visit(POExecute po)
void	visit(POFunctionCallback po)
void	visit(POMessage po)
void	visit(POMgmtMessage po)
void	visit(POStart po)
void	visit(POTimer po)
void	visit(POWireTapMessage po)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

StreamProcessor

public StreamProcessor(StreamContext ctx,
 StreamController controller)

Method Details

dispatch

public void dispatch(com.swiftmq.tools.pipeline.POObject po)

close

public void close()

visit

public void visit(POStart po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POWireTapMessage po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POMgmtMessage po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POMessage po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POFunctionCallback po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POExecute po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POCollect po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POTimer po)

Specified by:

visit in interface POStreamVisitor

visit

public void visit(POClose po)

Specified by:

visit in interface POStreamVisitor

toString

public String toString()

Overrides:

toString in class Object