public class MessageList extends AbstractListMessage<PlatformMessage> implements PlatformMessage
PlatformMessages.modCountDEFAULT_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, toStringDetailedadd, 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, trimToSizecontainsAllfinalize, getClass, notify, notifyAll, wait, wait, waitaddMessageHistory, addMessageHistory, clone, getClientId, getEstimatedSize, getMessageHistory, getMessageId, getMetadata, getProperty, getWorkflowQueue, getWorkflowQueue, isRedelivered, removeProperty, setClientId, setMessageId, setProperty, setRedelivered, setWorkflowQueue, setWorkflowQueue, toMessageStringcontainsAllparallelStream, streampublic MessageList(UUID clientId)
clientId - the client IDpublic MessageList(UUID clientId, int size)
clientId - the client IDsize - the sizepublic MessageList(UUID clientId, PlatformMessage... msgs)
MessageLists, 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.