org.refcodes.logger.alt.simpledb.impls

Class SimpleDbLoggerImpl<T>

java.lang.Object

org.refcodes.logger.alt.simpledb.impls.AbstractSimpleDbClient

org.refcodes.logger.alt.simpledb.impls.SimpleDbLoggerImpl<T>

Type Parameters:

T - The type of the Record instances managed by the Logger.

All Implemented Interfaces:

Flushable, org.refcodes.component.Component, org.refcodes.component.Decomposeable, org.refcodes.component.Destroyable, org.refcodes.component.Initializable, org.refcodes.logger.Logger<T>

Direct Known Subclasses:

SimpleDbQueryLoggerImpl

public class SimpleDbLoggerImpl<T>
extends AbstractSimpleDbClient
implements org.refcodes.logger.Logger<T>, org.refcodes.component.Component, org.refcodes.component.Initializable, org.refcodes.component.Decomposeable, org.refcodes.component.Flushable

The SimpleDbLoggerImpl is the Amazon SimpleDB implementation of the Logger interface. As Amazon SimpleDB stores only String values (everything is a String), type information may be lost as inferencing from the String content may not be possible. The Record instances Column.toStorageString(Object) and Column.fromStorageString(String) methods are used to apply conversion.

ATTENTION: Logging field values exceeding the size of 1024 characters will be truncated and an error message is logged out. We assume not having fields longer than 1024 bytes with this implementation of the Logger.

Nested Class Summary

Nested classes/interfaces inherited from interface org.refcodes.component.Destroyable

org.refcodes.component.Destroyable.DestroyAutomaton

Nested classes/interfaces inherited from interface org.refcodes.component.Initializable

org.refcodes.component.Initializable.InitializeAutomaton, org.refcodes.component.Initializable.InitializeBuilder<B extends org.refcodes.component.Initializable.InitializeBuilder<B>>, org.refcodes.component.Initializable.UncheckedInitializable

Nested classes/interfaces inherited from interface org.refcodes.component.Decomposeable

org.refcodes.component.Decomposeable.DecomposeAutomaton

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.refcodes.logger.RuntimeLogger	LOGGER

Constructor Summary

Constructors

Constructor and Description
SimpleDbLoggerImpl(String aDomainName, String aAccessKey, String aSecretKey, org.refcodes.tabular.ColumnFactory<T> aColumnFactory) Constructs the SimpleDbLoggerImpl for a given SimpleDB domain.
SimpleDbLoggerImpl(String aDomainName, String aAccessKey, String aSecretKey, String aEndPoint, org.refcodes.tabular.ColumnFactory<T> aColumnFactory) Constructs the SimpleDbLoggerImpl for a given SimpleDB domain.

Method Summary

Modifier and Type	Method and Description
protected void	addHeaderColumn(String eKey) Adds a key to the dynamically created Header for reducing object creation overhead when massively logging data as no Column instances are created once the key was already added.
void	decompose() Tears down this component, also removes external resources. ------------------------------------------------------------------------- ATTENTION: This method will also tear down the Amazon SimpleDB domain!
void	destroy()
void	flush() Flushes buffered log lines, when shutting down this component via the destroy() method, the buffer then is flushed automatically!
protected void	flushBuffer() Flushes the buffer with Records already encapsulated in Amazon SimpleDB's items.
protected org.refcodes.tabular.Header<T>	getHeader() Provides access to the Header member variable required for Record related operation.
void	initialize()
void	log(org.refcodes.tabular.Record<? extends T> aRecord)

Methods inherited from class org.refcodes.logger.alt.simpledb.impls.AbstractSimpleDbClient

clearDomain, getAmazonSimpleDbClient, getAmazonSimpleDbClient, getAmazonSimpleDbDomainName, getDomainNames, hasDomain, isRequestTimeoutException, isServiceUnavailableException, setAmazonSimpleDbDomainName, toMessage

Methods inherited from class java.lang.Object

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

Field Detail

LOGGER

protected static org.refcodes.logger.RuntimeLogger LOGGER

Constructor Detail

SimpleDbLoggerImpl

public SimpleDbLoggerImpl(String aDomainName,
                          String aAccessKey,
                          String aSecretKey,
                          org.refcodes.tabular.ColumnFactory<T> aColumnFactory)

Constructs the SimpleDbLoggerImpl for a given SimpleDB domain.

Parameters:

aDomainName - The name for the Amazon SimpleDB domain

aAccessKey - The Amazon access key for Amazon SimpleDB

aSecretKey - The Amazon secret key for Amazon SimpleDB

aColumnFactory - The ColumnFactory to create default Column instances for Record instances to be processed

Throws:

UnknownDomainAliasException - in case the campaigning domain alias cannot be resolved.

SimpleDbLoggerImpl

public SimpleDbLoggerImpl(String aDomainName,
                          String aAccessKey,
                          String aSecretKey,
                          String aEndPoint,
                          org.refcodes.tabular.ColumnFactory<T> aColumnFactory)

Constructs the SimpleDbLoggerImpl for a given SimpleDB domain.

Parameters:

aDomainName - The name for the Amazon SimpleDB domain

aAccessKey - The Amazon access key for Amazon SimpleDB

aSecretKey - The Amazon secret key for Amazon SimpleDB

aEndPoint - The end-point (Amazon region) to use (see AbstractSimpleDbClient's constructor documentation for possible values).

aColumnFactory - The ColumnFactory to create default Column instances for Record instances to be processed

Method Detail

log

public void log(org.refcodes.tabular.Record<? extends T> aRecord)
         throws org.refcodes.logger.IllegalRecordRuntimeException,
                org.refcodes.logger.UnexpectedLogRuntimeException

Specified by:

log in interface org.refcodes.logger.Logger<T>

Throws:

org.refcodes.logger.IllegalRecordRuntimeException

org.refcodes.logger.UnexpectedLogRuntimeException

initialize

public void initialize()
                throws org.refcodes.component.InitializeException

Specified by:

initialize in interface org.refcodes.component.Initializable

Throws:

org.refcodes.component.InitializeException

destroy

public void destroy()

Specified by:

destroy in interface org.refcodes.component.Destroyable

decompose

public void decompose()

Tears down this component, also removes external resources. ------------------------------------------------------------------------- ATTENTION: This method will also tear down the Amazon SimpleDB domain! -------------------------------------------------------------------------

Specified by:

decompose in interface org.refcodes.component.Decomposeable

flush

public void flush()
           throws org.refcodes.component.OpenException

Flushes buffered log lines, when shutting down this component via the destroy() method, the buffer then is flushed automatically! Especially useful when unit testing the SimpleDbLoggerImpl, then flushing can be forced by the test case.

Specified by:

flush in interface Flushable

Throws:

org.refcodes.component.OpenException

getHeader

protected org.refcodes.tabular.Header<T> getHeader()

Provides access to the Header member variable required for Record related operation.

Returns:

The Header.

addHeaderColumn

protected void addHeaderColumn(String eKey)

Adds a key to the dynamically created Header for reducing object creation overhead when massively logging data as no Column instances are created once the key was already added.

Parameters:

eKey - The key for which a Column is to be added.

flushBuffer

protected void flushBuffer()

Flushes the buffer with Records already encapsulated in Amazon SimpleDB's items.