Options
All
  • Public
  • Public/Protected
  • All
Menu

Class QueueProxy<E>

Type parameters

  • E

Hierarchy

Implements

Index

Constructors

constructor

Properties

Protected client

Protected name

name: string

Protected serviceName

serviceName: string

Methods

add

  • add(item: E): Promise<boolean>

addAll

  • addAll(items: E[]): Promise<boolean>

addItemListener

  • addItemListener(listener: ItemListener<E>, includeValue: boolean): Promise<string>

clear

  • clear(): Promise<void>

contains

  • contains(item: E): Promise<boolean>

containsAll

  • containsAll(items: E[]): Promise<boolean>

destroy

  • destroy(): Promise<void>

drainTo

  • drainTo(arr: E[], maxElements?: number): Promise<number>

Protected encodeInvoke

  • encodeInvoke<T>(codec: any, ...codecArguments: any[]): Promise<T>

Protected encodeInvokeOnAddress

  • encodeInvokeOnAddress<T>(codec: any, address: Address, ...codecArguments: any[]): Promise<T>

Protected encodeInvokeOnKey

  • encodeInvokeOnKey<T>(codec: any, partitionKey: any, ...codecArguments: any[]): Promise<T>
  • Encodes a request from a codec and invokes it on owner node of given key.

    Type parameters

    • T

    Parameters

    • codec: any
    • partitionKey: any
    • Rest ...codecArguments: any[]

    Returns Promise<T>

Protected encodeInvokeOnPartition

  • encodeInvokeOnPartition<T>(codec: any, partitionId: number, ...codecArguments: any[]): Promise<T>
  • Encodes a request from a codec and invokes it on owner node of given partition.

    Type parameters

    • T

    Parameters

    • codec: any
    • partitionId: number
    • Rest ...codecArguments: any[]

    Returns Promise<T>

Protected encodeInvokeOnRandomTarget

  • encodeInvokeOnRandomTarget<T>(codec: any, ...codecArguments: any[]): Promise<T>

Protected getConnectedServerVersion

  • getConnectedServerVersion(): number

getName

  • getName(): string

getPartitionKey

  • getPartitionKey(): string

getServiceName

  • getServiceName(): string

isEmpty

  • isEmpty(): Promise<boolean>

offer

  • offer(item: E, time?: number): Promise<boolean>

peek

  • peek(): Promise<E>

poll

  • poll(time?: number): Promise<E>

Protected postDestroy

  • postDestroy(): Promise<void>

put

  • put(item: E): Promise<void>

remainingCapacity

  • remainingCapacity(): Promise<number>

remove

  • remove(item: E): Promise<boolean>

removeAll

  • removeAll(items: E[]): Promise<boolean>

removeItemListener

  • removeItemListener(registrationId: string): Promise<boolean>

retainAll

  • retainAll(items: E[]): Promise<boolean>

size

  • size(): Promise<number>

take

  • take(): Promise<E>

toArray

  • toArray(): Promise<E[]>

Protected toData

  • toData(object: any): Data

Protected toObject

  • toObject(data: Data): any

Generated using TypeDoc