org.apache.ambari.server.events

Class MessageEmitter

java.lang.Object

org.apache.ambari.server.events.MessageEmitter

Direct Known Subclasses:

DefaultMessageEmitter

public abstract class MessageEmitter
extends Object

Is used to define a strategy for emitting message to subscribers.

Field Summary

Fields

Modifier and Type	Field and Description
protected AgentSessionManager	agentSessionManager
protected ScheduledExecutorCompletionService<org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper>	emitCompletionService
protected ScheduledExecutorService	emitExecutor
protected static AtomicLong	MESSAGE_ID
protected ConcurrentHashMap<Long,BlockingQueue<org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper>>	messagesToEmit
protected ExecutorService	monitorExecutor
int	retryCount
protected ExecutorService	retryExecutor
int	retryInterval
protected org.springframework.messaging.simp.SimpMessagingTemplate	simpMessagingTemplate
protected ConcurrentHashMap<Long,org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper>	unconfirmedMessages

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
protected org.springframework.messaging.MessageHeaders	createHeaders(String sessionId) Creates STOMP message header.
protected org.springframework.messaging.MessageHeaders	createHeaders(String sessionId, Long messageId) Creates STOMP message header.
protected void	emitExecutionCommandToHost(org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper eventWrapper) Emit execution command to specified host only.
void	emitMessageRetriable(ExecutionCommandEvent event)
protected void	emitMessageToAll(STOMPEvent event) Emits message to all subscribers.
protected void	emitMessageToHost(STOMPHostEvent event) Emit message to specified host only.
protected abstract String	getDestination(STOMPEvent stompEvent)
void	onHostRegister(HostRegisteredEvent hostRegisteredEvent)
void	processReceiveReport(Long hostId, AckReport ackReport)

Methods inherited from class java.lang.Object

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

Field Detail

MESSAGE_ID

protected static final AtomicLong MESSAGE_ID

retryCount

public final int retryCount

retryInterval

public final int retryInterval

agentSessionManager

protected final AgentSessionManager agentSessionManager

simpMessagingTemplate

protected final org.springframework.messaging.simp.SimpMessagingTemplate simpMessagingTemplate

emitExecutor

protected final ScheduledExecutorService emitExecutor

monitorExecutor

protected final ExecutorService monitorExecutor

retryExecutor

protected final ExecutorService retryExecutor

emitCompletionService

protected final ScheduledExecutorCompletionService<org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper> emitCompletionService

unconfirmedMessages

protected ConcurrentHashMap<Long,org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper> unconfirmedMessages

messagesToEmit

protected ConcurrentHashMap<Long,BlockingQueue<org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper>> messagesToEmit

Constructor Detail

MessageEmitter

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

Method Detail

emitMessageRetriable

public void emitMessageRetriable(ExecutionCommandEvent event)

processReceiveReport

public void processReceiveReport(Long hostId,
                                 AckReport ackReport)

getDestination

protected abstract String getDestination(STOMPEvent stompEvent)

createHeaders

protected org.springframework.messaging.MessageHeaders createHeaders(String sessionId)

Creates STOMP message header.

Parameters:

sessionId -

Returns:

message header.

createHeaders

protected org.springframework.messaging.MessageHeaders createHeaders(String sessionId,
                                                                     Long messageId)

Creates STOMP message header.

Parameters:

sessionId -

Returns:

message header.

emitMessageToAll

protected void emitMessageToAll(STOMPEvent event)

Emits message to all subscribers.

Parameters:

event - message should to be emitted.

emitMessageToHost

protected void emitMessageToHost(STOMPHostEvent event)
                          throws HostNotRegisteredException

Emit message to specified host only.

Parameters:

event - message should to be emitted.

Throws:

HostNotRegisteredException - in case host is not registered.

emitExecutionCommandToHost

protected void emitExecutionCommandToHost(org.apache.ambari.server.events.MessageEmitter.EmitTaskWrapper eventWrapper)
                                   throws HostNotRegisteredException

Emit execution command to specified host only.

Parameters:

eventWrapper - message should to be emitted.

Throws:

HostNotRegisteredException - in case host is not registered.

onHostRegister

public void onHostRegister(HostRegisteredEvent hostRegisteredEvent)