org.myrobotlab.framework

Class Outbox

java.lang.Object

org.myrobotlab.framework.Outbox

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable

public class Outbox
extends java.lang.Object
implements java.lang.Runnable, java.io.Serializable

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BROADCAST
static java.lang.String	IGNORE
static org.slf4j.Logger	log
java.util.HashMap<java.lang.String,java.util.ArrayList<MRLListener>>	notifyList
static java.lang.String	PROCESSANDBROADCAST
static java.lang.String	RELAY

Constructor Summary

Constructors

Constructor and Description
Outbox(NameProvider myService)

Method Summary

Modifier and Type	Method and Description
void	add(Message msg)
CommunicationInterface	getCommunicationManager()
int	getMaxQueueSize()
java.util.LinkedList<Message>	getMsgBox()
boolean	isBlocking()
boolean	isRunning()
void	run()
void	setBlocking(boolean blocking)
void	setCommunicationManager(CommunicationInterface c)
int	size()
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

log

public static final org.slf4j.Logger log

RELAY

public static final java.lang.String RELAY

See Also:

Constant Field Values

IGNORE

public static final java.lang.String IGNORE

See Also:

Constant Field Values

BROADCAST

public static final java.lang.String BROADCAST

See Also:

Constant Field Values

PROCESSANDBROADCAST

public static final java.lang.String PROCESSANDBROADCAST

See Also:

Constant Field Values

notifyList

public java.util.HashMap<java.lang.String,java.util.ArrayList<MRLListener>> notifyList

Constructor Detail

Outbox

public Outbox(NameProvider myService)

Method Detail

add

public void add(Message msg)

getCommunicationManager

public CommunicationInterface getCommunicationManager()

run

public void run()

Specified by:

run in interface java.lang.Runnable

setCommunicationManager

public void setCommunicationManager(CommunicationInterface c)

size

public int size()

start

public void start()

stop

public void stop()

getMsgBox

public java.util.LinkedList<Message> getMsgBox()

getMaxQueueSize

public int getMaxQueueSize()

isBlocking

public boolean isBlocking()

setBlocking

public void setBlocking(boolean blocking)

isRunning

public boolean isRunning()