ClusterStorage - appendMessage

Exception (generic)

Any error during message processing

Logged as warning, not rethrown

exception while appending to cluster storage with message: {}

Any runtime exception during message append (e.g., parsing, publishing) is logged and ignored.

ClusterStorage - retrieveMessages (private)

IOException

Message count mismatch, null/empty collection

Thrown to caller

unable to recover part or whole message range for sessionId:  + sessionId

If retrieved messages are missing or incomplete, an IOException is thrown.

ClusterStorage - retrieveMessages (private)

None

Skipping null/zero message

Logged as debug

retrieveMessages skipping message (null or zero) for sessionId: {}, from: {}, to: {}

Messages that are null or empty are skipped and logged for debugging.

ClusterStorage - backupStorage

None

No backup mode matched

No log

(No explicit log message)

No error or log if backup mode is not matched.

ClusterStorage - close

None

Double-close

Logged as debug

cluster storage for sessionId: {} already closed

Attempting to close an already closed storage is logged but not treated as an error.

ClusterStorage - close

None

Closing storage

Logged as debug

closing cluster storage for sessionId: {} and epoch: {}

Storage close operation is logged for traceability.

NoDataClusterStorage - appendMessage

Exception (generic)

Any error during message processing

Logged as warning, not rethrown

exception while appending to cluster storage with message: {}

Any runtime exception during message append is logged and ignored.

NoDataClusterStorage - constructor

None

Creation of storage

Logged as debug

NoDataClusterStorage created for sessionId: {}

Storage creation is logged for traceability.

ClusterStorageFactory - createFOMessageFilter / getFOMessageFilterInstance

ClassNotFoundException

Filter class not found

Logged as warning

class {} not found

If the filter class is missing, a warning is logged and no filter is used.

ClusterStorageFactory - getFOMessageFilterInstance

NoSuchMethodException

Constructor not found

Logged as info

class {} constructor with parameters {} not found

If the expected constructor is missing, info is logged and instantiation is skipped.

ClusterStorageFactory - getFOMessageFilterInstance

IllegalAccessException, IllegalArgumentException, InvocationTargetException

Constructor with args not found

Logged as info

class {} constructor with args {} not found

If constructor invocation fails, info is logged and instantiation is skipped.

ClusterStorageFactory - getFOMessageFilterInstance

SecurityException, InstantiationException

Instantiation failed

Logged as warning

instance of class {} with parameters {} and args {} cannot be instantiated

If instantiation fails, a warning is logged and no filter is used.

ClusterStorageFactory - saveSessionParameters

Exception (generic)

Property conversion or publisher failure

Logged as warning, not rethrown

unable to publish session parameters with message: {}

Any error during session parameter save is logged and ignored.

ClusterStorageFactory - saveSessionParameters

None

Publisher not available

Logged as warning

unable to publish session parameters as publisher not available with result: {}

If publisher is unavailable, a warning is logged.

ClusterStorageFactory - loadSessionParameters

Exception (generic)

Storage client or property conversion failure

Logged as warning, returns false

unable to load session parameters with message: {}

Any error during session parameter load is logged and returns false.

ClusterStorageFactory - getQueue

None

FOClientContext not ready

Logged as warning

falling back on persistent queue as fo-client context is not ready

If client context is not ready, falls back to persistent queue and logs a warning.

ClusterStorageFactory - getQueue

None

Creating queue

Logged as debug

creating clustered queue for sessionId: {}

Queue creation is logged for traceability.

ClusterStorageFactory - getOutgoingQueueFileName

None

No error handled

No log

(No explicit log message)

No error or log for queue file name generation.

ClusterInMemoryQueue - tryGetQueueMessage

Exception (generic)

Storage client failure, network issues

Logged as warning, returns null

unable to load queued messages with message: {} with useInMemoryQueueOnRemoteRecoveryFailure set to {}

Any error during queue message retrieval is logged and returns null.

ClusterInMemoryQueue - add

IllegalStateException

Queue is shutdown

Logged as warning, thrown

queue shutdown, skip entry: {}

Adding to a shutdown queue throws an exception and logs a warning.

ClusterInMemoryQueue - add / publishMessageInBuffer

Exception (generic)

Publisher failure, serialization issues

Logged as warning, returns -1

e.getMessage() (exception message)

Any error during publishing is logged and returns -1.

ClusterInMemoryQueue - add

None

Unable to publish event

Logged as warning

unable to publish event to cluster queue for sessionID: {}

If publishing fails, a warning is logged.

ClusterInMemoryQueue - clear

None

Unable to publish clear message

Logged as warning if result = 0

unable to publish clear queue message for sessionID: {}

If publishing clear fails, a warning is logged.

ClusterInMemoryQueue - clear

None

Clearing queue

Logged as debug

clear called for sessionID: {}

Queue clear operation is logged for traceability.

ClusterInMemoryQueue - commit

None

Sending REMOVE operation

Logged as debug

sending QueueOperation.REMOVE for sessionID: {} and before commit queue size: {}

REMOVE operation is logged for traceability.

ClusterInMemoryQueue - commit

None

Commit ignored

Logged as debug

commit ignored (zero size queue or session message) for sessionID: {}

If commit is ignored, it is logged for debugging.

ClusterInMemoryQueue - initialize

None

Queue initialization called

Logged as debug

initializing queue for sessionID: {} / "existing queue size before clear: {}"

Queue initialization is logged for traceability.

ClusterInMemoryQueue - restoreMessages

None

Messages recovered

Logged as debug

queue messages returned from storage for sessionId: {}, quantity: {} / "queue messages recovered from storage for session: {}, quantity: {}" / "no queue messages returned from storage for session: {}"

Message restoration is logged for debugging.

ClusterInMemoryQueue - addOutOfTurn

None

Adding out of turn

Logged as debug

addOutOfTurn called for sessionID: {} with message: {}

Out-of-turn addition is logged for debugging.

ClusterInMemoryQueue - poll

None

Polling queue

Logged as debug

poll called for sessionID: {} with message: {}

Poll operation is logged for debugging.

MultiMessageStorage - constructor

IllegalStateException

No primary storage configured

Logged as error, thrown

primary storage must be configured

If no primary storage is configured, an error is logged and exception is thrown.

MultiMessageStorage - initialize (per storage)

Exception (generic)

Storage initialization failure

Logged as error, returns null

initialisation error for storage: {} with message: {}

Any error during storage initialization is logged and returns null.

MultiMessageStorage - initialize (primary)

None

Primary returned null

Logged as warning

initialisation of primary storage: {} returned null - trying secondary storages

If primary initialization fails, a warning is logged and secondary storages are tried.

MultiMessageStorage - initialize (secondary)

None

Secondary returned null

Logged as warning

initialisation of secondary storage: {} returned null

If secondary initialization fails, a warning is logged.

MultiMessageStorage - initialize (secondary)

None

Using secondary result

Logged as info

using secondary storage: {} initialisation result (seqNum): {}

If secondary initialization succeeds, info is logged.

MultiMessageStorage - initialize (final result)

IOException

All storages failed to initialize

Logged as error, thrown

unable to initialize MultiMessageStorage

If all storages fail to initialize, an error is logged and exception is thrown.

MultiMessageStorage - appendMessage (all overloads)

IOException

All storages failed to append message

Logged as warning, thrown

failed to append message to all of the configured storages / "failed to append message to any of the configured storages"

If all storages fail to append, a warning is logged and exception is thrown.

MultiMessageStorage - appendMessage (per storage)

IOException

Individual storage append failure

Logged as warning, continues

e.getMessage() (exception message)

If a storage fails to append, a warning is logged and others are tried.

MultiMessageStorage - retrieveMessage (per storage)

Exception (generic)

Individual storage retrieval failure

Logged as error, returns null

retrieveMessage error with message: {}

Any error during message retrieval is logged and returns null.

MultiMessageStorage - retrieveMessage (per storage)

IOException

All storages failed to retrieve

Logged as error, thrown

no message retrieved from primary storage

If all storages fail to retrieve, a warning is logged and exception is thrown.

MultiStorageFactory - getQueue

None

In-memory queue enabled

Logged as debug

creating in memory queue as enabled in configuration

In-memory queue creation is logged for debugging.

MultiStorageFactory - getQueue

None

Creating queue for primary storage

Logged as debug

creating queue for primary storage: {}

Queue creation for primary storage is logged for debugging.

MultiStorageFactory - getQueue

None

Service queue not enabled on primary

Logged as warning

service queue is not enabled on primary storage: {}

If service queue is not enabled, a warning is logged.

MultiStorageFactory - getQueue

None

Creating queue for secondary storage

Logged as warning

creating queue for secondary storage: {}

Queue creation for secondary storage is logged for debugging.

MultiStorageFactory - getQueue

None

No service queue found

Logged as warning

no storage factories entries with enabled service queue found (invalid configuration)

If no service queue is found, a warning is logged.

MultiStorageFactory - getPrimaryStorageFactory

IllegalStateException

No primary storage found

Not logged, thrown

(No explicit log message)

If no primary storage is found, an exception is thrown.