Package jetbrains.buildServer.serverSide.impl.agent

Class MultiNodeAgentCommandsExecutor

java.lang.Object

jetbrains.buildServer.serverSide.impl.agent.MultiNodeAgentCommandsExecutor

All Implemented Interfaces:

AgentCommandsExecutor

public class MultiNodeAgentCommandsExecutor
extends Object
implements AgentCommandsExecutor

Field Summary

Fields

Modifier and Type	Field	Description
static String	AGENT_COMMAND_PREFIX
static String	AGENT_ID_PREFIX

Constructor Summary

Constructors

Constructor	Description
MultiNodeAgentCommandsExecutor(ExecutorService executorService, MultiNodeTasks multiNodeTasks, MultiNodeAgentCommandsListener agentCommandsListener, Supplier<jetbrains.buildServer.serverSide.impl.agent.PollingRemoteAgentConnection.AgentData> agentDetailsSupplier, Supplier<Long> timeSupplier)

Method Summary

Modifier and Type	Method	Description
static MultiNodeTasks.TaskData	createMultinodeTask(PollingRemoteAgentConnection.Command command, String identity)
void	dispose()
void	done(String result, int commandId)
String	executeCommandAndWait(PollingRemoteAgentConnection.Command command)	Synchronously execute command
void	failed(Error error, int commandId)
PollingRemoteAgentConnection.Command	getNextCommand()
boolean	hasActiveSubscriptions(long subscriptionTimeout)
void	inProgress(int commandId)
void	notifySubscribersOnNewCommand(MultiNodeTasks.SubmittedTask task)
void	scheduleCommand(PollingRemoteAgentConnection.Command command, jetbrains.buildServer.serverSide.impl.agent.PollingRemoteAgentConnection.Callback callback)
com.google.common.util.concurrent.ListenableFuture<PollingRemoteAgentConnection.Command>	subscribeToNextCommand()	Allows to subscribe to the next command for the agent.
void	unsubscribeFromNextCommand(com.google.common.util.concurrent.ListenableFuture<PollingRemoteAgentConnection.Command> future)	Remove listener returned by subscribeToNextCommand() method.

Methods inherited from class java.lang.Object

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

Field Detail

AGENT_COMMAND_PREFIX

public static final String AGENT_COMMAND_PREFIX

See Also:

Constant Field Values

AGENT_ID_PREFIX

public static final String AGENT_ID_PREFIX

See Also:

Constant Field Values

Constructor Detail

MultiNodeAgentCommandsExecutor

public MultiNodeAgentCommandsExecutor(@NotNull
                                      ExecutorService executorService,
                                      @NotNull
                                      MultiNodeTasks multiNodeTasks,
                                      @NotNull
                                      MultiNodeAgentCommandsListener agentCommandsListener,
                                      @NotNull
                                      Supplier<jetbrains.buildServer.serverSide.impl.agent.PollingRemoteAgentConnection.AgentData> agentDetailsSupplier,
                                      @NotNull
                                      Supplier<Long> timeSupplier)

Method Detail

notifySubscribersOnNewCommand

public void notifySubscribersOnNewCommand(@NotNull
                                          MultiNodeTasks.SubmittedTask task)

scheduleCommand

public void scheduleCommand(@NotNull
                            PollingRemoteAgentConnection.Command command,
                            @NotNull
                            jetbrains.buildServer.serverSide.impl.agent.PollingRemoteAgentConnection.Callback callback)
                     throws RejectedExecutionException

Specified by:

scheduleCommand in interface AgentCommandsExecutor

Throws:

RejectedExecutionException

executeCommandAndWait

public String executeCommandAndWait(@NotNull
                                    PollingRemoteAgentConnection.Command command)
                             throws AgentCommandExecutionException,
                                    AgentTimeoutException,
                                    InterruptedException

Synchronously execute command

Specified by:

executeCommandAndWait in interface AgentCommandsExecutor

Throws:

AgentCommandExecutionException

AgentTimeoutException

InterruptedException

createMultinodeTask

@NotNull
public static MultiNodeTasks.TaskData createMultinodeTask(@NotNull
                                                          PollingRemoteAgentConnection.Command command,
                                                          @NotNull
                                                          String identity)

subscribeToNextCommand

@NotNull
public com.google.common.util.concurrent.ListenableFuture<PollingRemoteAgentConnection.Command> subscribeToNextCommand()

Allows to subscribe to the next command for the agent. Returned future will be released when command is available. In this case Future.get() will return this command.

Specified by:

subscribeToNextCommand in interface AgentCommandsExecutor

unsubscribeFromNextCommand

public void unsubscribeFromNextCommand(@NotNull
                                       com.google.common.util.concurrent.ListenableFuture<PollingRemoteAgentConnection.Command> future)

Remove listener returned by subscribeToNextCommand() method.

Specified by:

unsubscribeFromNextCommand in interface AgentCommandsExecutor

getNextCommand

@Nullable
public PollingRemoteAgentConnection.Command getNextCommand()

Specified by:

getNextCommand in interface AgentCommandsExecutor

done

public void done(@NotNull
                 String result,
                 int commandId)

Specified by:

done in interface AgentCommandsExecutor

Throws:

UnrecognizedCommandException - when server doesn't know about this command

inProgress

public void inProgress(int commandId)

Specified by:

inProgress in interface AgentCommandsExecutor

failed

public void failed(@NotNull
                   Error error,
                   int commandId)

Specified by:

failed in interface AgentCommandsExecutor

Throws:

UnrecognizedCommandException - when server doesn't know about this command

hasActiveSubscriptions

public boolean hasActiveSubscriptions(long subscriptionTimeout)

Specified by:

hasActiveSubscriptions in interface AgentCommandsExecutor

dispose

public void dispose()

Specified by:

dispose in interface AgentCommandsExecutor