Package org.redisson.api.queue

Class QueueAddParams<V>

java.lang.Object

org.redisson.api.BaseSyncParams<QueueAddArgs<V>>

org.redisson.api.queue.QueueAddParams<V>

All Implemented Interfaces:

QueueAddArgs<V>, SyncArgs<QueueAddArgs<V>>

public final class QueueAddParams<V>
extends BaseSyncParams<QueueAddArgs<V>>
implements QueueAddArgs<V>

Constructor Summary

Constructors

Constructor	Description
QueueAddParams(MessageArgs<V>... msgs)

Method Summary

Modifier and Type	Method	Description
Codec	getHeadersCodec()
MessageArgs<V>[]	getMsgs()
Duration	getTimeout()
QueueAddArgs<V>	headersCodec(Codec codec)	Sets the codec to be used for encoding and decoding message headers.
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 class org.redisson.api.BaseSyncParams

getSyncFailureMode, getSyncMode, getSyncTimeout, syncFailureMode, syncMode, syncTimeout

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.redisson.api.SyncArgs

syncFailureMode, syncMode, syncTimeout

Constructor Details

QueueAddParams

@SafeVarargs
public QueueAddParams(MessageArgs<V>... msgs)

Method Details

getMsgs

public MessageArgs<V>[] getMsgs()

timeout

public QueueAddArgs<V> timeout(Duration value)

Description copied from interface: QueueAddArgs

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

Specified by:

timeout in interface QueueAddArgs<V>

Parameters:

value - the maximum time to wait

Returns:

arguments object

headersCodec

public QueueAddArgs<V> headersCodec(Codec codec)

Description copied from interface: QueueAddArgs

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

Specified by:

headersCodec in interface QueueAddArgs<V>

Parameters:

codec - the codec

Returns:

arguments object

getHeadersCodec

public Codec getHeadersCodec()

getTimeout

public Duration getTimeout()