Package org.redisson.api

Interface SyncArgs<T>

Type Parameters:
T - type
All Known Subinterfaces:
FailedAckArgs, FanoutPublishArgs<V>, QueueAckArgs, QueueAddArgs<V>, QueueMoveArgs, QueueNegativeAckArgs, QueuePollArgs, QueueRemoveArgs
All Known Implementing Classes:
BaseSyncParams, FanoutPublishParams, QueueAckParams, QueueAddParams, QueueMoveParams, QueueNegativeAckParams, QueuePollParams, QueueRemoveParams
public interface SyncArgs<T>
Interface defining parameters for queue synchronization. These parameters control how queue operations are synchronized with secondary Valkey or Redis nodes.
Author:
Nikita Koksharov

  • Method Summary

    Modifier and Type
    Method
    Description
    T
    syncFailureMode(SyncFailureMode syncFailureMode)
    Sets the behavior when synchronization with secondary nodes fails.
    T
    syncMode(SyncMode syncMode)
    Sets the synchronization mode to be used for current operation.
    T
    syncTimeout(Duration timeout)
    Sets the timeout duration for synchronization of the current operation.

  • Method Details

    • syncMode

      T syncMode(SyncMode syncMode)
      Sets the synchronization mode to be used for current operation.

      Default value is SyncMode.AUTO

      Parameters:
      syncMode - the synchronization mode
      Returns:
      arguments object
      See Also:

    • syncFailureMode

      T syncFailureMode(SyncFailureMode syncFailureMode)
      Sets the behavior when synchronization with secondary nodes fails.

      Default value is SyncFailureMode.LOG_WARNING

      Parameters:
      syncFailureMode - the failure handling mode
      Returns:
      The current instance for method chaining
      See Also:

    • syncTimeout

      T syncTimeout(Duration timeout)
      Sets the timeout duration for synchronization of the current operation. Defines how long the system will wait for acknowledgment from secondary nodes.

      Default value is 1 second.

      Parameters:
      timeout - The maximum time to wait for synchronization to complete
      Returns:
      arguments object