public class FileBackedAgentMessageQueue<T> extends Object implements AgentMessageQueue<T>
AgentMessageQueue.Message<T>
Constructor and Description |
---|
FileBackedAgentMessageQueue(File directoryWithQueues,
ObjectSerialiserDispatcher objectSerialiser) |
Modifier and Type | Method and Description |
---|---|
void |
add(T message) |
@Nullable AgentMessageQueue.Message<T> |
poll() |
public FileBackedAgentMessageQueue(File directoryWithQueues, ObjectSerialiserDispatcher objectSerialiser)
public void add(@NotNull T message)
add
in interface AgentMessageQueue<T>
@Nullable public @Nullable AgentMessageQueue.Message<T> poll()
poll
in interface AgentMessageQueue<T>
Copyright © 2022 Atlassian Software Systems Pty Ltd. All rights reserved.