Package org.graylog2.inputs.transports

Class AmqpTransport

java.lang.Object

org.graylog2.plugin.inputs.transports.ThrottleableTransport

org.graylog2.plugin.inputs.transports.ThrottleableTransport2

org.graylog2.inputs.transports.AmqpTransport

All Implemented Interfaces:

Transport

public class AmqpTransport
extends ThrottleableTransport2

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CK_CONNECTION_RECOVERY_INTERVAL
static final String	CK_EXCHANGE
static final String	CK_EXCHANGE_BIND
static final String	CK_HEARTBEAT_TIMEOUT
static final String	CK_HOSTNAME
static final String	CK_PARALLEL_QUEUES
static final String	CK_PASSWORD
static final String	CK_PORT
static final String	CK_PREFETCH
static final String	CK_QUEUE
static final String	CK_REQUEUE_INVALID_MESSAGES
static final String	CK_ROUTING_KEY
static final String	CK_TLS
static final String	CK_USERNAME
static final String	CK_VHOST

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

CK_THROTTLING_ALLOWED, throttlingAllowed

Constructor Summary

Constructors

Constructor	Description
AmqpTransport(Configuration configuration, com.google.common.eventbus.EventBus eventBus, LocalMetricRegistry localRegistry, EncryptedValueService encryptedValueService, ScheduledExecutorService scheduler, ScheduledExecutorService amqpScheduler)

Method Summary

Modifier and Type	Method	Description
void	doLaunch(MessageInput input, InputFailureRecorder inputFailureRecorder)
void	doStop()	Performs the same purpose as ThrottleableTransport.stop() but guarantees that the superclass' actions are performed.
com.codahale.metrics.MetricSet	getMetricSet()
void	lifecycleChanged(Lifecycle lifecycle)
void	setMessageAggregator(CodecAggregator aggregator)

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

doLaunch, launch

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

blockUntilUnthrottled, blockUntilUnthrottled, determineIfThrottled, handleChangedThrottledState, isThrottled, launch, stop, updateThrottleState

Methods inherited from class java.lang.Object

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

Field Details

CK_HOSTNAME

public static final String CK_HOSTNAME

See Also:

• Constant Field Values

CK_PORT

public static final String CK_PORT

See Also:

• Constant Field Values

CK_VHOST

public static final String CK_VHOST

See Also:

• Constant Field Values

CK_USERNAME

public static final String CK_USERNAME

See Also:

• Constant Field Values

CK_PASSWORD

public static final String CK_PASSWORD

See Also:

• Constant Field Values

CK_PREFETCH

public static final String CK_PREFETCH

See Also:

• Constant Field Values

CK_EXCHANGE

public static final String CK_EXCHANGE

See Also:

• Constant Field Values

CK_EXCHANGE_BIND

public static final String CK_EXCHANGE_BIND

See Also:

• Constant Field Values

CK_QUEUE

public static final String CK_QUEUE

See Also:

• Constant Field Values

CK_ROUTING_KEY

public static final String CK_ROUTING_KEY

See Also:

• Constant Field Values

CK_PARALLEL_QUEUES

public static final String CK_PARALLEL_QUEUES

See Also:

• Constant Field Values

CK_TLS

public static final String CK_TLS

See Also:

• Constant Field Values

CK_REQUEUE_INVALID_MESSAGES

public static final String CK_REQUEUE_INVALID_MESSAGES

See Also:

• Constant Field Values

CK_HEARTBEAT_TIMEOUT

public static final String CK_HEARTBEAT_TIMEOUT

See Also:

• Constant Field Values

CK_CONNECTION_RECOVERY_INTERVAL

public static final String CK_CONNECTION_RECOVERY_INTERVAL

See Also:

• Constant Field Values

Constructor Details

AmqpTransport

public AmqpTransport(Configuration configuration,
 com.google.common.eventbus.EventBus eventBus,
 LocalMetricRegistry localRegistry,
 EncryptedValueService encryptedValueService,
 @Named("daemonScheduler")
 ScheduledExecutorService scheduler,
 @Named("AMQP Executor")
 ScheduledExecutorService amqpScheduler)

Method Details

lifecycleChanged

public void lifecycleChanged(Lifecycle lifecycle)

setMessageAggregator

public void setMessageAggregator(CodecAggregator aggregator)

doLaunch

public void doLaunch(MessageInput input,
 InputFailureRecorder inputFailureRecorder)
              throws MisfireException

Specified by:

doLaunch in class ThrottleableTransport2

Throws:

MisfireException

doStop

public void doStop()

Description copied from class: ThrottleableTransport

Performs the same purpose as ThrottleableTransport.stop() but guarantees that the superclass' actions are performed.

Specified by:

doStop in class ThrottleableTransport

getMetricSet

public com.codahale.metrics.MetricSet getMetricSet()