diff --git a/classes/AMQPChannel.html b/classes/AMQPChannel.html index 3882c2b..b0122d7 100644 --- a/classes/AMQPChannel.html +++ b/classes/AMQPChannel.html @@ -24,7 +24,7 @@

Hierarchy

+
  • Defined in src/amqp-channel.ts:12
    • @@ -109,44 +109,44 @@
    id: Returns AMQPChannel
    +
  • Defined in src/amqp-channel.ts:28

    • Properties

    closed

    closed: boolean = false
    +
  • Defined in src/amqp-channel.ts:18

    • confirmId

    confirmId: number = 0
    +
  • Defined in src/amqp-channel.ts:19

    • Readonly connection

    connection: AMQPBaseClient
    +
  • Defined in src/amqp-channel.ts:13

    • Readonly consumers

    consumers: Map<string, AMQPConsumer> = ...
    +
  • Defined in src/amqp-channel.ts:15

    • Optional delivery

    delivery?: AMQPMessage
    +
  • Defined in src/amqp-channel.ts:20

    • Optional getMessage

    getMessage?: AMQPMessage
    +
  • Defined in src/amqp-channel.ts:21

    • Readonly id

    id: number
    +
  • Defined in src/amqp-channel.ts:14

    • onerror

    onerror: ((reason) => void)
    @@ -164,22 +164,22 @@

    Parameters

    reason: string

    Returns void

    +
  • Defined in src/amqp-channel.ts:23

    • Optional returned

    returned?: AMQPMessage
    +
  • Defined in src/amqp-channel.ts:22

    • Private rpcQueue

    rpcQueue: Promise<unknown> = ...
    +
  • Defined in src/amqp-channel.ts:16

    • Private Readonly unconfirmedPublishes

    unconfirmedPublishes: [number, ((confirmId) => void), ((err?) => void)][] = []
    +
  • Defined in src/amqp-channel.ts:17

    • Accessors

    @@ -189,7 +189,7 @@

    Private

  • Returns undefined | null | Logger

    • +
  • Defined in src/amqp-channel.ts:34

    • Methods

    @@ -215,7 +215,7 @@
    Optional Returns Promise<void>
    +
  • Defined in src/amqp-channel.ts:204

    • basicCancel

    +
  • Defined in src/amqp-channel.ts:172

    • basicConsume

    +
  • Defined in src/amqp-channel.ts:135

    • basicFlow

    +
  • Defined in src/amqp-channel.ts:405

    • basicGet

    +
  • Defined in src/amqp-channel.ts:108

    • basicNack

    +
  • Defined in src/amqp-channel.ts:225

    • basicPublish

    +
  • Defined in src/amqp-channel.ts:291

    • basicQos

    +
  • Defined in src/amqp-channel.ts:384

    • basicRecover

    +
  • Defined in src/amqp-channel.ts:267

    • basicReject

    +
  • Defined in src/amqp-channel.ts:248

    • close

    +
  • Defined in src/amqp-channel.ts:82

    • confirmSelect

    +
  • Defined in src/amqp-channel.ts:422

    • exchangeBind

    +
  • Defined in src/amqp-channel.ts:652

    • exchangeDeclare

    +
  • Defined in src/amqp-channel.ts:592

    • exchangeDelete

    +
  • Defined in src/amqp-channel.ts:624

    • exchangeUnbind

    +
  • Defined in src/amqp-channel.ts:680

    • onReturn

    +
  • Defined in src/amqp-channel.ts:74

    • open

    +
  • Defined in src/amqp-channel.ts:38

    • prefetch

    +
  • Defined in src/amqp-channel.ts:66

    • queue

    +
  • Defined in src/amqp-channel.ts:54

    • queueBind

    +
  • Defined in src/amqp-channel.ts:509

    • queueDeclare

    +
  • Defined in src/amqp-channel.ts:447

    • queueDelete

    +
  • Defined in src/amqp-channel.ts:479

    • queuePurge

    +
  • Defined in src/amqp-channel.ts:562

    • queueUnbind

    +
  • Defined in src/amqp-channel.ts:538

    • Private rejectClosed

    +
  • Defined in src/amqp-channel.ts:780

    • Private sendRpc

    +
  • Defined in src/amqp-channel.ts:741

    • txCommit

    +
  • Defined in src/amqp-channel.ts:711

    • Private txMethod

    Returns Promise<void>

    +
  • Defined in src/amqp-channel.ts:722

    • txRollback

    +
  • Defined in src/amqp-channel.ts:718

    • txSelect

    +
  • Defined in src/amqp-channel.ts:704
    • diff --git a/classes/AMQPClient.html b/classes/AMQPClient.html index 623c32d..8e27085 100644 --- a/classes/AMQPClient.html +++ b/classes/AMQPClient.html @@ -26,7 +26,7 @@

    Hierarchy

    • AMQPClient
    +
  • Defined in src/amqp-socket-client.ts:12
    • @@ -97,7 +97,7 @@

    Returns

    +
  • Defined in src/amqp-socket-client.ts:26

    • Properties

    @@ -105,25 +105,25 @@

    Optionalblocked?: string

    +
  • Defined in src/amqp-base-client.ts:24

    • Readonly bufferPool

    bufferPool: AMQPView[] = []
    +
  • Defined in src/amqp-base-client.ts:33

    • channelMax

    channelMax: number = 0
    +
  • Defined in src/amqp-base-client.ts:25

    • channels

    channels: AMQPChannel[]
    +
  • Defined in src/amqp-base-client.ts:19

    • Protected Optional closePromise

    closePromise?: [((value?) => void), ((err) => void)]
    @@ -155,13 +155,13 @@
    err: Returns void
    +
  • Defined in src/amqp-base-client.ts:21

    • closed

    closed: boolean = true
    +
  • Defined in src/amqp-base-client.ts:23

    • Protected Optional connectPromise

    connectPromise?: [((conn) => void), ((err) => void)]
    @@ -193,56 +193,56 @@
    err: Returns void
    +
  • Defined in src/amqp-base-client.ts:20

    • Private Readonly frameBuffer

    frameBuffer: Buffer
    +
  • Defined in src/amqp-socket-client.ts:21

    • frameMax

    frameMax: number
    +
  • Defined in src/amqp-base-client.ts:26

    • Private framePos

    framePos: number
    +
  • Defined in src/amqp-socket-client.ts:19

    • Private frameSize

    frameSize: number
    +
  • Defined in src/amqp-socket-client.ts:20

    • heartbeat

    heartbeat: number
    +
  • Defined in src/amqp-base-client.ts:27

    • Readonly host

    host: string
    +
  • Defined in src/amqp-socket-client.ts:15

    • Private Readonly insecure

    insecure: boolean
    +
  • Defined in src/amqp-socket-client.ts:18

    • logger

    logger: undefined | null | Logger = console
    +
  • Defined in src/amqp-base-client.ts:29

    • Optional name

    name?: string
    +
  • Defined in src/amqp-base-client.ts:17

    • Protected Optional onUpdateSecretOk

    onUpdateSecretOk?: ((value?) => void)
    @@ -261,7 +261,7 @@
    Optional Returns void
    +
  • Defined in src/amqp-base-client.ts:22

    • onerror

    onerror: ((error) => void)
    @@ -280,29 +280,29 @@
    error: Returns void
    +
  • Defined in src/amqp-base-client.ts:28

    • password

    password: string
    +
  • Defined in src/amqp-base-client.ts:16

    • Optional platform

    platform?: string
    +
  • Defined in src/amqp-base-client.ts:18

    • Readonly port

    port: number
    +
  • Defined in src/amqp-socket-client.ts:16

    • Optional socket

    socket?: Socket
    +
  • Defined in src/amqp-socket-client.ts:13

    • Readonly textEncoder

    textEncoder: TextEncoder = ...
    @@ -311,29 +311,29 @@

    Readonly

    +
  • Defined in src/amqp-base-client.ts:31

    • Readonly tls

    tls: boolean
    +
  • Defined in src/amqp-socket-client.ts:14

    • Readonly tlsOptions

    tlsOptions: undefined | AMQPTlsOptions
    +
  • Defined in src/amqp-socket-client.ts:17

    • username

    username: string
    +
  • Defined in src/amqp-base-client.ts:15

    • vhost

    vhost: string
    +
  • Defined in src/amqp-base-client.ts:14

    • Methods

    @@ -355,7 +355,7 @@

    Returns Promise<

    +
  • Defined in src/amqp-base-client.ts:63

    • close

    +
  • Defined in src/amqp-base-client.ts:85

    • Protected closeSocket

    +
  • Defined in src/amqp-socket-client.ts:161

    • connect

    +
  • Defined in src/amqp-socket-client.ts:50

    • Private connectSocket

    +
  • Defined in src/amqp-socket-client.ts:72

    • Private onRead

    Returns boolean

    +
  • Defined in src/amqp-socket-client.ts:92

    • updateSecret

    +
  • Defined in src/amqp-base-client.ts:108
    • diff --git a/classes/AMQPConsumer.html b/classes/AMQPConsumer.html index 3fc43f7..2596a91 100644 --- a/classes/AMQPConsumer.html +++ b/classes/AMQPConsumer.html @@ -24,7 +24,7 @@

    Hierarchy

    • AMQPConsumer
    +
  • Defined in src/amqp-consumer.ts:8
    • @@ -89,24 +89,24 @@

    Returns voidReturns AMQPConsumer

    +
  • Defined in src/amqp-consumer.ts:23

    • Properties

    Readonly channel

    channel: AMQPChannel
    +
  • Defined in src/amqp-consumer.ts:9

    • Private closed

    closed: boolean = false
    +
  • Defined in src/amqp-consumer.ts:12

    • Private Optional closedError

    closedError?: Error
    +
  • Defined in src/amqp-consumer.ts:13

    • Readonly onMessage

    onMessage: ((msg) => void)
    @@ -124,7 +124,7 @@

    Parameters

    msg: AMQPMessage

    Returns void

    +
  • Defined in src/amqp-consumer.ts:11

    • Private Optional rejectWait

    rejectWait?: ((err) => void)
    @@ -142,7 +142,7 @@

    Parameters

    err: Error

    Returns void

    +
  • Defined in src/amqp-consumer.ts:15

    • Private Optional resolveWait

    resolveWait?: ((value) => void)
    @@ -160,17 +160,17 @@

    Parameters

    value: void

    Returns void

    +
  • Defined in src/amqp-consumer.ts:14

    • Readonly tag

    tag: string
    +
  • Defined in src/amqp-consumer.ts:10

    • Private Optional timeoutId

    timeoutId?: Timeout
    +
  • Defined in src/amqp-consumer.ts:16

    • Methods

    @@ -184,7 +184,7 @@

    cancelReturns Promise<AMQPChannel>

    +
  • Defined in src/amqp-consumer.ts:51

    • wait

    +
  • Defined in src/amqp-consumer.ts:34
    • diff --git a/classes/AMQPError.html b/classes/AMQPError.html index 8f690b4..5b1a646 100644 --- a/classes/AMQPError.html +++ b/classes/AMQPError.html @@ -26,7 +26,7 @@

    Hierarchy

    • AMQPError
    +
  • Defined in src/amqp-error.ts:8
    • @@ -73,7 +73,7 @@

    Returns

    +
  • Defined in src/amqp-error.ts:14

    • Properties

    @@ -83,7 +83,7 @@

    connection

    +
  • Defined in src/amqp-error.ts:9

    • message

    message: string
    diff --git a/classes/AMQPMessage.html b/classes/AMQPMessage.html index cdc0558..e76b71d 100644 --- a/classes/AMQPMessage.html +++ b/classes/AMQPMessage.html @@ -24,7 +24,7 @@

    Hierarchy

    • AMQPMessage
    +
  • Defined in src/amqp-message.ts:19
    • @@ -77,7 +77,7 @@
    channel: Returns AMQPMessage
    +
  • Defined in src/amqp-message.ts:37

    • Properties

    @@ -87,12 +87,12 @@

    body

    +
  • Defined in src/amqp-message.ts:25

    • bodyPos

    bodyPos: number = 0
    +
  • Defined in src/amqp-message.ts:26

    • bodySize

    bodySize: number = 0
    @@ -100,7 +100,7 @@

    bodySize

    +
  • Defined in src/amqp-message.ts:24

    • channel

    channel: AMQPChannel
    @@ -108,7 +108,7 @@

    channel

    +
  • Defined in src/amqp-message.ts:20

    • consumerTag

    consumerTag: string = ""
    @@ -116,7 +116,7 @@

    consumerTag

    +
  • Defined in src/amqp-message.ts:28

    • deliveryTag

    deliveryTag: number = 0
    @@ -124,7 +124,7 @@

    deliveryTag

    +
  • Defined in src/amqp-message.ts:27

    • exchange

    exchange: string = ""
    @@ -132,7 +132,7 @@

    exchange

    +
  • Defined in src/amqp-message.ts:21

    • Optional messageCount

    messageCount?: number
    @@ -140,7 +140,7 @@

    Optional

    +
  • Defined in src/amqp-message.ts:30

    • properties

    properties: AMQPProperties = {}
    @@ -148,7 +148,7 @@

    properties

    +
  • Defined in src/amqp-message.ts:23

    • redelivered

    redelivered: boolean = false
    @@ -156,7 +156,7 @@

    redelivered

    +
  • Defined in src/amqp-message.ts:29

    • Optional replyCode

    replyCode?: number
    @@ -164,7 +164,7 @@

    Optional

    +
  • Defined in src/amqp-message.ts:31

    • Optional replyText

    replyText?: string
    @@ -172,7 +172,7 @@

    Optional

    +
  • Defined in src/amqp-message.ts:32

    • routingKey

    routingKey: string = ""
    @@ -180,7 +180,7 @@

    routingKey

    +
  • Defined in src/amqp-message.ts:22

    • Methods

    @@ -198,7 +198,7 @@
    multiple: Returns Promise<void>
    +
  • Defined in src/amqp-message.ts:60

    • bodyString

    +
  • Defined in src/amqp-message.ts:55

    • bodyToString

    +
  • Defined in src/amqp-message.ts:44

    • cancelConsumer

    +
  • Defined in src/amqp-message.ts:75

    • nack

    +
  • Defined in src/amqp-message.ts:65

    • reject

    +
  • Defined in src/amqp-message.ts:70
    • diff --git a/classes/AMQPQueue.html b/classes/AMQPQueue.html index 313ddad..0475c7f 100644 --- a/classes/AMQPQueue.html +++ b/classes/AMQPQueue.html @@ -24,7 +24,7 @@

    Hierarchy

    • AMQPQueue
    +
  • Defined in src/amqp-queue.ts:9
    • @@ -73,19 +73,19 @@
    name: Returns AMQPQueue
    +
  • Defined in src/amqp-queue.ts:16

    • Properties

    Readonly channel

    channel: AMQPChannel
    +
  • Defined in src/amqp-queue.ts:10

    • Readonly name

    name: string
    +
  • Defined in src/amqp-queue.ts:11

    • Methods

    @@ -108,7 +108,7 @@
    args: Returns Promise<AMQPQueue>
    +
  • Defined in src/amqp-queue.ts:24

    • delete

    +
  • Defined in src/amqp-queue.ts:85

    • get

    +
  • Defined in src/amqp-queue.ts:98

    • publish

    +
  • Defined in src/amqp-queue.ts:49

    • purge

    +
  • Defined in src/amqp-queue.ts:102

    • subscribe

    +
  • Defined in src/amqp-queue.ts:66

    • unbind

    +
  • Defined in src/amqp-queue.ts:35

    • unsubscribe

    +
  • Defined in src/amqp-queue.ts:74
    • diff --git a/classes/AMQPWebSocketClient.html b/classes/AMQPWebSocketClient.html index 5d4a5be..bc2bc46 100644 --- a/classes/AMQPWebSocketClient.html +++ b/classes/AMQPWebSocketClient.html @@ -26,7 +26,7 @@

    Hierarchy

    • AMQPWebSocketClient
    +
  • Defined in src/amqp-websocket-client.ts:18
    • @@ -104,7 +104,7 @@

    Returns

    +
  • Defined in src/amqp-websocket-client.ts:28
  • @@ -115,7 +115,7 @@
    init: Returns AMQPWebSocketClient
    • +
  • Defined in src/amqp-websocket-client.ts:29

    • Properties

    @@ -123,25 +123,25 @@

    Optionalblocked?: string

    +
  • Defined in src/amqp-base-client.ts:24

    • Readonly bufferPool

    bufferPool: AMQPView[] = []
    +
  • Defined in src/amqp-base-client.ts:33

    • channelMax

    channelMax: number = 0
    +
  • Defined in src/amqp-base-client.ts:25

    • channels

    channels: AMQPChannel[]
    +
  • Defined in src/amqp-base-client.ts:19

    • Protected Optional closePromise

    closePromise?: [((value?) => void), ((err) => void)]
    @@ -173,13 +173,13 @@
    err: Returns void
    +
  • Defined in src/amqp-base-client.ts:21

    • closed

    closed: boolean = true
    +
  • Defined in src/amqp-base-client.ts:23

    • Protected Optional connectPromise

    connectPromise?: [((conn) => void), ((err) => void)]
    @@ -211,46 +211,46 @@
    err: Returns void
    +
  • Defined in src/amqp-base-client.ts:20

    • Private frameBuffer

    frameBuffer: Uint8Array
    +
  • Defined in src/amqp-websocket-client.ts:23

    • frameMax

    frameMax: number
    +
  • Defined in src/amqp-base-client.ts:26

    • Private framePos

    framePos: number = 0
    +
  • Defined in src/amqp-websocket-client.ts:21

    • Private frameSize

    frameSize: number = 0
    +
  • Defined in src/amqp-websocket-client.ts:22

    • heartbeat

    heartbeat: number
    +
  • Defined in src/amqp-base-client.ts:27

    • logger

    logger: undefined | null | Logger = console
    +
  • Defined in src/amqp-base-client.ts:29

    • Optional name

    name?: string
    +
  • Defined in src/amqp-base-client.ts:17

    • Protected Optional onUpdateSecretOk

    onUpdateSecretOk?: ((value?) => void)
    @@ -269,7 +269,7 @@
    Optional Returns void
    +
  • Defined in src/amqp-base-client.ts:22

    • onerror

    onerror: ((error) => void)
    @@ -288,24 +288,24 @@
    error: Returns void
    +
  • Defined in src/amqp-base-client.ts:28

    • password

    password: string
    +
  • Defined in src/amqp-base-client.ts:16

    • Optional platform

    platform?: string
    +
  • Defined in src/amqp-base-client.ts:18

    • Private Optional socket

    socket?: WebSocket
    +
  • Defined in src/amqp-websocket-client.ts:20

    • Readonly textEncoder

    textEncoder: TextEncoder = ...
    @@ -314,24 +314,24 @@

    Readonly

    +
  • Defined in src/amqp-base-client.ts:31

    • Readonly url

    url: string
    +
  • Defined in src/amqp-websocket-client.ts:19

    • username

    username: string
    +
  • Defined in src/amqp-base-client.ts:15

    • vhost

    vhost: string
    +
  • Defined in src/amqp-base-client.ts:14

    • Methods

    @@ -353,7 +353,7 @@

    Returns Promise<

    +
  • Defined in src/amqp-base-client.ts:63

    • close

    +
  • Defined in src/amqp-base-client.ts:85

    • Protected closeSocket

    +
  • Defined in src/amqp-websocket-client.ts:84

    • connect

    +
  • Defined in src/amqp-websocket-client.ts:48

    • Private handleMessage

      @@ -409,7 +409,7 @@

      Parameters

      event: MessageEvent<any>

    Returns void

    +
  • Defined in src/amqp-websocket-client.ts:90

    • send

    +
  • Defined in src/amqp-websocket-client.ts:68

    • updateSecret

      @@ -444,7 +444,7 @@
      reason: Returns Promise<unknown>
    +
  • Defined in src/amqp-base-client.ts:108

    • Static platform

    +
  • Defined in src/amqp-websocket-client.ts:141
    • diff --git a/types/AMQPProperties.html b/types/AMQPProperties.html index 32afcb8..644b1c5 100644 --- a/types/AMQPProperties.html +++ b/types/AMQPProperties.html @@ -73,7 +73,7 @@
    Optional
    Optional userId?: string
    +
  • Defined in src/amqp-properties.ts:1
    • diff --git a/types/AMQPTlsOptions.html b/types/AMQPTlsOptions.html index d513446..9ac466c 100644 --- a/types/AMQPTlsOptions.html +++ b/types/AMQPTlsOptions.html @@ -33,7 +33,7 @@

    Passphrase

    Shared passphrase used for a single private key and/or a P

    Ca

    Optionally override the trusted CA certificates. Default is to trust the well-known CAs curated by Mozilla.

    +
  • Defined in src/amqp-tls-options.ts:13
    • diff --git a/types/ConsumeParams.html b/types/ConsumeParams.html index b665742..df8d263 100644 --- a/types/ConsumeParams.html +++ b/types/ConsumeParams.html @@ -40,7 +40,7 @@
    Optional
    +
  • Defined in src/amqp-channel.ts:911
    • diff --git a/types/ExchangeParams.html b/types/ExchangeParams.html index a4d28b4..f54b64b 100644 --- a/types/ExchangeParams.html +++ b/types/ExchangeParams.html @@ -40,7 +40,7 @@
    Optional
    +
  • Defined in src/amqp-channel.ts:868
    • diff --git a/types/Field.html b/types/Field.html index 7ee5f18..0a2318f 100644 --- a/types/Field.html +++ b/types/Field.html @@ -17,7 +17,7 @@

    Type alias Field

    Field: string | boolean | bigint | number | undefined | null | object
    +
  • Defined in src/amqp-properties.ts:26
    • diff --git a/types/MessageCount.html b/types/MessageCount.html index b2bcae2..c5dec17 100644 --- a/types/MessageCount.html +++ b/types/MessageCount.html @@ -22,7 +22,7 @@

    Type declaration

  • messageCount: number
    • +
  • Defined in src/amqp-channel.ts:862
    • diff --git a/types/QueueOk.html b/types/QueueOk.html index e416f51..2165761 100644 --- a/types/QueueOk.html +++ b/types/QueueOk.html @@ -26,7 +26,7 @@
    messageCount
    name: string
    +
  • Defined in src/amqp-channel.ts:856
    • diff --git a/types/QueueParams.html b/types/QueueParams.html index cbe89d2..2735041 100644 --- a/types/QueueParams.html +++ b/types/QueueParams.html @@ -40,7 +40,7 @@
    Optional
    +
  • Defined in src/amqp-channel.ts:887