org.apache.ambari.server.events.publishers

Class RequestUpdateEventPublisher

java.lang.Object

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

org.apache.ambari.server.events.publishers.RequestUpdateEventPublisher

public class RequestUpdateEventPublisher
extends BufferedUpdateEventPublisher<RequestUpdateEvent>

Constructor Summary

Constructors

Constructor and Description
RequestUpdateEventPublisher(STOMPUpdatePublisher stompUpdatePublisher)

Method Summary

Modifier and Type	Method and Description
STOMPEvent.Type	getType()
void	mergeBufferAndPost(List<RequestUpdateEvent> events, com.google.common.eventbus.EventBus m_eventBus)

Methods inherited from class org.apache.ambari.server.events.publishers.BufferedUpdateEventPublisher

equals, getScheduledPublisher, hashCode, publish, retrieveBuffer

Methods inherited from class java.lang.Object

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

Constructor Detail

RequestUpdateEventPublisher

@Inject
public RequestUpdateEventPublisher(STOMPUpdatePublisher stompUpdatePublisher)

Method Detail

getType

public STOMPEvent.Type getType()

Specified by:

getType in class BufferedUpdateEventPublisher<RequestUpdateEvent>

mergeBufferAndPost

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

Specified by:

mergeBufferAndPost in class BufferedUpdateEventPublisher<RequestUpdateEvent>