com.continuent.tungsten.common.patterns.notification.adaptor
Class MonitorNotificationUDPAdaptor

java.lang.Object
  com.continuent.tungsten.common.patterns.notification.adaptor.MonitorNotificationUDPAdaptor

All Implemented Interfaces:

ResourceNotifier, java.lang.Runnable

public class MonitorNotificationUDPAdaptor
extends java.lang.Object
implements ResourceNotifier

This class represents a means to receive monitoring information about datasources, in the form of TungstenProperties instances, via UDP.

Version:

1.0

Author:

Ed Archibald

Constructor Summary

MonitorNotificationUDPAdaptor(java.lang.String clusterName)

Method Summary

void	addListener(ResourceNotificationListener listener)
java.util.Map<java.lang.String,NotificationGroupMember>	getNotificationGroupMembers()
static void	main(java.lang.String[] argv)
void	notifyListeners(ClusterResourceNotification notification)
void	prepare()
void	run() Collect datagrams, each of which represents a specific datasource, status, etc.
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

MonitorNotificationUDPAdaptor

public MonitorNotificationUDPAdaptor(java.lang.String clusterName)
                              throws NotificationAdaptorException

Parameters:

clusterName -

Throws:

NotificationAdaptorException

Method Detail

main

public static void main(java.lang.String[] argv)

Parameters:

argv -

addListener

public void addListener(ResourceNotificationListener listener)

Specified by:

addListener in interface ResourceNotifier

Parameters:

listener -

notifyListeners

public void notifyListeners(ClusterResourceNotification notification)
                     throws ResourceNotificationException

Specified by:

notifyListeners in interface ResourceNotifier

Parameters:

notification -

Throws:

ResourceNotificationException

run

public void run()

Collect datagrams, each of which represents a specific datasource, status, etc. and communicate this to the router manager.

Specified by:

run in interface java.lang.Runnable

shutdown

public void shutdown()

getNotificationGroupMembers

public java.util.Map<java.lang.String,NotificationGroupMember> getNotificationGroupMembers()

Specified by:

getNotificationGroupMembers in interface ResourceNotifier

prepare

public void prepare()
             throws java.lang.Exception

Specified by:

prepare in interface ResourceNotifier

Throws:

java.lang.Exception