org.graylog2.shared.inputs

Class InputLauncher

java.lang.Object

org.graylog2.shared.inputs.InputLauncher

public class InputLauncher
extends Object

Constructor Summary

Constructors

Constructor and Description
InputLauncher(IOState.Factory<MessageInput> inputStateFactory, InputBuffer inputBuffer, PersistedInputs persistedInputs, InputRegistry inputRegistry, com.codahale.metrics.MetricRegistry metricRegistry, Configuration configuration, LeaderElectionService leaderElectionService)

Method Summary

Modifier and Type	Method and Description
protected void	handleLaunchException(Throwable e, IOState<MessageInput> inputState)
IOState<MessageInput>	launch(MessageInput input)
void	launchAllPersisted()
boolean	leaderStatusInhibitsLaunch(MessageInput input)
boolean	shouldStartAutomatically(MessageInput input)

Methods inherited from class java.lang.Object

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

Constructor Detail

InputLauncher

@Inject
public InputLauncher(IOState.Factory<MessageInput> inputStateFactory,
                             InputBuffer inputBuffer,
                             PersistedInputs persistedInputs,
                             InputRegistry inputRegistry,
                             com.codahale.metrics.MetricRegistry metricRegistry,
                             Configuration configuration,
                             LeaderElectionService leaderElectionService)

Method Detail

launch

public IOState<MessageInput> launch(MessageInput input)

handleLaunchException

protected void handleLaunchException(Throwable e,
                                     IOState<MessageInput> inputState)

launchAllPersisted

public void launchAllPersisted()

shouldStartAutomatically

public boolean shouldStartAutomatically(MessageInput input)

leaderStatusInhibitsLaunch

public boolean leaderStatusInhibitsLaunch(MessageInput input)