org.apache.ambari.server.events.publishers

Class ServiceUpdateEventPublisher

java.lang.Object

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

org.apache.ambari.server.events.publishers.ServiceUpdateEventPublisher

public class ServiceUpdateEventPublisher
extends BufferedUpdateEventPublisher<ServiceUpdateEvent>

Constructor Summary

Constructors

Constructor and Description
ServiceUpdateEventPublisher(STOMPUpdatePublisher stompUpdatePublisher)

Method Summary

Modifier and Type	Method and Description
STOMPEvent.Type	getType()
void	mergeBufferAndPost(List<ServiceUpdateEvent> events, com.google.common.eventbus.EventBus 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

ServiceUpdateEventPublisher

@Inject
public ServiceUpdateEventPublisher(STOMPUpdatePublisher stompUpdatePublisher)

Method Detail

getType

public STOMPEvent.Type getType()

Specified by:

getType in class BufferedUpdateEventPublisher<ServiceUpdateEvent>

mergeBufferAndPost

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

Specified by:

mergeBufferAndPost in class BufferedUpdateEventPublisher<ServiceUpdateEvent>