QueueDefinition (OpenNMS 2022.1.1 API)

All Known Implementing Classes:

MapBasedParserDef, MapBasedQueueDef, QueueConfig
```
public interface QueueDefinition
```
Telemetry protocol configuration.

Method Summary

All Methods Instance Methods Abstract Methods
Modifier and Type	Method	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.

- Method Detail
  - getName
```
String getName()
```
    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.
    
    Returns:
    
    the protocol name
  - getNumThreads
```
Optional<Integer> getNumThreads()
```
    Number of threads used for consuming/dispatching messages.
    
    Returns:
    
    the number of threads
  - getBatchSize
```
Optional<Integer> getBatchSize()
```
    Messages are aggregated in batches before being dispatched. When the batch reaches this size, it will be dispatched.
    
    Returns:
    
    the batch size
  - getBatchIntervalMs
```
Optional<Integer> getBatchIntervalMs()
```
    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.
    
    Returns:
    
    the batch interval
  - getQueueSize
```
Optional<Integer> getQueueSize()
```
    Maximum number of messages to keep in memory while waiting to be dispatched.
    
    Returns:
    
    the queue size
  - getUseRoutingKey
```
Optional<Boolean> getUseRoutingKey()
```
    Whether or not the routing key should be used when forwarding messages to the broker.
    
    Returns:
    
    whether or not to use the routing key