org.graylog2.inputs.transports

Class RadioAmqpTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.ThrottleableTransport

org.graylog2.inputs.transports.AmqpTransport

org.graylog2.inputs.transports.RadioAmqpTransport

All Implemented Interfaces:

Transport

public class RadioAmqpTransport
extends AmqpTransport

Nested Class Summary

Nested Classes

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

Field Summary

Fields inherited from class org.graylog2.inputs.transports.AmqpTransport

CK_EXCHANGE, CK_HEARTBEAT_TIMEOUT, CK_HOSTNAME, CK_PARALLEL_QUEUES, CK_PASSWORD, CK_PORT, CK_PREFETCH, CK_QUEUE, CK_REQUEUE_INVALID_MESSAGES, CK_ROUTING_KEY, CK_TLS, CK_USERNAME, CK_VHOST

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

CK_THROTTLING_ALLOWED

Constructor Summary

Constructors

Constructor and Description
RadioAmqpTransport(Configuration configuration, com.google.common.eventbus.EventBus eventBus, LocalMetricRegistry localRegistry, ScheduledExecutorService scheduler)

Method Summary

Methods inherited from class org.graylog2.inputs.transports.AmqpTransport

doLaunch, doStop, getMetricSet, lifecycleChanged, setMessageAggregator

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

RadioAmqpTransport

public RadioAmqpTransport(Configuration configuration,
                  com.google.common.eventbus.EventBus eventBus,
                  LocalMetricRegistry localRegistry,
                  @Named(value="daemonScheduler")
                  ScheduledExecutorService scheduler)