Uses of Interface
org.apache.activemq.artemis.core.io.IOCallback

Packages that use IOCallback

Package	Description
org.apache.activemq.artemis.core.io
org.apache.activemq.artemis.core.io.aio
org.apache.activemq.artemis.core.io.buffer
org.apache.activemq.artemis.core.io.nio
org.apache.activemq.artemis.core.journal
org.apache.activemq.artemis.core.journal.impl
org.apache.activemq.artemis.core.persistence
org.apache.activemq.artemis.core.persistence.impl.journal
org.apache.activemq.artemis.core.persistence.impl.nullpm
org.apache.activemq.artemis.core.server
org.apache.activemq.artemis.jdbc.store.file

Uses of IOCallback in org.apache.activemq.artemis.core.io

Classes in org.apache.activemq.artemis.core.io that implement IOCallback

Modifier and Type	Class	Description
class	DelegateCallback	It is a utility class to allow several IOCallbacks to be used as one.
class	DummyCallback
class	RunnableCallback

Methods in org.apache.activemq.artemis.core.io with parameters of type IOCallback

Modifier and Type	Method	Description
int	SequentialFile.read(ByteBuffer bytes, IOCallback callback)
void	AbstractSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	AbstractSequentialFile.write(EncodingSupport bytes, boolean sync, IOCallback callback)
void	SequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	SequentialFile.write(EncodingSupport bytes, boolean sync, IOCallback callback)
void	SequentialFile.writeDirect(ByteBuffer bytes, boolean sync, IOCallback callback)	Write directly to the file without using any buffer

Method parameters in org.apache.activemq.artemis.core.io with type arguments of type IOCallback

Modifier and Type	Method	Description
static void	IOCallback.done(Collection<? extends IOCallback> delegates)
void	AbstractSequentialFile.LocalBufferObserver.flushBuffer(io.netty.buffer.ByteBuf byteBuf, boolean requestedSync, List<IOCallback> callbacks)
static void	IOCallback.onError(Collection<? extends IOCallback> delegates, int errorCode, String errorMessage)

Constructor parameters in org.apache.activemq.artemis.core.io with type arguments of type IOCallback

Constructor	Description
DelegateCallback(Collection<? extends IOCallback> delegates)	It doesn't copy defensively the given delegates.

Uses of IOCallback in org.apache.activemq.artemis.core.io.aio

Methods in org.apache.activemq.artemis.core.io.aio with parameters of type IOCallback

Modifier and Type	Method	Description
AIOSequentialFileFactory.AIOSequentialCallback	AIOSequentialFileFactory.AIOSequentialCallback.init(long writeSequence, IOCallback IOCallback, LibaioFile libaioFile, AIOSequentialFile sequentialFile, ByteBuffer usedBuffer, boolean releaseBuffer)
int	AIOSequentialFile.read(ByteBuffer bytes, IOCallback callback)
void	AIOSequentialFile.writeDirect(ByteBuffer bytes, boolean sync, IOCallback callback)	Note: Parameter sync is not used on AIO

Uses of IOCallback in org.apache.activemq.artemis.core.io.buffer

Methods in org.apache.activemq.artemis.core.io.buffer with parameters of type IOCallback

Modifier and Type	Method	Description
void	TimedBuffer.addBytes(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	TimedBuffer.addBytes(EncodingSupport bytes, boolean sync, IOCallback callback)

Method parameters in org.apache.activemq.artemis.core.io.buffer with type arguments of type IOCallback

Modifier and Type	Method	Description
void	TimedBufferObserver.flushBuffer(io.netty.buffer.ByteBuf buffer, boolean syncRequested, List<IOCallback> callbacks)	It flushes ByteBuf.readableBytes() of buffer without changing its reader/writer indexes. It just use buffer temporary: it can be reused by the caller right after this call.

Uses of IOCallback in org.apache.activemq.artemis.core.io.nio

Methods in org.apache.activemq.artemis.core.io.nio with parameters of type IOCallback

Modifier and Type	Method	Description
int	NIOSequentialFile.read(ByteBuffer bytes, IOCallback callback)
void	NIOSequentialFile.writeDirect(ByteBuffer bytes, boolean sync, IOCallback callback)

Uses of IOCallback in org.apache.activemq.artemis.core.journal

Subinterfaces of IOCallback in org.apache.activemq.artemis.core.journal

Modifier and Type	Interface	Description
interface	IOCompletion

Uses of IOCallback in org.apache.activemq.artemis.core.journal.impl

Classes in org.apache.activemq.artemis.core.journal.impl that implement IOCallback

Modifier and Type	Class	Description
class	SimpleWaitIOCallback
class	SyncIOCompletion	Internal class used to manage explicit syncs on the Journal through callbacks.
class	TransactionCallback

Methods in org.apache.activemq.artemis.core.journal.impl that return IOCallback

Modifier and Type	Method	Description
IOCallback	TransactionCallback.getDelegateCompletion()

Methods in org.apache.activemq.artemis.core.journal.impl with parameters of type IOCallback

Modifier and Type	Method	Description
void	TransactionCallback.setDelegateCompletion(IOCallback delegateCompletion)

Uses of IOCallback in org.apache.activemq.artemis.core.persistence

Subinterfaces of IOCallback in org.apache.activemq.artemis.core.persistence

Modifier and Type	Interface	Description
interface	OperationContext	This represents a set of operations done as part of replication.

Methods in org.apache.activemq.artemis.core.persistence with parameters of type IOCallback

Modifier and Type	Method	Description
void	StorageManager.afterCompleteOperations(IOCallback run)
void	StorageManager.afterStoreOperations(IOCallback run)	This is similar to afterComplete, however this only cares about the journal part.
void	OperationContext.executeOnCompletion(IOCallback runnable)	Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.
void	OperationContext.executeOnCompletion(IOCallback runnable, boolean storeOnly)	Execute the task when all IO operations are complete, Or execute it immediately if nothing is pending.

Uses of IOCallback in org.apache.activemq.artemis.core.persistence.impl.journal

Classes in org.apache.activemq.artemis.core.persistence.impl.journal that implement IOCallback

Modifier and Type	Class	Description
class	DummyOperationContext
class	OperationContextImpl	Each instance of OperationContextImpl is associated with an executor (usually an ordered Executor).

Methods in org.apache.activemq.artemis.core.persistence.impl.journal with parameters of type IOCallback

Modifier and Type	Method	Description
void	AbstractJournalStorageManager.afterCompleteOperations(IOCallback run)
void	AbstractJournalStorageManager.afterStoreOperations(IOCallback run)
void	DummyOperationContext.executeOnCompletion(IOCallback runnable)
void	DummyOperationContext.executeOnCompletion(IOCallback runnable, boolean storeOnly)
void	OperationContextImpl.executeOnCompletion(IOCallback runnable)
void	OperationContextImpl.executeOnCompletion(IOCallback completion, boolean storeOnly)

Uses of IOCallback in org.apache.activemq.artemis.core.persistence.impl.nullpm

Methods in org.apache.activemq.artemis.core.persistence.impl.nullpm with parameters of type IOCallback

Modifier and Type	Method	Description
void	NullStorageManager.afterCompleteOperations(IOCallback run)
void	NullStorageManager.afterStoreOperations(IOCallback run)

Uses of IOCallback in org.apache.activemq.artemis.core.server

Methods in org.apache.activemq.artemis.core.server with parameters of type IOCallback

Modifier and Type	Method	Description
void	ActiveMQServerLogger_$logger.pageSubscriptionError(IOCallback IOCallback, String error)
void	ActiveMQServerLogger.pageSubscriptionError(IOCallback IOCallback, String error)

Uses of IOCallback in org.apache.activemq.artemis.jdbc.store.file

Methods in org.apache.activemq.artemis.jdbc.store.file with parameters of type IOCallback

Modifier and Type	Method	Description
int	JDBCSequentialFile.internalWrite(ActiveMQBuffer buffer, IOCallback callback)
int	JDBCSequentialFile.internalWrite(ActiveMQBuffer buffer, IOCallback callback, boolean append)
int	JDBCSequentialFile.read(ByteBuffer bytes, IOCallback callback)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback, boolean append)
void	JDBCSequentialFile.write(EncodingSupport bytes, boolean sync, IOCallback callback)
void	JDBCSequentialFile.writeDirect(ByteBuffer bytes, boolean sync, IOCallback callback)