public class MessageListenerQueueProvider<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage>
extends java.lang.Object
MessageListener
used in CommonCommBaseImplementation
.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 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) |
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) |
protected pt.lsts.neptus.messages.listener.MessageListener<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage> listener
protected MessageFilter<Mi extends pt.lsts.neptus.messages.listener.MessageInfo,M extends IMessage> filter
protected final java.lang.Object filterLock
protected java.util.concurrent.LinkedBlockingQueue<pt.lsts.neptus.comm.manager.MessageListenerQueueProvider.MessagePackage> messageList
protected int queueMaxSize
public MessageListenerQueueProvider(pt.lsts.neptus.messages.listener.MessageListener<Mi,M> listener)
listener
- public MessageListenerQueueProvider(pt.lsts.neptus.messages.listener.MessageListener<Mi,M> listener, MessageFilter<Mi,M> filter)
listener
- filter
- public int getQueueMaxSize()
public void setQueueMaxSize(int queueMaxSize)
queueMaxSize
- the queueMaxSize to setpublic void setFilter(MessageFilter<Mi,M> filter)
filter
- the filter to setpublic void clearFilter()
public void cleanup()
public void clearMessages()
public int getMessageCount()
Copyright © 2004-2020 FEUP-LSTS and Neptus developers. All Rights Reserved.