Uses of Class
org.graylog2.plugin.inputs.MessageInput

Packages that use MessageInput

Package	Description
org.graylog.aws.inputs.cloudtrail
org.graylog.integrations.aws.inputs
org.graylog.integrations.aws.transports
org.graylog.integrations.inputs.paloalto
org.graylog.integrations.inputs.paloalto11
org.graylog.integrations.inputs.paloalto9
org.graylog.integrations.ipfix.inputs
org.graylog.integrations.ipfix.transports
org.graylog.plugins.beats
org.graylog.plugins.cef.input
org.graylog.plugins.netflow.inputs
org.graylog.plugins.netflow.transport
org.graylog2.contentpacks.facades
org.graylog2.inputs
org.graylog2.inputs.beats.kafka
org.graylog2.inputs.codecs.gelf
org.graylog2.inputs.gelf.amqp
org.graylog2.inputs.gelf.http
org.graylog2.inputs.gelf.kafka
org.graylog2.inputs.gelf.tcp
org.graylog2.inputs.gelf.udp
org.graylog2.inputs.misc.jsonpath
org.graylog2.inputs.random
org.graylog2.inputs.raw.amqp
org.graylog2.inputs.raw.http
org.graylog2.inputs.raw.kafka
org.graylog2.inputs.raw.tcp
org.graylog2.inputs.raw.udp
org.graylog2.inputs.syslog.amqp
org.graylog2.inputs.syslog.kafka
org.graylog2.inputs.syslog.tcp
org.graylog2.inputs.syslog.udp
org.graylog2.inputs.transports
org.graylog2.inputs.transports.netty
org.graylog2.plugin
org.graylog2.plugin.inject
org.graylog2.plugin.inputs.transports
org.graylog2.plugin.inputs.util
org.graylog2.shared.inputs

Uses of MessageInput in org.graylog.aws.inputs.cloudtrail

Subclasses of MessageInput in org.graylog.aws.inputs.cloudtrail

Modifier and Type	Class	Description
class	CloudTrailInput

Methods in org.graylog.aws.inputs.cloudtrail with parameters of type MessageInput

Modifier and Type	Method	Description
void	CloudTrailTransport.doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)

Constructors in org.graylog.aws.inputs.cloudtrail with parameters of type MessageInput

Modifier	Constructor	Description
	CloudTrailSubscriber(com.amazonaws.regions.Region sqsRegion, com.amazonaws.regions.Region s3Region, String queueName, MessageInput sourceInput, AWSAuthProvider authProvider, okhttp3.HttpUrl proxyUrl, com.fasterxml.jackson.databind.ObjectMapper objectMapper, InputFailureRecorder inputFailureRecorder)

Uses of MessageInput in org.graylog.integrations.aws.inputs

Subclasses of MessageInput in org.graylog.integrations.aws.inputs

Modifier and Type	Class	Description
class	AWSInput	General AWS input for all types of supported AWS logs.

Uses of MessageInput in org.graylog.integrations.aws.transports

Methods in org.graylog.integrations.aws.transports with parameters of type MessageInput

Modifier and Type	Method	Description
void	AWSTransport.doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	KinesisTransport.doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)

Uses of MessageInput in org.graylog.integrations.inputs.paloalto

Subclasses of MessageInput in org.graylog.integrations.inputs.paloalto

Modifier and Type	Class	Description
class	PaloAltoTCPInput

Uses of MessageInput in org.graylog.integrations.inputs.paloalto11

Subclasses of MessageInput in org.graylog.integrations.inputs.paloalto11

Modifier and Type	Class	Description
class	PaloAlto11xInput

Uses of MessageInput in org.graylog.integrations.inputs.paloalto9

Subclasses of MessageInput in org.graylog.integrations.inputs.paloalto9

Modifier and Type	Class	Description
class	PaloAlto9xInput

Uses of MessageInput in org.graylog.integrations.ipfix.inputs

Subclasses of MessageInput in org.graylog.integrations.ipfix.inputs

Modifier and Type	Class	Description
class	IpfixUdpInput

Uses of MessageInput in org.graylog.integrations.ipfix.transports

Methods in org.graylog.integrations.ipfix.transports with parameters of type MessageInput

Modifier and Type	Method	Description
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	IpfixUdpTransport.getChannelHandlers(MessageInput input)

Uses of MessageInput in org.graylog.plugins.beats

Subclasses of MessageInput in org.graylog.plugins.beats

Modifier and Type	Class	Description
class	Beats2Input
class	BeatsInput

Methods in org.graylog.plugins.beats with parameters of type MessageInput

Modifier and Type	Method	Description
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	BeatsTransport.getCustomChildChannelHandlers(MessageInput input)

Uses of MessageInput in org.graylog.plugins.cef.input

Subclasses of MessageInput in org.graylog.plugins.cef.input

Modifier and Type	Class	Description
class	CEFAmqpInput
class	CEFKafkaInput
class	CEFTCPInput
class	CEFUDPInput

Uses of MessageInput in org.graylog.plugins.netflow.inputs

Subclasses of MessageInput in org.graylog.plugins.netflow.inputs

Modifier and Type	Class	Description
class	NetFlowUdpInput

Uses of MessageInput in org.graylog.plugins.netflow.transport

Methods in org.graylog.plugins.netflow.transport with parameters of type MessageInput

Modifier and Type	Method	Description
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	NetFlowUdpTransport.getChannelHandlers(MessageInput input)

Uses of MessageInput in org.graylog2.contentpacks.facades

Constructor parameters in org.graylog2.contentpacks.facades with type arguments of type MessageInput

Modifier	Constructor	Description
	InputFacade(com.fasterxml.jackson.databind.ObjectMapper objectMapper, InputService inputService, InputRegistry inputRegistry, DBLookupTableService lookupTableService, GrokPatternService grokPatternService, MessageInputFactory messageInputFactory, ExtractorFactory extractorFactory, ConverterFactory converterFactory, ServerStatus serverStatus, Set<PluginMetaData> pluginMetaData, Map<String,MessageInput.Factory<? extends MessageInput>> inputFactories)

Uses of MessageInput in org.graylog2.inputs

Methods in org.graylog2.inputs that return MessageInput

Modifier and Type	Method	Description
MessageInput	PersistedInputsImpl.get(String id)
MessageInput	InputService.getMessageInput(Input io)
MessageInput	InputServiceImpl.getMessageInput(Input io)

Methods in org.graylog2.inputs that return types with arguments of type MessageInput

Modifier and Type	Method	Description
Iterator<MessageInput>	PersistedInputsImpl.iterator()

Method parameters in org.graylog2.inputs with type arguments of type MessageInput

Modifier and Type	Method	Description
void	InputStateListener.inputStateChanged(IOStateChangedEvent<MessageInput> event)

Uses of MessageInput in org.graylog2.inputs.beats.kafka

Subclasses of MessageInput in org.graylog2.inputs.beats.kafka

Modifier and Type	Class	Description
class	BeatsKafkaInput

Uses of MessageInput in org.graylog2.inputs.codecs.gelf

Methods in org.graylog2.inputs.codecs.gelf that return MessageInput

Modifier and Type	Method	Description
MessageInput	GELFMessageChunk.getSourceInput()

Constructors in org.graylog2.inputs.codecs.gelf with parameters of type MessageInput

Modifier	Constructor	Description
	GELFMessageChunk(byte[] payload, MessageInput sourceInput)
	GELFMessageChunk(GELFMessage msg, MessageInput sourceInput)

Uses of MessageInput in org.graylog2.inputs.gelf.amqp

Subclasses of MessageInput in org.graylog2.inputs.gelf.amqp

Modifier and Type	Class	Description
class	GELFAMQPInput

Uses of MessageInput in org.graylog2.inputs.gelf.http

Subclasses of MessageInput in org.graylog2.inputs.gelf.http

Modifier and Type	Class	Description
class	GELFHttpInput

Uses of MessageInput in org.graylog2.inputs.gelf.kafka

Subclasses of MessageInput in org.graylog2.inputs.gelf.kafka

Modifier and Type	Class	Description
class	GELFKafkaInput

Uses of MessageInput in org.graylog2.inputs.gelf.tcp

Subclasses of MessageInput in org.graylog2.inputs.gelf.tcp

Modifier and Type	Class	Description
class	GELFTCPInput

Uses of MessageInput in org.graylog2.inputs.gelf.udp

Subclasses of MessageInput in org.graylog2.inputs.gelf.udp

Modifier and Type	Class	Description
class	GELFUDPInput

Uses of MessageInput in org.graylog2.inputs.misc.jsonpath

Subclasses of MessageInput in org.graylog2.inputs.misc.jsonpath

Modifier and Type	Class	Description
class	JsonPathInput

Uses of MessageInput in org.graylog2.inputs.random

Subclasses of MessageInput in org.graylog2.inputs.random

Modifier and Type	Class	Description
class	FakeHttpMessageInput

Uses of MessageInput in org.graylog2.inputs.raw.amqp

Subclasses of MessageInput in org.graylog2.inputs.raw.amqp

Modifier and Type	Class	Description
class	RawAMQPInput

Uses of MessageInput in org.graylog2.inputs.raw.http

Subclasses of MessageInput in org.graylog2.inputs.raw.http

Modifier and Type	Class	Description
class	RawHttpInput

Uses of MessageInput in org.graylog2.inputs.raw.kafka

Subclasses of MessageInput in org.graylog2.inputs.raw.kafka

Modifier and Type	Class	Description
class	RawKafkaInput

Uses of MessageInput in org.graylog2.inputs.raw.tcp

Subclasses of MessageInput in org.graylog2.inputs.raw.tcp

Modifier and Type	Class	Description
class	RawTCPInput

Uses of MessageInput in org.graylog2.inputs.raw.udp

Subclasses of MessageInput in org.graylog2.inputs.raw.udp

Modifier and Type	Class	Description
class	RawUDPInput

Uses of MessageInput in org.graylog2.inputs.syslog.amqp

Subclasses of MessageInput in org.graylog2.inputs.syslog.amqp

Modifier and Type	Class	Description
class	SyslogAMQPInput

Uses of MessageInput in org.graylog2.inputs.syslog.kafka

Subclasses of MessageInput in org.graylog2.inputs.syslog.kafka

Modifier and Type	Class	Description
class	SyslogKafkaInput

Uses of MessageInput in org.graylog2.inputs.syslog.tcp

Subclasses of MessageInput in org.graylog2.inputs.syslog.tcp

Modifier and Type	Class	Description
class	SyslogTCPInput

Uses of MessageInput in org.graylog2.inputs.syslog.udp

Subclasses of MessageInput in org.graylog2.inputs.syslog.udp

Modifier and Type	Class	Description
class	SyslogUDPInput

Uses of MessageInput in org.graylog2.inputs.transports

Methods in org.graylog2.inputs.transports with parameters of type MessageInput

Modifier and Type	Method	Description
void	AmqpTransport.doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	HttpPollTransport.doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	KafkaTransport.doLaunch(MessageInput input)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	UdpTransport.getChannelHandlers(MessageInput input)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	UdpTransport.getChildChannelHandlers(MessageInput input)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	AbstractHttpTransport.getCustomChildChannelHandlers(MessageInput input)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	SyslogTcpTransport.getCustomChildChannelHandlers(MessageInput input)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	TcpTransport.getCustomChildChannelHandlers(MessageInput input)
void	AbstractHttpTransport.launch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	UdpTransport.launch(MessageInput input)
protected RawMessage	RandomMessageTransport.produceRawMessage(MessageInput input)

Constructors in org.graylog2.inputs.transports with parameters of type MessageInput

Modifier	Constructor	Description
	AmqpConsumer(int heartbeatTimeout, MessageInput sourceInput, Configuration configuration, ScheduledExecutorService scheduler, InputFailureRecorder inputFailureRecorder, AmqpTransport amqpTransport, EncryptedValueService encryptedValueService, Duration connectionRecoveryInterval)

Uses of MessageInput in org.graylog2.inputs.transports.netty

Constructors in org.graylog2.inputs.transports.netty with parameters of type MessageInput

Modifier	Constructor	Description
	EnvelopeMessageHandler(MessageInput input)
	ExceptionLoggingChannelHandler(MessageInput input, org.slf4j.Logger logger)
	ExceptionLoggingChannelHandler(MessageInput input, org.slf4j.Logger logger, boolean keepAliveEnabled)
	RawMessageHandler(MessageInput input)

Uses of MessageInput in org.graylog2.plugin

Methods in org.graylog2.plugin with type parameters of type MessageInput

Modifier and Type	Method	Description
protected <T extends MessageInput> void	PluginModule.addMessageInput(Class<T> messageInputClass, Class<? extends MessageInput.Factory<T>> factoryClass)

Method parameters in org.graylog2.plugin with type arguments of type MessageInput

Modifier and Type	Method	Description
protected void	PluginModule.addMessageInput(Class<? extends MessageInput> messageInputClass)

Constructor parameters in org.graylog2.plugin with type arguments of type MessageInput

Modifier	Constructor	Description
	InputFailureRecorder(IOState<MessageInput> inputState)

Uses of MessageInput in org.graylog2.plugin.inject

Methods in org.graylog2.plugin.inject with type parameters of type MessageInput

Modifier and Type	Method	Description
protected <T extends MessageInput> void	Graylog2Module.installInput(com.google.inject.multibindings.MapBinder<String,MessageInput.Factory<? extends MessageInput>> inputMapBinder, Class<T> target)
protected <T extends MessageInput> void	Graylog2Module.installInput(com.google.inject.multibindings.MapBinder<String,MessageInput.Factory<? extends MessageInput>> inputMapBinder, Class<T> target, Class<? extends MessageInput.Factory<T>> targetFactory)

Methods in org.graylog2.plugin.inject that return types with arguments of type MessageInput

Modifier and Type	Method	Description
protected com.google.inject.multibindings.MapBinder<String,MessageInput.Factory<? extends MessageInput>>	Graylog2Module.inputsMapBinder()

Method parameters in org.graylog2.plugin.inject with type arguments of type MessageInput

Modifier and Type	Method	Description
protected <T extends MessageInput> void	Graylog2Module.installInput(com.google.inject.multibindings.MapBinder<String,MessageInput.Factory<? extends MessageInput>> inputMapBinder, Class<T> target)
protected <T extends MessageInput> void	Graylog2Module.installInput(com.google.inject.multibindings.MapBinder<String,MessageInput.Factory<? extends MessageInput>> inputMapBinder, Class<T> target, Class<? extends MessageInput.Factory<T>> targetFactory)

Uses of MessageInput in org.graylog2.plugin.inputs.transports

Methods in org.graylog2.plugin.inputs.transports with parameters of type MessageInput

Modifier and Type	Method	Description
void	GeneratorTransport.doLaunch(MessageInput input)
protected abstract void	ThrottleableTransport.doLaunch(MessageInput input)	Deprecated. Performs the same purpose as ThrottleableTransport.launch(org.graylog2.plugin.inputs.MessageInput) but guarantees that the superclass' actions are performed.
protected final void	ThrottleableTransport2.doLaunch(MessageInput input)
protected abstract void	ThrottleableTransport2.doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)
protected io.netty.bootstrap.ServerBootstrap	AbstractTcpTransport.getBootstrap(MessageInput input)
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	NettyTransport.getChannelHandlers(MessageInput input)	Subclasses can override this to add additional channel handlers to the Netty ChannelPipeline to support additional features.
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	AbstractTcpTransport.getChildChannelHandlers(MessageInput input)
protected abstract LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	NettyTransport.getChildChannelHandlers(MessageInput input)	Subclasses can override this to modify the channel handlers for child channels.
protected LinkedHashMap<String,Callable<? extends io.netty.channel.ChannelHandler>>	NettyTransport.getCustomChildChannelHandlers(MessageInput input)	Subclasses can override this to modify the channel handlers at the end of the pipeline for child channels.
void	AbstractTcpTransport.launch(MessageInput input)
void	ThrottleableTransport.launch(MessageInput input)	Deprecated.
void	ThrottleableTransport2.launch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	Transport.launch(MessageInput input)
default void	Transport.launch(MessageInput input, InputFailureRecorder inputFailureRecorder)
protected abstract RawMessage	GeneratorTransport.produceRawMessage(MessageInput input)

Uses of MessageInput in org.graylog2.plugin.inputs.util

Constructors in org.graylog2.plugin.inputs.util with parameters of type MessageInput

Modifier	Constructor	Description
	PacketInformationDumper(MessageInput sourceInput)

Uses of MessageInput in org.graylog2.shared.inputs

Methods in org.graylog2.shared.inputs that return MessageInput

Modifier and Type	Method	Description
MessageInput	MessageInputFactory.create(String type, Configuration configuration)
MessageInput	MessageInputFactory.create(InputCreateRequest lr, String user, String nodeId)
MessageInput	PersistedInputs.get(String id)
MessageInput	InputRegistry.getRunningInput(String inputId)

Methods in org.graylog2.shared.inputs that return types with arguments of type MessageInput

Modifier and Type	Method	Description
IOState<MessageInput>	InputRegistry.getInputState(String inputId)
Set<IOState<MessageInput>>	InputRegistry.getInputStates()
Set<IOState<MessageInput>>	InputRegistry.getRunningInputs()
IOState<MessageInput>	InputRegistry.getRunningInputState(String inputStateId)
IOState<MessageInput>	InputLauncher.launch(MessageInput input)
IOState<MessageInput>	InputRegistry.stop(MessageInput input)
Stream<IOState<MessageInput>>	InputRegistry.stream()

Methods in org.graylog2.shared.inputs with parameters of type MessageInput

Modifier and Type	Method	Description
IOState<MessageInput>	InputLauncher.launch(MessageInput input)
boolean	InputLauncher.leaderStatusInhibitsLaunch(MessageInput input)
boolean	InputRegistry.remove(MessageInput input)
boolean	InputLauncher.shouldStartAutomatically(MessageInput input)
IOState<MessageInput>	InputRegistry.stop(MessageInput input)

Method parameters in org.graylog2.shared.inputs with type arguments of type MessageInput

Modifier and Type	Method	Description
boolean	InputRegistry.add(IOState<MessageInput> messageInputIOState)
protected void	InputLauncher.handleLaunchException(Throwable e, IOState<MessageInput> inputState)
boolean	InputRegistry.remove(IOState<MessageInput> inputState)

Constructor parameters in org.graylog2.shared.inputs with type arguments of type MessageInput

Modifier	Constructor	Description
	InputLauncher(IOState.Factory<MessageInput> inputStateFactory, InputBuffer inputBuffer, PersistedInputs persistedInputs, InputRegistry inputRegistry, com.codahale.metrics.MetricRegistry metricRegistry, Configuration configuration, LeaderElectionService leaderElectionService)
	MessageInputFactory(Map<String,MessageInput.Factory<? extends MessageInput>> inputFactories)