org.apache.ambari.server.agent.stomp

Class HeartbeatController

java.lang.Object

org.apache.ambari.server.agent.stomp.HeartbeatController

@Controller
 @SendToUser(value="/")
 @MessageMapping(value="/")
 @Import(value=GuiceBeansConfig.class)
public class HeartbeatController
extends Object

Constructor Summary

Constructors

Constructor and Description
HeartbeatController(com.google.inject.Injector injector)

Method Summary

Modifier and Type	Method and Description
HeartBeatResponse	heartbeat(String simpSessionId, HeartBeat message)
CompletableFuture<RegistrationResponse>	register(String simpSessionId, Register message)

Methods inherited from class java.lang.Object

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

Constructor Detail

HeartbeatController

public HeartbeatController(com.google.inject.Injector injector)

Method Detail

register

@MessageMapping(value="/register")
public CompletableFuture<RegistrationResponse> register(@Header
                                                                                           String simpSessionId,
                                                                                           Register message)
                                                                                    throws javax.ws.rs.WebApplicationException,
                                                                                           InvalidStateTransitionException,
                                                                                           org.apache.ambari.server.AmbariException

Throws:

javax.ws.rs.WebApplicationException

InvalidStateTransitionException

org.apache.ambari.server.AmbariException

heartbeat

@MessageMapping(value="/heartbeat")
public HeartBeatResponse heartbeat(@Header
                                                                       String simpSessionId,
                                                                       HeartBeat message)