Class OutgoingMessageQueueImpl

java.lang.Object

com.biglybt.pifimpl.local.network.OutgoingMessageQueueImpl

All Implemented Interfaces:

OutgoingMessageQueue

public class OutgoingMessageQueueImpl
extends Object
implements OutgoingMessageQueue

Field Summary

Fields

Modifier and Type	Field	Description
private final OutgoingMessageQueue	core_queue
private final HashMap	registrations

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OutgoingMessageQueueImpl(OutgoingMessageQueue core_queue)

Method Summary

Modifier and Type	Method	Description
void	deregisterListener(OutgoingMessageQueueListener listener)	Remove registration of queue listener.
int[]	getCurrentMessageProgress()
int	getDataQueuedBytes()
int	getProtocolQueuedBytes()
boolean	isBlocked()
void	notifyOfExternalSend(Message message)	Notifty the queue (and its listeners) of a message sent externally on the queue's behalf.
void	registerListener(OutgoingMessageQueueListener listener)	Register queue listener.
void	sendMessage(Message message)	Queue the given message for sending.
void	setEncoder(MessageStreamEncoder encoder)	Set the message stream encoder that will be used to encode outgoing messages.

Methods inherited from class Object

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

Methods inherited from interface OutgoingMessageQueue

getPercentDoneOfCurrentMessage

Field Details

core_queue

private final OutgoingMessageQueue core_queue

registrations

private final HashMap registrations

Constructor Details

OutgoingMessageQueueImpl

protected OutgoingMessageQueueImpl(OutgoingMessageQueue core_queue)

Method Details

setEncoder

public void setEncoder(MessageStreamEncoder encoder)

Description copied from interface: OutgoingMessageQueue

Set the message stream encoder that will be used to encode outgoing messages.

Specified by:

setEncoder in interface OutgoingMessageQueue

Parameters:

encoder - to use

sendMessage

public void sendMessage(Message message)

Description copied from interface: OutgoingMessageQueue

Queue the given message for sending.

Specified by:

sendMessage in interface OutgoingMessageQueue

Parameters:

message - to send

registerListener

public void registerListener(OutgoingMessageQueueListener listener)

Description copied from interface: OutgoingMessageQueue

Register queue listener.

Specified by:

registerListener in interface OutgoingMessageQueue

Parameters:

listener - to register

deregisterListener

public void deregisterListener(OutgoingMessageQueueListener listener)

Description copied from interface: OutgoingMessageQueue

Remove registration of queue listener.

Specified by:

deregisterListener in interface OutgoingMessageQueue

Parameters:

listener - to remove

notifyOfExternalSend

public void notifyOfExternalSend(Message message)

Description copied from interface: OutgoingMessageQueue

Notifty the queue (and its listeners) of a message sent externally on the queue's behalf.

Specified by:

notifyOfExternalSend in interface OutgoingMessageQueue

Parameters:

message - sent externally

getCurrentMessageProgress

public int[] getCurrentMessageProgress()

Specified by:

getCurrentMessageProgress in interface OutgoingMessageQueue

getDataQueuedBytes

public int getDataQueuedBytes()

Specified by:

getDataQueuedBytes in interface OutgoingMessageQueue

getProtocolQueuedBytes

public int getProtocolQueuedBytes()

Specified by:

getProtocolQueuedBytes in interface OutgoingMessageQueue

isBlocked

public boolean isBlocked()

Specified by:

isBlocked in interface OutgoingMessageQueue