Package jetbrains.buildServer.serverSide.impl

Class BuildAgentMessagesQueue.BuildMessagesQueue

java.lang.Object

jetbrains.buildServer.serverSide.impl.BuildAgentMessagesQueue.BuildMessagesQueue

Enclosing class:

BuildAgentMessagesQueue

public class BuildAgentMessagesQueue.BuildMessagesQueue
extends Object

Constructor Summary

Constructors

Constructor	Description
BuildMessagesQueue(RunningBuildEx build)

Method Summary

Modifier and Type	Method	Description
void	addMessages(List<BuildMessage1> messages)
Date	getFirstMessageDate()
List<MessageProcessor>	getMessageProcessors()	Returns unmodifiable list of currently initialized messages processors
int	getNumberOfUnprocessedMessages()
List<BuildMessage1>	getUnprocessedMessages()
boolean	isEmpty()
void	lockProcessingMessages()
void	markAsFinished(Date finishDate, boolean failedOnAgent)
int	processMessages()
boolean	tryLockProcessingMessages()
void	unlockProcessingMessages()
boolean	waitUntilAllMessagesProcessed(long timeoutMillis)

Methods inherited from class java.lang.Object

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

Constructor Detail

BuildMessagesQueue

public BuildMessagesQueue(@NotNull
                          RunningBuildEx build)

Method Detail

addMessages

public void addMessages(@NotNull
                        List<BuildMessage1> messages)
                 throws InterruptedException

Throws:

InterruptedException

markAsFinished

public void markAsFinished(@NotNull
                           Date finishDate,
                           boolean failedOnAgent)

waitUntilAllMessagesProcessed

public boolean waitUntilAllMessagesProcessed(long timeoutMillis)

Parameters:

timeoutMillis - time to wait in milliseconds

Returns:

true if messages were processed and false if timeout happened

isEmpty

public boolean isEmpty()

getFirstMessageDate

@Nullable
public Date getFirstMessageDate()

getUnprocessedMessages

@NotNull
public List<BuildMessage1> getUnprocessedMessages()

getNumberOfUnprocessedMessages

public int getNumberOfUnprocessedMessages()

tryLockProcessingMessages

public boolean tryLockProcessingMessages()

lockProcessingMessages

public void lockProcessingMessages()

unlockProcessingMessages

public void unlockProcessingMessages()

processMessages

public int processMessages()

getMessageProcessors

@NotNull
public List<MessageProcessor> getMessageProcessors()

Returns unmodifiable list of currently initialized messages processors

Returns:

see above

Since:

2022.02