Package com.illumon.iris.db.tables.dataimport.logtailer

Class DataImportCommandProcessor

java.lang.Object

com.illumon.iris.db.tables.dataimport.logtailer.DataImportProcessorBaseImpl

com.illumon.iris.db.tables.dataimport.logtailer.DataImportCommandProcessor

All Implemented Interfaces:

DataImportChannelProcessorBase, DataImportProcessorBase

public final class DataImportCommandProcessor
extends DataImportProcessorBaseImpl
implements DataImportChannelProcessorBase

Process commands from a client.

Field Summary

Fields inherited from class com.illumon.iris.db.tables.dataimport.logtailer.DataImportProcessorBaseImpl

CHECKPOINT_INTERVAL_MILLIS_SUFFIX, dataStreamProcessorDirectory, DISP_DEFAULT_PREFIX, DISP_PREFIX, FLUSH_INTERVAL_SUFFIX, log, logPrefix, MAX_SHUTDOWN_DELAY_MILLIS_SUFFIX, PROFILING_LEVEL_SUFFIX, schemaService

Fields inherited from interface com.illumon.iris.db.tables.dataimport.logtailer.DataImportChannelProcessorBase

NEW_LINE

Method Summary

Modifier and Type	Method	Description
void	close(String reason)
com.illumon.iris.db.tables.dataimport.logtailer.DataImportChannel	getChannel()	Get the DataImportChannel for this channel processor.
void	handleApplicationMessage(com.illumon.iris.db.tables.dataimport.logtailer.DataImportChannel channel, DataImportChannelItem item)
void	shutdown()	Perform any actions needed to terminate this DataImportProcessor.

Methods inherited from class com.illumon.iris.db.tables.dataimport.logtailer.DataImportProcessorBaseImpl

getLog, getLogPrefix

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.illumon.iris.db.tables.dataimport.logtailer.DataImportChannelProcessorBase

handleDisconnection, handleProtocolError, handleReadException, handleReject, handleUnexpectedMessage, initializeApplicationHandler, sendReject, sendReject, sendReject

Methods inherited from interface com.illumon.iris.db.tables.dataimport.logtailer.DataImportProcessorBase

getLog, getLogPrefix

Method Details

getChannel

@NotNull
public com.illumon.iris.db.tables.dataimport.logtailer.DataImportChannel getChannel()

Description copied from interface: DataImportChannelProcessorBase

Get the DataImportChannel for this channel processor.

Specified by:

getChannel in interface DataImportChannelProcessorBase

Returns:

the DataImportChannel

shutdown

public void shutdown()

Description copied from interface: DataImportProcessorBase

Perform any actions needed to terminate this DataImportProcessor.

Specified by:

shutdown in interface DataImportProcessorBase

close

public void close(@NotNull
 String reason)

handleApplicationMessage

public void handleApplicationMessage(@NotNull
 com.illumon.iris.db.tables.dataimport.logtailer.DataImportChannel channel,
 @NotNull
 DataImportChannelItem item)