com.atlassian.bamboo.v2.build.queue
Class AgentQueueAccessorImpl

java.lang.Object
  com.atlassian.bamboo.v2.build.queue.AgentQueueAccessorImpl

All Implemented Interfaces:

AgentQueueAccessor

Direct Known Subclasses:

RemoteAgentQueueAccessorImpl

public class AgentQueueAccessorImpl
extends java.lang.Object
implements AgentQueueAccessor

An instance of this class is shared between multiple local agents

Field Summary

protected org.springframework.jms.core.JmsTemplate

jmsTemplate

Constructor Summary

AgentQueueAccessorImpl(org.springframework.jms.core.JmsTemplate jmsTemplate)

Method Summary

protected java.lang.String	getSelector(long id)
BuildContext	takeBuildContext(long id) Takes a BuildContext from the queue, blocking until one is available.

Methods inherited from class java.lang.Object

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

Field Detail

jmsTemplate

protected final org.springframework.jms.core.JmsTemplate jmsTemplate

Constructor Detail

AgentQueueAccessorImpl

public AgentQueueAccessorImpl(org.springframework.jms.core.JmsTemplate jmsTemplate)

Method Detail

takeBuildContext

@Nullable
public BuildContext takeBuildContext(long id)
                              throws java.lang.InterruptedException

Description copied from interface: AgentQueueAccessor

Takes a BuildContext from the queue, blocking until one is available. The lock on the build is not released. The caller should call BuildExecutionManager#finishProcess to release this lock when ready.

Specified by:

takeBuildContext in interface AgentQueueAccessor

Returns:

The BuildContext, null in case of timeout on retrieval.

Throws:

java.lang.InterruptedException - if the calling Thread is interrupted.

getSelector

protected java.lang.String getSelector(long id)