org.databene.platform.contiperf
Class PerfTrackingConsumer

java.lang.Object
  org.databene.platform.contiperf.PerfTrackingWrapper
      org.databene.platform.contiperf.PerfTrackingConsumer

All Implemented Interfaces:

java.io.Closeable, Consumer<java.lang.Object>

public class PerfTrackingConsumer
extends PerfTrackingWrapper
implements Consumer<java.lang.Object>

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<java.lang.Object> target)

PerfTrackingConsumer(Consumer<java.lang.Object> target, java.lang.String id)

Method Summary

void	close()
void	finishConsuming(java.lang.Object object)
void	flush()
protected org.databene.contiperf.Invoker	getInvoker()
void	setId(java.lang.String id)
void	setTarget(Consumer<java.lang.Object> target)
void	startConsuming(java.lang.Object object)

Methods inherited from class org.databene.platform.contiperf.PerfTrackingWrapper

getTracker, setExecutionLogger, 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<java.lang.Object> target)

PerfTrackingConsumer

public PerfTrackingConsumer(Consumer<java.lang.Object> target,
                            java.lang.String id)

Method Detail

setId

public void setId(java.lang.String id)

setTarget

public void setTarget(Consumer<java.lang.Object> target)

startConsuming

public void startConsuming(java.lang.Object object)

Specified by:

startConsuming in interface Consumer<java.lang.Object>

finishConsuming

public void finishConsuming(java.lang.Object object)

Specified by:

finishConsuming in interface Consumer<java.lang.Object>

flush

public void flush()

Specified by:

flush in interface Consumer<java.lang.Object>

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface Consumer<java.lang.Object>

Overrides:

close in class PerfTrackingWrapper

getInvoker

protected org.databene.contiperf.Invoker getInvoker()

Specified by:

getInvoker in class PerfTrackingWrapper