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 java.lang.Object
implements BambooAgentMessageSender

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

Constructor Summary

BatchedMessageSender(BambooAgentMessageSender delegate)

BatchedMessageSender(BambooAgentMessageSender delegate, long flushingDelay, int maxQueueSize)

Method Summary

void	flush()
void	send(BambooAgentMessage message) Sends a BambooAgentMessage, and any others that have been submitted but not yet sent, to the server immediately.
void	submit(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 Detail

BatchedMessageSender

public BatchedMessageSender(BambooAgentMessageSender delegate)

BatchedMessageSender

public BatchedMessageSender(BambooAgentMessageSender delegate,
                            long flushingDelay,
                            int maxQueueSize)

Method Detail

send

public void send(@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
                   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()