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
final class	DelegateCallback	It is a utility class to allow several IOCallbacks to be used as one.
class	DummyCallback

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)	Read the file.
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
void	AbstractSequentialFile.LocalBufferObserver.checkSync(boolean syncRequested, List<IOCallback> callbacks)
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)
static DelegateCallback	DelegateCallback.wrap(Collection<? extends IOCallback> 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
default void	TimedBufferObserver.checkSync(boolean syncRequested, List<IOCallback> callbacks)
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.

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	JournalTransaction
final class	SimpleWaitIOCallback
class	SyncIOCompletion	Internal class used to manage explicit syncs on the Journal through callbacks.

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

Modifier and Type	Method	Description
IOCallback	JournalTransaction.getDelegateCompletion()

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

Modifier and Type	Method	Description
void	JournalTransaction.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.afterCompleteOperations(IOCallback run, OperationConsistencyLevel consistencyLevel)
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, OperationConsistencyLevel consistencyLevel)	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
final 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.afterCompleteOperations(IOCallback run, OperationConsistencyLevel consistencyLevel)
void	AbstractJournalStorageManager.afterStoreOperations(IOCallback run)
void	DummyOperationContext.executeOnCompletion(IOCallback runnable)
void	DummyOperationContext.executeOnCompletion(IOCallback runnable, OperationConsistencyLevel consistencyLevel)
void	OperationContextImpl.executeOnCompletion(IOCallback runnable)
void	OperationContextImpl.executeOnCompletion(IOCallback completion, OperationConsistencyLevel consistencyLevel)

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.afterCompleteOperations(IOCallback run, OperationConsistencyLevel consistencyLevel)
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_impl.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.jdbcWrite(ActiveMQBuffer buffer, IOCallback callback)
int	JDBCSequentialFile.jdbcWrite(ActiveMQBuffer buffer, IOCallback callback, boolean append)
int	JDBCSequentialFile.read(ByteBuffer bytes, IOCallback callback)
void	JDBCSequentialFile.sendToDB(ActiveMQBuffer bytes, IOCallback callback, boolean append)
void	JDBCSequentialFile.write(ActiveMQBuffer bytes, boolean sync, IOCallback callback)
void	JDBCSequentialFile.write(EncodingSupport bytes, boolean sync, IOCallback callback)
void	JDBCSequentialFile.writeDirect(ByteBuffer bytes, boolean sync, IOCallback callback)

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

Modifier	Constructor	Description
	ScheduledWrite(ByteBuffer ioBuffer, IOCallback callback, boolean append)
	ScheduledWrite(ActiveMQBuffer amqBuffer, IOCallback callback, boolean append)
	ScheduledWrite(IOCallback callback)