Class ShrinkProcessor

java.lang.Object

com.swiftmq.impl.store.standard.processor.shrink.ShrinkProcessor

All Implemented Interfaces:

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

public class ShrinkProcessor
extends Object
implements EventVisitor, CheckPointFinishedListener

Constructor Summary

Constructors

Constructor	Description
ShrinkProcessor(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(StartShrink po)

Methods inherited from class Object

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

Constructor Details

ShrinkProcessor

public ShrinkProcessor(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(StartShrink 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