public class MessageList extends AbstractListMessage<PlatformMessage> implements PlatformMessage
PlatformMessage
s.modCount
DEFAULT_MAX_LOG_LENGTH, MESSAGE_DROPPED, MESSAGE_SEND_TIME_PROP, PROP_MAX_LOG_LENGTH
Constructor and Description |
---|
MessageList(UUID clientId)
Constructor with the given client ID.
|
MessageList(UUID clientId,
int size)
Constructor with a client ID and a size.
|
MessageList(UUID clientId,
PlatformMessage... msgs)
Constructor with a client ID and a list of messages.
|
Modifier and Type | Method and Description |
---|---|
boolean |
add(PlatformMessage message) |
protected PlatformMessage |
clone(PlatformMessage tmp) |
boolean |
containsMessage(Class<? extends PlatformMessage> clazz)
Checks to see if this list contains a message of the specified class type.
|
boolean |
equals(Object other) |
<T extends PlatformMessage> |
getMessage(Class<T> clazz)
Gets the first instance of a message of the specified type, walking into inner MessageLists if present
|
int |
hashCode() |
<T extends PlatformMessage> |
iterator(Class<T> messageClass)
Return an iterator that will recursively iterate over all sub messages of this MessageList.
|
addMessageHistory, addMessageHistory, clone, getClientId, getEstimatedSize, getMessageHistory, getMessageId, getMetadata, getProperty, getWorkflowQueue, getWorkflowQueue, isRedelivered, removeProperty, setClientId, setMessageId, setProperty, setRedelivered, setWorkflowQueue, setWorkflowQueue, toMessageString, toString, toStringDetailed
add, addAll, addAll, clear, contains, ensureCapacity, forEach, get, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSize
containsAll
finalize, getClass, notify, notifyAll, wait, wait, wait
addMessageHistory, addMessageHistory, clone, getClientId, getEstimatedSize, getMessageHistory, getMessageId, getMetadata, getProperty, getWorkflowQueue, getWorkflowQueue, isRedelivered, removeProperty, setClientId, setMessageId, setProperty, setRedelivered, setWorkflowQueue, setWorkflowQueue, toMessageString
containsAll
parallelStream, stream
public MessageList(UUID clientId)
clientId
- the client IDpublic MessageList(UUID clientId, int size)
clientId
- the client IDsize
- the sizepublic MessageList(UUID clientId, PlatformMessage... msgs)
MessageList
s, then you may want to add them with the
ArrayList.addAll(java.util.Collection)
method if you want them added
as individual messages instead of a nested MessageList
within this
MessageList
.clientId
- the client IDmsgs
- the messagespublic boolean containsMessage(Class<? extends PlatformMessage> clazz)
clazz
- the class to check for using instanceofpublic <T extends PlatformMessage> T getMessage(Class<T> clazz)
clazz
- the class to findpublic <T extends PlatformMessage> Iterator<T> iterator(Class<T> messageClass)
messageClass
- the PlatformMessage class to select for iteration.public int hashCode()
hashCode
in interface Collection<PlatformMessage>
hashCode
in interface List<PlatformMessage>
hashCode
in class AbstractListMessage<PlatformMessage>
public boolean equals(Object other)
equals
in interface Collection<PlatformMessage>
equals
in interface List<PlatformMessage>
equals
in class AbstractListMessage<PlatformMessage>
protected PlatformMessage clone(PlatformMessage tmp)
clone
in class AbstractListMessage<PlatformMessage>
public boolean add(PlatformMessage message)
add
in interface Collection<PlatformMessage>
add
in interface List<PlatformMessage>
add
in class ArrayList<PlatformMessage>
Copyright © 2018 Attivio, Inc. All Rights Reserved.
PATENT NOTICE: Attivio, Inc. Software Related Patents. With respect to the Attivio software product(s) being used, the following patents apply: Querying Joined Data Within A Search Engine Index: United States Patent No.(s): 8,073,840. Ordered Processing of Groups of Messages: U.S. Patent No.(s) 8,495,656. Signal processing approach to sentiment analysis for entities in documents: U.S. Patent No.(s) 8,725,494. Other U.S. and International Patents Pending.