Uses of Interface
org.apache.activemq.artemis.core.paging.PagedMessage
Packages that use PagedMessage
Package
Description
-
Uses of PagedMessage in org.apache.activemq.artemis.core.paging
Methods in org.apache.activemq.artemis.core.paging that return PagedMessageModifier and TypeMethodDescriptionPagedMessage.setMessageNumber(int messageNr) PagedMessage.setPageNumber(long pageNr) -
Uses of PagedMessage in org.apache.activemq.artemis.core.paging.cursor
Fields in org.apache.activemq.artemis.core.paging.cursor declared as PagedMessageMethods in org.apache.activemq.artemis.core.paging.cursor that return PagedMessageModifier and TypeMethodDescriptionPagedReference.getPagedMessage()PagedReferenceImpl.getPagedMessage()QueryPagedReferenceImpl.getPagedMessage()PageSubscription.queryMessage(PagePosition pos) To be used to requery the referenceMethods in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagedMessageModifier and TypeMethodDescriptionvoidPageSubscription.addPendingDelivery(PagedMessage pagedMessage) booleanPageSubscription.isAcked(PagedMessage pagedMessage) PageCursorProvider.newReference(PagedMessage msg, PageSubscription sub) voidPageSubscription.removePendingDelivery(PagedMessage pagedMessage) Constructors in org.apache.activemq.artemis.core.paging.cursor with parameters of type PagedMessageModifierConstructorDescriptionPagedReferenceImpl(PagedMessage message, PageSubscription subscription) QueryPagedReferenceImpl(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 PagedMessageMethods in org.apache.activemq.artemis.core.paging.cursor.impl with parameters of type PagedMessageModifier and TypeMethodDescriptionvoidPageSubscriptionImpl.addPendingDelivery(PagedMessage pagedMessage) booleanPageSubscriptionImpl.isAcked(PagedMessage pagedMessage) PageCursorProviderImpl.newReference(PagedMessage msg, PageSubscription subscription) voidPageSubscriptionImpl.removePendingDelivery(PagedMessage pagedMessage) -
Uses of PagedMessage in org.apache.activemq.artemis.core.paging.impl
Classes in org.apache.activemq.artemis.core.paging.impl that implement PagedMessageMethods in org.apache.activemq.artemis.core.paging.impl that return types with arguments of type PagedMessageModifier and TypeMethodDescriptionPage.getMessages()Page.iterator()Page.read()Page.read(StorageManager storage) Page.read(StorageManager storage, boolean onlyLargeMessages) Methods in org.apache.activemq.artemis.core.paging.impl with parameters of type PagedMessageModifier and TypeMethodDescriptionintPageTimedWriter.addTask(OperationContext context, PagedMessage message, Transaction tx, RouteContextList listCtx, boolean useFlowControl) protected voidPagingStoreImpl.directWritePage(PagedMessage pagedMessage, boolean lineUp, boolean originalReplicated) voidPage.write(PagedMessage message, boolean lineUp, boolean originallyReplicated) voidPage.writeDirect(PagedMessage message) This write will not interact back with the storage manager.static intPageReadWriter.writeMessage(PagedMessage message, SequentialFileFactory fileFactory, SequentialFile file) Method parameters in org.apache.activemq.artemis.core.paging.impl with type arguments of type PagedMessageModifier and TypeMethodDescriptionbooleanPage.delete(LinkedList<PagedMessage> messages) static intPageReadWriter.readFromSequentialFile(StorageManager storage, SimpleString storeName, SequentialFileFactory fileFactory, SequentialFile file, long pageId, Consumer<PagedMessage> messages, PageReadWriter.PageRecordFilter skipRecord, PageReadWriter.SuspectFileCallback suspectFileCallback, PageReadWriter.ReadCallback readCallback) -
Uses of PagedMessage in org.apache.activemq.artemis.core.persistence
Methods in org.apache.activemq.artemis.core.persistence with parameters of type PagedMessageModifier and TypeMethodDescriptionvoidStorageManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean storageUp, boolean originallyReplicated) -
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 PagedMessageModifier and TypeMethodDescriptionvoidJournalStorageManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean storageUp, boolean originallyReplicated) -
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 PagedMessageModifier and TypeMethodDescriptionvoidNullStorageManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean lineup, boolean originallyReplicated) -
Uses of PagedMessage in org.apache.activemq.artemis.core.protocol.core.impl.wireformat
Fields in org.apache.activemq.artemis.core.protocol.core.impl.wireformat declared as PagedMessageMethods in org.apache.activemq.artemis.core.protocol.core.impl.wireformat that return PagedMessageConstructors in org.apache.activemq.artemis.core.protocol.core.impl.wireformat with parameters of type PagedMessageModifierConstructorDescriptionReplicationPageWriteMessage(PagedMessage pagedMessage, long pageNumber, boolean useLong, SimpleString address) -
Uses of PagedMessage in org.apache.activemq.artemis.core.replication
Methods in org.apache.activemq.artemis.core.replication with parameters of type PagedMessageModifier and TypeMethodDescriptionvoidReplicationManager.pageWrite(SimpleString address, PagedMessage message, long pageNumber, boolean lineup)