org.graylog2.inputs

Class ServerInputRegistry

java.lang.Object

org.graylog2.shared.inputs.InputRegistry

org.graylog2.inputs.ServerInputRegistry

public class ServerInputRegistry
extends InputRegistry

Field Summary

Fields

Modifier and Type	Field and Description
protected InputService	inputService
protected NotificationService	notificationService

Fields inherited from class org.graylog2.shared.inputs.InputRegistry

executor, inputStates

Constructor Summary

Constructors

Constructor and Description
ServerInputRegistry(MessageInputFactory messageInputFactory, ProcessBuffer processBuffer, ServerStatus serverStatus, ActivityWriter activityWriter, InputService inputService, NotificationService notificationService, com.codahale.metrics.MetricRegistry metricRegistry)

Method Summary

Modifier and Type	Method and Description
void	cleanInput(MessageInput messageInput)
protected void	finishedLaunch(InputState state)
protected void	finishedStop(InputState inputState)
protected void	finishedTermination(InputState state)
protected java.util.List<MessageInput>	getAllPersisted()

Methods inherited from class org.graylog2.shared.inputs.InputRegistry

create, getAvailableInputs, getInputState, getInputStates, getPersisted, getRunningInput, getRunningInputs, getRunningInputState, handleLaunchException, hasTypeRunning, launch, launch, launch, launch, launch, launchAllPersisted, launchPersisted, removeFromRunning, runningCount, stop, terminate

Methods inherited from class java.lang.Object

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

Field Detail

inputService

protected final InputService inputService

notificationService

protected final NotificationService notificationService

Constructor Detail

ServerInputRegistry

public ServerInputRegistry(MessageInputFactory messageInputFactory,
                           ProcessBuffer processBuffer,
                           ServerStatus serverStatus,
                           ActivityWriter activityWriter,
                           InputService inputService,
                           NotificationService notificationService,
                           com.codahale.metrics.MetricRegistry metricRegistry)

Method Detail

getAllPersisted

protected java.util.List<MessageInput> getAllPersisted()

Specified by:

getAllPersisted in class InputRegistry

cleanInput

public void cleanInput(MessageInput messageInput)

Specified by:

cleanInput in class InputRegistry

finishedLaunch

protected void finishedLaunch(InputState state)

Specified by:

finishedLaunch in class InputRegistry

finishedTermination

protected void finishedTermination(InputState state)

Specified by:

finishedTermination in class InputRegistry

finishedStop

protected void finishedStop(InputState inputState)

Specified by:

finishedStop in class InputRegistry