public interface IRogQueue<T extends IRogQueueElement> extends IRogCollectionNode<T>, Queue<T>
IRogNode.PoolingListenerIStoreObject.EncodingTypeENCODING_TYPE_CUSTOM, ENCODING_TYPE_JSON, ENCODING_TYPE_PROTOBUF, ENCODING_TYPE_QUARK, ENCODING_TYPE_XBUF, ENCODING_TYPE_XBUF2, NEXT_FREE_ENCODING_TYPE| Modifier and Type | Method and Description |
|---|---|
XIterator<T> |
reusableIterator()
Returns an iterator over the elements in this queue.
|
XIterator<T> |
reusableReverseIterator()
Returns an iterator over the elements in this queue in reverse.
|
XIterator<T> |
reverseIterator()
Returns an iterator that iterates elements in reverse.
|
addChild, getNumChildren, removeChilddeserializeFromProtobuf, dispose, dump, getAttachment, getIsLiveInboundMessage, getIsPriority, getIsReadOnly, getMetadata, getParent, getPoolingListener, getType, metadataToJsonString, serializeToProtobuf, setAsInboundMessage, setAsInternal, setAsLastTransaction, setAsMessage, setAsOutboundMessage, setAsPriority, setAsReadOnly, setAsReplayedMessage, setAttachment, setInMsgsInTransaction, setOutMsgsInTransaction, setParentId, setPoolingListener, setTransactionInSequenceNumber, setTransactionOutSequenceNumberacquire, deserialize, deserializeMetadata, deserializeMetadata, getContentEncodingType, getOwnershipCount, getSerializedMetadataLength, getStoreMetadata, serialize, serializeMetadata, setFieldValueensureId, getBinding, getCheckpointVersion, getCommittedDataSize, getId, getOfid, getStableTransactionId, getTransactionId, setBinding, setCheckpointVersion, setCommittedDataSize, setId, setStableTransactionId, setTransactionIdgetMessageReflectoracquire, deserializeFromByteArray, deserializeFromByteBuffer, deserializeFromJson, deserializeFromPacket, getAppSendBeginTs, getAppSendDoneTs, getCreateTs, getEnqueueTs, getEnqueueTsMicros, getMessage, getMessageBus, getMessageBusAsRaw, getMessageChannel, getMessageChannelAsRaw, getMessageEncodingType, getMessageFlow, getMessageKey, getMessageKeyAsRaw, getMessageSender, getMessageSequenceNumber, getMessageTransportHeaders, getOriginTs, getOutTs, getOutTsMicros, getOwnershipCount, getPostDeserializeTs, getPostProcessingTs, getPostProcessingTsMicros, getPostSerializeTs, getPostWireSendTs, getPostWireTs, getPreDeserializeTs, getPreProcessingTs, getPreProcessingTsMicros, getPreSerializeTs, getPreWireTs, getReceiveTs, getSendStartTs, getSendTs, getTag, getVfid, isPossibleDuplicate, resolveMessageKeyWith, resolveMessageKeyWith, serializeToByteArray, serializeToByteBuffer, serializeToIOBuffer, serializeToJson, serializeToPacket, setAppSendBeginTs, setAppSendDoneTs, setCreateTs, setEnqueueTsMicros, setMessageBus, setMessageBusAsRaw, setMessageChannel, setMessageChannelAsRaw, setMessageFlow, setMessageKey, setMessageKeyAsRaw, setMessageSender, setMessageSequenceNumber, setMessageTransportHeaders, setOriginTs, setOutTs, setOutTsMicros, setPossibleDuplicate, setPostDeserializeTs, setPostProcessingTs, setPostProcessingTsMicros, setPostSerializeTs, setPostWireSendTs, setPostWireTs, setPreDeserializeTs, setPreProcessingTs, setPreProcessingTsMicros, setPreSerializeTs, setPreWireTs, setReceiveTs, setSendStartTs, setSendTs, setTag, syncreferenceTrackergetEnqueueTs, getEnqueueTsMicros, getGraphId, getInMsgsInTransaction, getIsInboundMessage, getIsInternal, getIsLastTransaction, getIsMessage, getIsOutboundMessage, getIsReplayedMessage, getMessageBus, getMessageChannel, getMessageFlow, getMessageKey, getMessageSender, getMessageSequenceNumber, getMessageTransportHeaders, getOutMsgsInTransaction, getOutTs, getOutTsMicros, getParentId, getPreProcessingTs, getPreProcessingTsMicros, getTransactionInSequenceNumber, getTransactionOutSequenceNumber, isPossibleDuplicate, metadataToJsonString, metadataToStringgetValidationErrors, isValidXIterator<T> reverseIterator()
The first element in the returned iterator will be the last element in the
queue and subsequent calls to next() will return
the previous element in the queue. A call to toFirst()
will reset the iterator to the last element in the queue.
XIterator<T> reusableIterator()
This iterator may be used in lieue of the Collection.iterator() to avoid creating
garbage associate with constructing a new Iterator.
This iterator may only be used by a single thread at a time. This method
invokes XIterator.toFirst() on the iterator prior to returning
it and will return the same iterator instance on each call. Note also that the
returned iterator is the same iterator returned by reusableReverseIterator().
XIterator<T> reusableReverseIterator()
The first element in the returned iterator will be the last element in the
queue and subsequent calls to next() will return
the previous element in the queue. A call to toFirst()
will reset the iterator to the last element in the queue.
This iterator may be used in lieue of the Collection.iterator() to avoid creating
garbage associate with constructing a new Iterator.
This iterator may only be used by a single thread at a time. This method
invokes XIterator.toFirst() on the iterator prior to returning
it and will return the same iterator instance on each call. Note also that the
returned iterator is the same iterator returned by reusableIterator().
Copyright © 2019 Neeve Research, LLC. All Rights Reserved.