Package jetbrains.buildServer.serverSide.impl.agent

Interface AgentCommandsExecutor

All Known Implementing Classes:

MultiNodeAgentCommandsExecutor, SingleNodeAgentCommandsExecutor

public interface AgentCommandsExecutor

Method Summary

Modifier and Type	Method	Description
void	dispose()
void	done(String result, int commandId)
String	executeCommandAndWait(PollingRemoteAgentConnection.Command 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()
void	unsubscribeFromNextCommand(com.google.common.util.concurrent.ListenableFuture<PollingRemoteAgentConnection.Command> future)

Method Detail

scheduleCommand

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

Throws:

RejectedExecutionException

executeCommandAndWait

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

Throws:

AgentCommandExecutionException

AgentTimeoutException

InterruptedException

subscribeToNextCommand

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

unsubscribeFromNextCommand

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

getNextCommand

@Nullable
PollingRemoteAgentConnection.Command getNextCommand()

done

void done(@NotNull
          String result,
          int commandId)

inProgress

void inProgress(int commandId)

failed

void failed(@NotNull
            Error error,
            int commandId)

hasActiveSubscriptions

boolean hasActiveSubscriptions(long subscriptionTimeout)

dispose

void dispose()