org.apache.logging.log4j.cassandra

Class CassandraManager

java.lang.Object

org.apache.logging.log4j.core.appender.AbstractManager

org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

org.apache.logging.log4j.cassandra.CassandraManager

All Implemented Interfaces:

Flushable, AutoCloseable

public class CassandraManager
extends org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

Manager for a Cassandra appender instance.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager.AbstractFactoryData

Field Summary

Fields inherited from class org.apache.logging.log4j.core.appender.AbstractManager

count, LOGGER

Method Summary

Modifier and Type	Method and Description
protected boolean	commitAndClose()
protected void	connectAndStart()
static CassandraManager	getManager(String name, org.apache.logging.log4j.core.net.SocketAddress[] contactPoints, org.apache.logging.log4j.core.appender.db.ColumnMapping[] columns, boolean useTls, String clusterName, String keyspace, String table, String username, String password, boolean useClockForTimestampGenerator, int bufferSize, boolean batched, com.datastax.driver.core.BatchStatement.Type batchType)
protected boolean	shutdownInternal()
protected void	startupInternal()
protected void	writeInternal(org.apache.logging.log4j.core.LogEvent event, Serializable serializable)

Methods inherited from class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

buffer, flush, getManager, isBuffered, isRunning, releaseSub, shutdown, startup, toString, write, write, writeInternal, writeThrough

Methods inherited from class org.apache.logging.log4j.core.appender.AbstractManager

close, getContentFormat, getCount, getLoggerContext, getName, hasManager, log, logDebug, logError, logger, logWarn, narrow, release, stop, updateData

Methods inherited from class java.lang.Object

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

Method Detail

startupInternal

protected void startupInternal()
                        throws Exception

Specified by:

startupInternal in class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

Throws:

Exception

shutdownInternal

protected boolean shutdownInternal()
                            throws Exception

Specified by:

shutdownInternal in class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

Throws:

Exception

connectAndStart

protected void connectAndStart()

Specified by:

connectAndStart in class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

writeInternal

protected void writeInternal(org.apache.logging.log4j.core.LogEvent event,
                             Serializable serializable)

Specified by:

writeInternal in class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

commitAndClose

protected boolean commitAndClose()

Specified by:

commitAndClose in class org.apache.logging.log4j.core.appender.db.AbstractDatabaseManager

getManager

public static CassandraManager getManager(String name,
                                          org.apache.logging.log4j.core.net.SocketAddress[] contactPoints,
                                          org.apache.logging.log4j.core.appender.db.ColumnMapping[] columns,
                                          boolean useTls,
                                          String clusterName,
                                          String keyspace,
                                          String table,
                                          String username,
                                          String password,
                                          boolean useClockForTimestampGenerator,
                                          int bufferSize,
                                          boolean batched,
                                          com.datastax.driver.core.BatchStatement.Type batchType)