org.apache.ambari.server.events

Class DefaultMessageEmitter

java.lang.Object

org.apache.ambari.server.events.MessageEmitter

org.apache.ambari.server.events.DefaultMessageEmitter

public class DefaultMessageEmitter
extends MessageEmitter

Field Summary

Fields

Modifier and Type	Field and Description
static Set<STOMPEvent.Type>	DEFAULT_AGENT_EVENT_TYPES
static Set<STOMPEvent.Type>	DEFAULT_API_EVENT_TYPES

Fields inherited from class org.apache.ambari.server.events.MessageEmitter

agentSessionManager, emitCompletionService, emitExecutor, MESSAGE_ID, messagesToEmit, monitorExecutor, retryCount, retryExecutor, retryInterval, simpMessagingTemplate, unconfirmedMessages

Constructor Summary

Constructors

Constructor and Description
DefaultMessageEmitter(AgentSessionManager agentSessionManager, org.springframework.messaging.simp.SimpMessagingTemplate simpMessagingTemplate, AmbariEventPublisher ambariEventPublisher, int retryCount, int retryInterval)

Method Summary

Modifier and Type	Method and Description
void	emitMessage(STOMPEvent event) Determines destinations and emits message.
protected String	getDestination(STOMPEvent stompEvent)

Methods inherited from class org.apache.ambari.server.events.MessageEmitter

createHeaders, createHeaders, emitExecutionCommandToHost, emitMessageRetriable, emitMessageToAll, emitMessageToHost, onHostRegister, processReceiveReport

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_AGENT_EVENT_TYPES

public static final Set<STOMPEvent.Type> DEFAULT_AGENT_EVENT_TYPES

DEFAULT_API_EVENT_TYPES

public static final Set<STOMPEvent.Type> DEFAULT_API_EVENT_TYPES

Constructor Detail

DefaultMessageEmitter

public DefaultMessageEmitter(AgentSessionManager agentSessionManager,
                             org.springframework.messaging.simp.SimpMessagingTemplate simpMessagingTemplate,
                             AmbariEventPublisher ambariEventPublisher,
                             int retryCount,
                             int retryInterval)

Method Detail

emitMessage

public void emitMessage(STOMPEvent event)
                 throws org.apache.ambari.server.AmbariException

Description copied from class: MessageEmitter

Determines destinations and emits message.

Parameters:

event - message should to be emitted.

Throws:

org.apache.ambari.server.AmbariException

getDestination

protected String getDestination(STOMPEvent stompEvent)

Specified by:

getDestination in class MessageEmitter