org.opennms.netmgt.telemetry.distributed.common

Class MapBasedQueueDef

java.lang.Object

org.opennms.netmgt.telemetry.distributed.common.MapBasedQueueDef

All Implemented Interfaces:

QueueDefinition

Direct Known Subclasses:

MapBasedParserDef

public class MapBasedQueueDef
extends Object
implements QueueDefinition

Constructor Summary

Constructors

Constructor and Description
MapBasedQueueDef(PropertyTree definition)

Method Summary

Modifier and Type	Method and Description
Optional<Integer>	getBatchIntervalMs() Messages are aggregated in batches before being dispatched.
Optional<Integer>	getBatchSize() Messages are aggregated in batches before being dispatched.
String	getName() The name of the protocol.
Optional<Integer>	getNumThreads() Number of threads used for consuming/dispatching messages.
Optional<Integer>	getQueueSize() Maximum number of messages to keep in memory while waiting to be dispatched.
Optional<Boolean>	getUseRoutingKey() Whether or not the routing key should be used when forwarding messages to the broker.

Methods inherited from class java.lang.Object

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

Constructor Detail

MapBasedQueueDef

public MapBasedQueueDef(PropertyTree definition)

Method Detail

getName

public String getName()

Description copied from interface: QueueDefinition

The name of the protocol. This is used as a suffix for any associated queues that are created and must be the same on both OpenNMS and Minion.

Specified by:

getName in interface QueueDefinition

Returns:

the protocol name

getNumThreads

public Optional<Integer> getNumThreads()

Description copied from interface: QueueDefinition

Number of threads used for consuming/dispatching messages.

Specified by:

getNumThreads in interface QueueDefinition

Returns:

the number of threads

getBatchSize

public Optional<Integer> getBatchSize()

Description copied from interface: QueueDefinition

Messages are aggregated in batches before being dispatched. When the batch reaches this size, it will be dispatched.

Specified by:

getBatchSize in interface QueueDefinition

Returns:

the batch size

getBatchIntervalMs

public Optional<Integer> getBatchIntervalMs()

Description copied from interface: QueueDefinition

Messages are aggregated in batches before being dispatched. When the batch has been created for longer than this interval (ms) it will be dispatched, regardless of the current size.

Specified by:

getBatchIntervalMs in interface QueueDefinition

Returns:

the batch interval

getQueueSize

public Optional<Integer> getQueueSize()

Description copied from interface: QueueDefinition

Maximum number of messages to keep in memory while waiting to be dispatched.

Specified by:

getQueueSize in interface QueueDefinition

Returns:

the queue size

getUseRoutingKey

public Optional<Boolean> getUseRoutingKey()

Description copied from interface: QueueDefinition

Whether or not the routing key should be used when forwarding messages to the broker.

Specified by:

getUseRoutingKey in interface QueueDefinition

Returns:

whether or not to use the routing key