org.apache.ambari.server.events.publishers

Class BufferedUpdateEventPublisher<T>

java.lang.Object

org.apache.ambari.server.events.publishers.BufferedUpdateEventPublisher<T>

Direct Known Subclasses:

HostComponentUpdateEventPublisher, RequestUpdateEventPublisher, ServiceUpdateEventPublisher

public abstract class BufferedUpdateEventPublisher<T>
extends Object

Constructor Summary

Constructors

Constructor and Description
BufferedUpdateEventPublisher(STOMPUpdatePublisher stompUpdatePublisher)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
protected org.apache.ambari.server.events.publishers.BufferedUpdateEventPublisher.MergingRunnable	getScheduledPublisher(com.google.common.eventbus.EventBus m_eventBus)
abstract STOMPEvent.Type	getType()
int	hashCode()
abstract void	mergeBufferAndPost(List<T> events, com.google.common.eventbus.EventBus m_eventBus)
void	publish(T event, com.google.common.eventbus.EventBus m_eventBus)
protected List<T>	retrieveBuffer()

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferedUpdateEventPublisher

public BufferedUpdateEventPublisher(STOMPUpdatePublisher stompUpdatePublisher)

Method Detail

getType

public abstract STOMPEvent.Type getType()

publish

public void publish(T event,
                    com.google.common.eventbus.EventBus m_eventBus)

getScheduledPublisher

protected org.apache.ambari.server.events.publishers.BufferedUpdateEventPublisher.MergingRunnable getScheduledPublisher(com.google.common.eventbus.EventBus m_eventBus)

retrieveBuffer

protected List<T> retrieveBuffer()

mergeBufferAndPost

public abstract void mergeBufferAndPost(List<T> events,
                                        com.google.common.eventbus.EventBus m_eventBus)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object