Package org.opennms.features.events.sink.dispatcher

Class EventdConfigBean

java.lang.Object

org.opennms.features.events.sink.dispatcher.EventdConfigBean

All Implemented Interfaces:

EventdConfig

public class EventdConfigBean
extends java.lang.Object
implements EventdConfig

This is used to initialize sink module on Minion. Doesn't support listening events on TCP/UDP.

Constructor Summary

Constructors

Constructor	Description
EventdConfigBean()

Method Summary

Modifier and Type	Method	Description
int	getBatchIntervalMs()	Messages are aggregated in batches before being dispatched.
int	getBatchSize()	Messages are aggregated in batches before being dispatched.
java.lang.String	getGetNextEventID()	getGetNextEventID
int	getNumThreads()	Number of threads used for consuming/dispatching messages.
int	getQueueLength()	getQueueLength
int	getQueueSize()	Maximum number of messages to keep in memory while waiting to be dispatched.
int	getReceivers()	getReceivers
int	getSocketSoTimeoutPeriod()	getSocketSoTimeoutPeriod
java.lang.String	getSocketSoTimeoutRequired()	getSocketsSoTimeoutRequired
java.lang.String	getTCPIpAddress()	getTCPIpAddress
int	getTCPPort()	getTCPPort
java.lang.String	getUDPIpAddress()	getUDPIpAddress
int	getUDPPort()	getUDPPort
boolean	hasSocketSoTimeoutPeriod()	hasSocketSoTimeoutPeriod
void	setBatchIntervalMs(int batchIntervalMs)
void	setBatchSize(int batchSize)
void	setNumThreads(int numThreads)
void	setQueueSize(int queueSize)

Methods inherited from class java.lang.Object

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

Constructor Detail

EventdConfigBean

public EventdConfigBean()

Method Detail

getTCPIpAddress

public java.lang.String getTCPIpAddress()

Description copied from interface: EventdConfig

getTCPIpAddress

Specified by:

getTCPIpAddress in interface EventdConfig

Returns:

a String

getTCPPort

public int getTCPPort()

Description copied from interface: EventdConfig

getTCPPort

Specified by:

getTCPPort in interface EventdConfig

Returns:

an int

getUDPIpAddress

public java.lang.String getUDPIpAddress()

Description copied from interface: EventdConfig

getUDPIpAddress

Specified by:

getUDPIpAddress in interface EventdConfig

Returns:

a String

getUDPPort

public int getUDPPort()

Description copied from interface: EventdConfig

getUDPPort

Specified by:

getUDPPort in interface EventdConfig

Returns:

an int

getReceivers

public int getReceivers()

Description copied from interface: EventdConfig

getReceivers

Specified by:

getReceivers in interface EventdConfig

Returns:

an int

getQueueLength

public int getQueueLength()

Description copied from interface: EventdConfig

getQueueLength

Specified by:

getQueueLength in interface EventdConfig

Returns:

an int

getSocketSoTimeoutRequired

public java.lang.String getSocketSoTimeoutRequired()

Description copied from interface: EventdConfig

getSocketsSoTimeoutRequired

Specified by:

getSocketSoTimeoutRequired in interface EventdConfig

Returns:

a String

getSocketSoTimeoutPeriod

public int getSocketSoTimeoutPeriod()

Description copied from interface: EventdConfig

getSocketSoTimeoutPeriod

Specified by:

getSocketSoTimeoutPeriod in interface EventdConfig

Returns:

an int

hasSocketSoTimeoutPeriod

public boolean hasSocketSoTimeoutPeriod()

Description copied from interface: EventdConfig

hasSocketSoTimeoutPeriod

Specified by:

hasSocketSoTimeoutPeriod in interface EventdConfig

Returns:

a boolean

getGetNextEventID

public java.lang.String getGetNextEventID()

Description copied from interface: EventdConfig

getGetNextEventID

Specified by:

getGetNextEventID in interface EventdConfig

Returns:

a String

getNumThreads

public int getNumThreads()

Description copied from interface: EventdConfig

Number of threads used for consuming/dispatching messages.

Specified by:

getNumThreads in interface EventdConfig

Returns:

number of threads

setNumThreads

public void setNumThreads(int numThreads)

getQueueSize

public int getQueueSize()

Description copied from interface: EventdConfig

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

Specified by:

getQueueSize in interface EventdConfig

Returns:

queue size

setQueueSize

public void setQueueSize(int queueSize)

getBatchSize

public int getBatchSize()

Description copied from interface: EventdConfig

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

Specified by:

getBatchSize in interface EventdConfig

Returns:

batch size

setBatchSize

public void setBatchSize(int batchSize)

getBatchIntervalMs

public int getBatchIntervalMs()

Description copied from interface: EventdConfig

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

Specified by:

getBatchIntervalMs in interface EventdConfig

Returns:

interval in ms

setBatchIntervalMs

public void setBatchIntervalMs(int batchIntervalMs)