org.opennms.plugins.dbnotifier

Class DbNotificationClientQueueImpl

java.lang.Object

org.opennms.plugins.dbnotifier.DbNotificationClientQueueImpl

All Implemented Interfaces:

DbNotificationClient, NotificationClient

public class DbNotificationClientQueueImpl
extends Object
implements DbNotificationClient

This is a notification client which receives the notification and adds it to a queue for processing

Author:

admin

Constructor Summary

Constructors

Constructor and Description
DbNotificationClientQueueImpl()

Method Summary

Modifier and Type	Method and Description
void	destroy()
DatabaseChangeNotifier	getDatabaseChangeNotifier()
Integer	getMaxQueueLength()
void	init()
void	sendDbNotification(DbNotification dbNotification)
void	setChannelHandlingClients(Map<String,NotificationClient> channelHandlingClients)
void	setDatabaseChangeNotifier(DatabaseChangeNotifier databaseChangeNotifier)
void	setMaxQueueLength(Integer maxQueueLength)

Methods inherited from class java.lang.Object

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

Constructor Detail

DbNotificationClientQueueImpl

public DbNotificationClientQueueImpl()

Method Detail

setChannelHandlingClients

public void setChannelHandlingClients(Map<String,NotificationClient> channelHandlingClients)

Parameters:

channelHandlingClients - the channelHandlingClients to set

setDatabaseChangeNotifier

public void setDatabaseChangeNotifier(DatabaseChangeNotifier databaseChangeNotifier)

Specified by:

setDatabaseChangeNotifier in interface DbNotificationClient

Parameters:

databaseChangeNotifier -

getDatabaseChangeNotifier

public DatabaseChangeNotifier getDatabaseChangeNotifier()

Specified by:

getDatabaseChangeNotifier in interface DbNotificationClient

Returns:

the databaseChangeNotifier

getMaxQueueLength

public Integer getMaxQueueLength()

setMaxQueueLength

public void setMaxQueueLength(Integer maxQueueLength)

init

public void init()

Specified by:

init in interface NotificationClient

destroy

public void destroy()

Specified by:

destroy in interface NotificationClient

sendDbNotification

public void sendDbNotification(DbNotification dbNotification)

Specified by:

sendDbNotification in interface NotificationClient