org.databene.platform.contiperf
Class PerfTrackingConsumer

java.lang.Object
  extended by org.databene.platform.contiperf.PerfTrackingWrapper
      extended by org.databene.platform.contiperf.PerfTrackingConsumer
All Implemented Interfaces:
java.io.Closeable, java.io.Flushable, Consumer

public class PerfTrackingConsumer
extends PerfTrackingWrapper
implements Consumer

Consumer implementation that calls a ContiPerf PerfTrackingConsumer.

Created: 22.10.2009 16:17:14

Since:
0.6.0
Author:
Volker Bergmann

Constructor Summary
PerfTrackingConsumer()
           
PerfTrackingConsumer(Consumer target)
           
PerfTrackingConsumer(Consumer target, java.lang.String id)
           
 
Method Summary
 void close()
          When called, the implementor has to close and free all resources.
 void finishConsuming(ProductWrapper<?> wrapper)
          Starts consumption of an object.
 void flush()
          Is called by Benerator for advising the Consumer to finish processing of the objects consumed so far.
protected  org.databene.contiperf.Invoker getInvoker()
           
 void setId(java.lang.String id)
           
 void setTarget(Consumer target)
           
 void startConsuming(ProductWrapper<?> wrapper)
          Starts consumption of an object.
 
Methods inherited from class org.databene.platform.contiperf.PerfTrackingWrapper
getOrCreateTracker, setContext, setMax, setPercentiles
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

PerfTrackingConsumer

public PerfTrackingConsumer()

PerfTrackingConsumer

public PerfTrackingConsumer(Consumer target)

PerfTrackingConsumer

public PerfTrackingConsumer(Consumer target,
                            java.lang.String id)
Method Detail

setId

public void setId(java.lang.String id)

setTarget

public void setTarget(Consumer target)

startConsuming

public void startConsuming(ProductWrapper<?> wrapper)
Description copied from interface: Consumer
Starts consumption of an object. For invocation details see the class documentation.

Specified by:
startConsuming in interface Consumer

finishConsuming

public void finishConsuming(ProductWrapper<?> wrapper)
Description copied from interface: Consumer
Starts consumption of an object. For invocation details see the class documentation.

Specified by:
finishConsuming in interface Consumer

flush

public void flush()
Description copied from interface: Consumer
Is called by Benerator for advising the Consumer to finish processing of the objects consumed so far. In Benerator descriptor files, the flushing behavior is controlled by the pageSize attribute.

Specified by:
flush in interface java.io.Flushable
Specified by:
flush in interface Consumer

close

public void close()
Description copied from interface: Consumer
When called, the implementor has to close and free all resources. It will not receive any more calls.

Specified by:
close in interface java.io.Closeable
Specified by:
close in interface Consumer
Overrides:
close in class PerfTrackingWrapper

getInvoker

protected org.databene.contiperf.Invoker getInvoker()
Specified by:
getInvoker in class PerfTrackingWrapper


Copyright © 2013. All Rights Reserved.