org.graylog2.inputs.transports

Class LocalMetricsTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.ThrottleableTransport

org.graylog2.inputs.transports.LocalMetricsTransport

All Implemented Interfaces:

Transport

public class LocalMetricsTransport
extends ThrottleableTransport

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	LocalMetricsTransport.Config
static interface	LocalMetricsTransport.Factory

Field Summary

Fields inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport

CK_THROTTLING_ALLOWED

Constructor Summary

Constructors

Constructor and Description
LocalMetricsTransport(Configuration configuration, com.fasterxml.jackson.databind.ObjectMapper mapper, com.codahale.metrics.MetricRegistry metricRegistry, com.google.common.eventbus.EventBus eventBus, ScheduledExecutorService scheduler)

Method Summary

Methods

Modifier and Type	Method and Description
void	doLaunch(MessageInput input)
void	doStop()
com.codahale.metrics.MetricSet	getMetricSet()
void	setMessageAggregator(CodecAggregator aggregator)

Methods inherited from class org.graylog2.plugin.inputs.transports.ThrottleableTransport

blockUntilUnthrottled, determineIfThrottled, isThrottled, launch, stop, updateThrottleState

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalMetricsTransport

public LocalMetricsTransport(Configuration configuration,
                     com.fasterxml.jackson.databind.ObjectMapper mapper,
                     com.codahale.metrics.MetricRegistry metricRegistry,
                     com.google.common.eventbus.EventBus eventBus,
                     @Named(value="daemonScheduler")
                     ScheduledExecutorService scheduler)

Method Detail

setMessageAggregator

public void setMessageAggregator(CodecAggregator aggregator)

doLaunch

public void doLaunch(MessageInput input)
              throws MisfireException

Specified by:

doLaunch in class ThrottleableTransport

Throws:

MisfireException

doStop

public void doStop()

Specified by:

doStop in class ThrottleableTransport

getMetricSet

public com.codahale.metrics.MetricSet getMetricSet()