Class ScanProcessor

java.lang.Object

com.swiftmq.impl.store.standard.processor.scan.ScanProcessor

All Implemented Interfaces:

CheckPointFinishedListener, EventVisitor, com.swiftmq.tools.pipeline.POVisitor

public class ScanProcessor
extends Object
implements EventVisitor, CheckPointFinishedListener

Constructor Summary

Constructors

Constructor	Description
ScanProcessor(StoreContext ctx)

Method Summary

Modifier and Type	Method	Description
void	checkpointFinished()
void	close()
void	enqueue(com.swiftmq.tools.pipeline.POObject po)
String	toString()
void	visit(Close po)
void	visit(StartScan po)

Methods inherited from class Object

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

Constructor Details

ScanProcessor

public ScanProcessor(StoreContext ctx)

Method Details

checkpointFinished

public void checkpointFinished()

Specified by:

checkpointFinished in interface CheckPointFinishedListener

enqueue

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

visit

public void visit(StartScan po)

Specified by:

visit in interface EventVisitor

visit

public void visit(Close po)

Specified by:

visit in interface EventVisitor

close

public void close()

toString

public String toString()

Overrides:

toString in class Object