Package com.swiftmq.impl.streams.processor

Class StreamProcessor

java.lang.Object

com.swiftmq.impl.streams.processor.StreamProcessor

All Implemented Interfaces:

POStreamVisitor, POVisitor

public class StreamProcessor
extends java.lang.Object
implements POStreamVisitor

Constructor Summary

Constructors

Constructor	Description
StreamProcessor(StreamContext ctx, StreamController controller)

Method Summary

Modifier and Type	Method	Description
void	dispatch(POObject po)
java.lang.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 java.lang.Object

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

Constructor Detail

StreamProcessor

public StreamProcessor(StreamContext ctx,
                       StreamController controller)

Method Detail

dispatch

public void dispatch(POObject po)

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 java.lang.String toString()

Overrides:

toString in class java.lang.Object