Uses of Interface
org.apache.activemq.artemis.core.paging.PagedMessage
-
-
Uses of PagedMessage in org.apache.activemq.artemis.core.paging.cursor
Methods in org.apache.activemq.artemis.core.paging.cursor that return PagedMessage Modifier and Type Method Description PagedMessagePageCache. getMessage(PagePosition pagePosition)PagedMessagePageCursorProvider. getMessage(PagePosition pos)PagedMessage[]BulkPageCache. getMessages()PagedMessagePagedReference. getPagedMessage()PagedMessagePagedReferenceImpl. getPagedMessage()PagedMessagePageSubscription. queryMessage(PagePosition pos)To be used to requery the reference case the Garbage Collection removed it from the PagedReference as it's using WeakReferencesMethods in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagedMessage Modifier and Type Method Description voidLivePageCache. addLiveMessage(PagedMessage message)PagedReferencePageCursorProvider. newReference(PagePosition pos, PagedMessage msg, PageSubscription sub)Constructors in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagedMessage Constructor Description PagedReferenceImpl(PagePosition position, PagedMessage message, PageSubscription subscription) -
Uses of PagedMessage in org.apache.activemq.artemis.core.paging.cursor.impl
Methods in org.apache.activemq.artemis.core.paging.cursor.impl that return PagedMessage Modifier and Type Method Description PagedMessageLivePageCacheImpl. getMessage(PagePosition pagePosition)PagedMessagePageCursorProviderImpl. getMessage(PagePosition pos)PagedMessagePageReader. getMessage(PagePosition pagePosition)PagedMessagePageReader. getMessage(PagePosition pagePosition, boolean throwException, boolean keepOpen)PagedMessage[]LivePageCacheImpl. getMessages()PagedMessagePageSubscriptionImpl. queryMessage(PagePosition pos)protected PagedMessage[]PageReader. readMessages()Used just for testing purposes.Methods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type PagedMessage Modifier and Type Method Description voidLivePageCacheImpl. addLiveMessage(PagedMessage message)PagedReferencePageCursorProviderImpl. newReference(PagePosition pos, PagedMessage msg, PageSubscription subscription)Constructors in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type PagedMessage Constructor Description LivePageCacheImpl(long pageId, PagedMessage[] initialMessages) -
Uses of PagedMessage in org.apache.activemq.artemis.core.paging.impl
Classes in org.apache.activemq.artemis.core.paging.impl that implement PagedMessage Modifier and Type Class Description classPagedMessageImplThis class represents a paged messageMethods in org.apache.activemq.artemis.core.paging.impl that return PagedMessage Modifier and Type Method Description PagedMessagePage. readMessage(int startOffset, int startMessageNumber, int targetMessageNumber)Methods in org.apache.activemq.artemis.core.paging.impl that return types with arguments of type PagedMessage Modifier and Type Method Description List<PagedMessage>Page. read()List<PagedMessage>Page. read(StorageManager storage)List<PagedMessage>Page. read(StorageManager storage, boolean onlyLargeMessages)Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type PagedMessage Modifier and Type Method Description booleanPage. delete(PagedMessage[] messages)voidPage. write(PagedMessage message)voidPage. writeDirect(PagedMessage message)This write will not interact back with the storage manager. -
Uses of PagedMessage in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type PagedMessage Modifier and Type Method Description voidStorageManager. pageWrite(PagedMessage message, int pageNumber) -
Uses of PagedMessage in org.apache.activemq.artemis.core.persistence.impl.journal
Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type PagedMessage Modifier and Type Method Description voidJournalStorageManager. pageWrite(PagedMessage message, int pageNumber) -
Uses of PagedMessage in org.apache.activemq.artemis.core.persistence.impl.nullpm
Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type PagedMessage Modifier and Type Method Description voidNullStorageManager. pageWrite(PagedMessage message, int pageNumber) -
Uses of PagedMessage in org.apache.activemq.artemis.core.protocol.core.impl.wireformat
Methods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return PagedMessage Modifier and Type Method Description PagedMessageReplicationPageWriteMessage. getPagedMessage()Constructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type PagedMessage Constructor Description ReplicationPageWriteMessage(PagedMessage pagedMessage, int pageNumber) -
Uses of PagedMessage in org.apache.activemq.artemis.core.replication
Methods in org.apache.activemq.artemis.core.replication with parameters of type PagedMessage Modifier and Type Method Description voidReplicationManager. pageWrite(PagedMessage message, int pageNumber)
-