org.databene.model.storage
Class StorageSystemConsumer

java.lang.Object
  org.databene.model.consumer.AbstractConsumer<Entity>
      org.databene.model.storage.StorageSystemConsumer

All Implemented Interfaces:

java.io.Closeable, Consumer<Entity>

public class StorageSystemConsumer
extends AbstractConsumer<Entity>

Stores an Entity in the associated StorageSystem. It replaces the class SystemProcessor.

Created: 29.01.2008 09:35:07

Since:

0.4.0

Author:

Volker Bergmann

Constructor Summary

StorageSystemConsumer(StorageSystem system, boolean insert)

Method Summary

void	close()
void	flush()
void	startConsuming(Entity entity)
java.lang.String	toString()

Methods inherited from class org.databene.model.consumer.AbstractConsumer

finishConsuming

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageSystemConsumer

public StorageSystemConsumer(StorageSystem system,
                             boolean insert)

Method Detail

startConsuming

public void startConsuming(Entity entity)

flush

public void flush()

Specified by:

flush in interface Consumer<Entity>

Overrides:

flush in class AbstractConsumer<Entity>

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface Consumer<Entity>

Overrides:

close in class AbstractConsumer<Entity>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object