Package org.redisson.api.queue

Interface QueueAddArgs<V>

Type Parameters:

V - type

All Superinterfaces:

SyncArgs<QueueAddArgs<V>>

All Known Implementing Classes:

QueueAddParams

public interface QueueAddArgs<V>
extends SyncArgs<QueueAddArgs<V>>

Interface defining parameters for queue addition operations.

Author:

Nikita Koksharov

Method Summary

Modifier and Type	Method	Description
QueueAddArgs<V>	headersCodec(Codec codec)	Sets the codec to be used for encoding and decoding message headers.
static <V> QueueAddArgs<V>	messages(MessageArgs<V>... msgs)	Defines messages to be added.
QueueAddArgs<V>	timeout(Duration value)	Sets the maximum time to wait when adding messages to a full queue with a limited size.

Methods inherited from interface org.redisson.api.SyncArgs

syncFailureMode, syncMode, syncTimeout

Method Details

timeout

QueueAddArgs<V> timeout(Duration value)

Sets the maximum time to wait when adding messages to a full queue with a limited size.

Parameters:

value - the maximum time to wait

Returns:

arguments object

headersCodec

QueueAddArgs<V> headersCodec(Codec codec)

Sets the codec to be used for encoding and decoding message headers.

Parameters:

codec - the codec

Returns:

arguments object

messages

@SafeVarargs
static <V> QueueAddArgs<V> messages(MessageArgs<V>... msgs)

Defines messages to be added.

Parameters:

msgs - The message arguments to be added to the queue

Returns:

arguments object