org.apache.ambari.server.agent.stomp

Class AgentsRegistrationQueue

java.lang.Object

org.apache.ambari.server.agent.stomp.AgentsRegistrationQueue

public class AgentsRegistrationQueue
extends Object

Simultaneous processing a lot of registering/topology/metadata etc. requests from agents during agent registration can cause response timeout on agents' side. So it is allowed to process simultaneously requests only from limited number of agents with session ids from registrationQueue. Queue has limited capacity, session id can able be appeared in queue with agent connecting to server and releases with first heartbeat or disconnect from server.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	complete(String sessionId)
boolean	offer(String sessionId)

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentsRegistrationQueue

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

Method Detail

offer

public boolean offer(String sessionId)

complete

public void complete(String sessionId)