@Operator(group="io") public final class QueueClose extends PrimitiveOp
This operation signals that no more elements will be enqueued in the given queue. Subsequent Enqueue(Many) operations will fail. Subsequent Dequeue(Many) operations will continue to succeed if sufficient elements remain in the queue. Subsequent Dequeue(Many) operations that would block will fail immediately.
Modifier and Type | Class and Description |
---|---|
static class |
QueueClose.Options
Optional attributes for
QueueClose |
operation
Modifier and Type | Method and Description |
---|---|
static QueueClose.Options |
cancelPendingEnqueues(Boolean cancelPendingEnqueues) |
static QueueClose |
create(Scope scope,
Operand<?> handle,
QueueClose.Options... options)
Factory method to create a class wrapping a new QueueClose operation.
|
equals, hashCode, op, toString
public static QueueClose create(Scope scope, Operand<?> handle, QueueClose.Options... options)
scope
- current scopehandle
- The handle to a queue.options
- carries optional attributes valuespublic static QueueClose.Options cancelPendingEnqueues(Boolean cancelPendingEnqueues)
cancelPendingEnqueues
- If true, all pending enqueue requests that are
blocked on the given queue will be canceled.Copyright © 2022. All rights reserved.