com.continuent.tungsten.common.patterns.notification
Class QueueingNotificationListener

java.lang.Object
  com.continuent.tungsten.common.patterns.notification.QueueingNotificationListener

All Implemented Interfaces:

ResourceNotificationListener, java.lang.Runnable

public class QueueingNotificationListener
extends java.lang.Object
implements ResourceNotificationListener, java.lang.Runnable

Constructor Summary

QueueingNotificationListener()

Method Summary

java.util.Map<java.lang.String,java.lang.Object>	getNotification() Gets the next notification in the queue
void	init(java.lang.String type)
void	notify(ClusterResourceNotification notification)
void	putNotification(java.util.Map<java.lang.String,java.lang.Object> notification) Put a notification on the appropriate queue
void	run()
void	start()

Methods inherited from class java.lang.Object

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

Constructor Detail

QueueingNotificationListener

public QueueingNotificationListener()

Method Detail

init

public void init(java.lang.String type)

notify

public void notify(ClusterResourceNotification notification)
            throws ResourceNotificationException

Specified by:

notify in interface ResourceNotificationListener

Throws:

ResourceNotificationException

putNotification

public void putNotification(java.util.Map<java.lang.String,java.lang.Object> notification)
                     throws ResourceNotificationException

Put a notification on the appropriate queue

Throws:

ResourceNotificationException

getNotification

public java.util.Map<java.lang.String,java.lang.Object> getNotification()
                                                                 throws ResourceNotificationException

Gets the next notification in the queue

Throws:

ResourceNotificationException

run

public void run()

Specified by:

run in interface java.lang.Runnable

start

public void start()

Specified by:

start in interface ResourceNotificationListener