pt.lsts.neptus.comm.manager

Class MessageListenerQueueProvider<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage>

java.lang.Object

pt.lsts.neptus.comm.manager.MessageListenerQueueProvider<Mi,M>

public class MessageListenerQueueProvider<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage>
extends java.lang.Object

This class implements a queue of messages used to provide a private queue to each MessageListener used in CommonCommBaseImplementation.

Author:

pdias

Field Summary

Fields

Modifier and Type	Field and Description
protected MessageFilter<Mi,M>	filter
protected java.lang.Object	filterLock
protected pt.lsts.neptus.messages.listener.MessageListener<Mi,M>	listener
protected java.util.concurrent.LinkedBlockingQueue<pt.lsts.neptus.comm.manager.MessageListenerQueueProvider.MessagePackage>	messageList
protected int	queueMaxSize

Constructor Summary

Constructors

Constructor and Description
MessageListenerQueueProvider(pt.lsts.neptus.messages.listener.MessageListener<Mi,M> listener)
MessageListenerQueueProvider(pt.lsts.neptus.messages.listener.MessageListener<Mi,M> listener, MessageFilter<Mi,M> filter)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	addMessage(Mi info, M message)
void	cleanup() This call invalidates the further use of this, but should be called to cleanup.
void	clearFilter() Set the filter to none.
void	clearMessages()
int	getMessageCount()
int	getQueueMaxSize()
void	setFilter(MessageFilter<Mi,M> filter)
void	setQueueMaxSize(int queueMaxSize)

Methods inherited from class java.lang.Object

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

Field Detail

listener

protected pt.lsts.neptus.messages.listener.MessageListener<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage> listener

filter

protected MessageFilter<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage> filter

filterLock

protected final java.lang.Object filterLock

messageList

protected java.util.concurrent.LinkedBlockingQueue<pt.lsts.neptus.comm.manager.MessageListenerQueueProvider.MessagePackage> messageList

queueMaxSize

protected int queueMaxSize

Constructor Detail

MessageListenerQueueProvider

public MessageListenerQueueProvider(pt.lsts.neptus.messages.listener.MessageListener<Mi,M> listener)

Parameters:

listener -

MessageListenerQueueProvider

public MessageListenerQueueProvider(pt.lsts.neptus.messages.listener.MessageListener<Mi,M> listener,
                            MessageFilter<Mi,M> filter)

Parameters:

listener -

filter -

Method Detail

getQueueMaxSize

public int getQueueMaxSize()

Returns:

the queueMaxSize

setQueueMaxSize

public void setQueueMaxSize(int queueMaxSize)

Parameters:

queueMaxSize - the queueMaxSize to set

setFilter

public void setFilter(MessageFilter<Mi,M> filter)

Parameters:

filter - the filter to set

clearFilter

public void clearFilter()

Set the filter to none.

cleanup

public void cleanup()

This call invalidates the further use of this, but should be called to cleanup.

clearMessages

public void clearMessages()

getMessageCount

public int getMessageCount()

addMessage

public boolean addMessage(Mi info,
                 M message)

Parameters:

info -

message -

Returns: