eu.hgross.blaubot.messaging

Class BlaubotMessageSender

java.lang.Object

eu.hgross.blaubot.messaging.BlaubotMessageSender

public class BlaubotMessageSender
extends java.lang.Object

The message sender simply queues messages that are going to be sent over the IBlaubotConnection for which this message sender was created for. The sender can be activated/deactivated, meaning stopping and starting a queue consuming thread that serializes and sends the queued messages (if any) over the given IBlaubotConnection. TODO: handle failing connections

Constructor Summary

Constructors

Constructor and Description
BlaubotMessageSender(IBlaubotConnection blaubotConnection)

Method Summary

Modifier and Type	Method and Description
void	activate() Activates the message receiver (reading from the connection)
void	deactivate(IActionListener actionListener) Deactivates the message sender (completes current message readings, if any and then shuts down).
boolean	equals(java.lang.Object o)
protected IBlaubotConnection	getBlaubotConnection() The connection that is managed by this message sender.
protected long	getQueuedBytes() The current number of bytes in this MessageSender's queue.
protected int	getQueueSize() The current amount of messages in the queue
long	getSentMessages() sent messages
long	getSentPayloadBytes()
int	hashCode()
void	sendMessage(BlaubotMessage message) Queues the given message to be sent over the IBlaubotConnection this object was created with.
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

BlaubotMessageSender

public BlaubotMessageSender(IBlaubotConnection blaubotConnection)

Method Detail

sendMessage

public void sendMessage(BlaubotMessage message)

Queues the given message to be sent over the IBlaubotConnection this object was created with.

Parameters:

message - the message to be send

activate

public void activate()

Activates the message receiver (reading from the connection)

deactivate

public void deactivate(IActionListener actionListener)

Deactivates the message sender (completes current message readings, if any and then shuts down).

Parameters:

actionListener - callback to be informed when the sender was closed (thread finished), can be null

getSentPayloadBytes

public long getSentPayloadBytes()

Returns:

sent bytes so far

getSentMessages

public long getSentMessages()

sent messages

Returns:

sent messages so far

getBlaubotConnection

protected IBlaubotConnection getBlaubotConnection()

The connection that is managed by this message sender.

Returns:

the managed connection

getQueueSize

protected int getQueueSize()

The current amount of messages in the queue

Returns:

current amount of messages in the queue

getQueuedBytes

protected long getQueuedBytes()

The current number of bytes in this MessageSender's queue.

Returns:

number of bytes

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object