org.graylog2.outputs

Class OutputRegistry

java.lang.Object

org.graylog2.outputs.OutputRegistry

@Singleton
public class OutputRegistry
extends Object

Constructor Summary

Constructors

Constructor and Description
OutputRegistry(MessageOutput defaultMessageOutput, OutputService outputService, MessageOutputFactory messageOutputFactory, NotificationService notificationService, NodeId nodeId, com.google.common.eventbus.EventBus eventBus, StreamService streamService, long faultCountThreshold, long faultPenaltySeconds)

Method Summary

Modifier and Type	Method and Description
Set<MessageOutput>	getMessageOutputs()
MessageOutput	getOutputForIdAndStream(String id, Stream stream)
protected Map<String,MessageOutput>	getRunningMessageOutputs()
void	handleOutputChanged(OutputChangedEvent outputChangedEvent) Stops the output and removes it from the registry.
void	handleOutputDeleted(OutputDeletedEvent outputDeletedEvent)
void	handleStreamsChanged(StreamsChangedEvent streamsChangedEvent) Whenever a stream changes, this could mean that an output was removed from it.
protected MessageOutput	launchOutput(Output output, Stream stream)
Callable<MessageOutput>	loadForIdAndStream(String id, Stream stream)
void	removeOutput(Output output)

Methods inherited from class java.lang.Object

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

Constructor Detail

OutputRegistry

@Inject
public OutputRegistry(MessageOutput defaultMessageOutput,
                              OutputService outputService,
                              MessageOutputFactory messageOutputFactory,
                              NotificationService notificationService,
                              NodeId nodeId,
                              com.google.common.eventbus.EventBus eventBus,
                              StreamService streamService,
                              @Named(value="output_fault_count_threshold")
                              long faultCountThreshold,
                              @Named(value="output_fault_penalty_seconds")
                              long faultPenaltySeconds)

Method Detail

handleOutputChanged

public void handleOutputChanged(OutputChangedEvent outputChangedEvent)

Stops the output and removes it from the registry. It will be restarted automatically by the OutputRouter via getOutputForIdAndStream(String, Stream)

handleStreamsChanged

public void handleStreamsChanged(StreamsChangedEvent streamsChangedEvent)

Whenever a stream changes, this could mean that an output was removed from it. Checks which outputs are currently assigned to any streams and removes those from the registry which are not expected to be running.

handleOutputDeleted

public void handleOutputDeleted(OutputDeletedEvent outputDeletedEvent)

getOutputForIdAndStream

@Nullable
public MessageOutput getOutputForIdAndStream(String id,
                                                       Stream stream)

loadForIdAndStream

public Callable<MessageOutput> loadForIdAndStream(String id,
                                                  Stream stream)

launchOutput

protected MessageOutput launchOutput(Output output,
                                     Stream stream)
                              throws MessageOutputConfigurationException

Throws:

MessageOutputConfigurationException

getRunningMessageOutputs

protected Map<String,MessageOutput> getRunningMessageOutputs()

getMessageOutputs

public Set<MessageOutput> getMessageOutputs()

removeOutput

public void removeOutput(Output output)