Package com.atlassian.bamboo.collections
Class FileBackedAgentMessageQueue<T>
- java.lang.Object
-
- com.atlassian.bamboo.collections.FileBackedAgentMessageQueue<T>
-
- All Implemented Interfaces:
AgentMessageQueue<T>
public class FileBackedAgentMessageQueue<T> extends Object implements AgentMessageQueue<T>
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from interface com.atlassian.bamboo.collections.AgentMessageQueue
AgentMessageQueue.Message<T>
-
-
Constructor Summary
Constructors Constructor Description FileBackedAgentMessageQueue(File directoryWithQueues, ObjectSerialiserDispatcher objectSerialiser)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
add(T message)
@Nullable AgentMessageQueue.Message<T>
poll()
-
-
-
Constructor Detail
-
FileBackedAgentMessageQueue
public FileBackedAgentMessageQueue(File directoryWithQueues, ObjectSerialiserDispatcher objectSerialiser)
-
-
Method Detail
-
add
public void add(@NotNull T message)
- Specified by:
add
in interfaceAgentMessageQueue<T>
-
poll
@Nullable public @Nullable AgentMessageQueue.Message<T> poll()
- Specified by:
poll
in interfaceAgentMessageQueue<T>
-
-