Package jetbrains.buildServer.serverSide.impl.agent

Class SingleNodeAgentCommandsExecutor

java.lang.Object

jetbrains.buildServer.serverSide.impl.agent.SingleNodeAgentCommandsExecutor

All Implemented Interfaces:

AgentCommandsExecutor

public class SingleNodeAgentCommandsExecutor
extends Object
implements AgentCommandsExecutor

Constructor Summary

Constructors

Constructor	Description
SingleNodeAgentCommandsExecutor(int initialCommandId, ExecutorService executorService, Supplier<jetbrains.buildServer.serverSide.impl.agent.PollingRemoteAgentConnection.AgentData> agentDataSupplier, Supplier<Long> timeSupplier)

Method Summary

Modifier and Type	Method	Description
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	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

Constructor Detail

SingleNodeAgentCommandsExecutor

public SingleNodeAgentCommandsExecutor(int initialCommandId,
                                       @NotNull
                                       ExecutorService executorService,
                                       @NotNull
                                       Supplier<jetbrains.buildServer.serverSide.impl.agent.PollingRemoteAgentConnection.AgentData> agentDataSupplier,
                                       @NotNull
                                       Supplier<Long> timeSupplier)

Method Detail

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

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