Package com.atlassian.bamboo.v2.build.agent.remote.sender

Class BatchedMessageSender

java.lang.Object

com.atlassian.bamboo.v2.build.agent.remote.sender.BatchedMessageSender

All Implemented Interfaces:

BambooAgentMessageSender

@ThreadSafe
public class BatchedMessageSender
extends Object
implements BambooAgentMessageSender

A sender strategy that batches the messages up in a queue and periodically flushes the queue.

Constructor Summary

Constructors

Constructor	Description
BatchedMessageSender(BambooAgentMessageSender delegate, HomeDirectoryLayout homeDirectoryLayout, ObjectSerialiserDispatcher objectSerialiserDispatcher)

Method Summary

Modifier and Type	Method	Description
void	flush()	Flush outgoing messages.
@Nullable Object	send(@NotNull BambooAgentMessage message)	Sends a BambooAgentMessage, and any others that have been submitted but not yet sent, to the server immediately.
void	submit(@NotNull BambooAgentMessage message)	Submits a BambooAgentMessage to be sent to the server when convenient.

Methods inherited from class java.lang.Object

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

Constructor Details

BatchedMessageSender

public BatchedMessageSender(BambooAgentMessageSender delegate,
 HomeDirectoryLayout homeDirectoryLayout,
 ObjectSerialiserDispatcher objectSerialiserDispatcher)

Method Details

send

@Nullable
public @Nullable Object send(@NotNull
 @NotNull BambooAgentMessage message)

Description copied from interface: BambooAgentMessageSender

Sends a BambooAgentMessage, and any others that have been submitted but not yet sent, to the server immediately.

Specified by:

send in interface BambooAgentMessageSender

Parameters:

message - The BambooAgentMessage to send.

submit

public void submit(@NotNull
 @NotNull BambooAgentMessage message)

Description copied from interface: BambooAgentMessageSender

Submits a BambooAgentMessage to be sent to the server when convenient.

Specified by:

submit in interface BambooAgentMessageSender

Parameters:

message - The BambooAgentMessage to submit.

flush

public void flush()

Description copied from interface: BambooAgentMessageSender

Flush outgoing messages.

Specified by:

flush in interface BambooAgentMessageSender