AMQPClient | @types/amqp

Hierarchy

Socket
- AMQPClient

Index

Methods

Properties

Readonly bufferSize

bufferSize: number

deprecated: since v14.6.0 - Use writableLength instead.

Readonly bytesRead

bytesRead: number

Readonly bytesWritten

bytesWritten: number

Readonly connecting

connecting: boolean

Readonly destroyed

destroyed: boolean

Readonly localAddress

localAddress: string

Readonly localPort

localPort: number

readable

readable: boolean

Readonly readableEncoding

readableEncoding: BufferEncoding

Readonly readableEnded

readableEnded: boolean

Readonly readableFlowing

readableFlowing: boolean

Readonly readableHighWaterMark

readableHighWaterMark: number

Readonly readableLength

readableLength: number

Readonly readableObjectMode

readableObjectMode: boolean

Optional Readonly remoteAddress

remoteAddress: string

Optional Readonly remoteFamily

remoteFamily: string

Optional Readonly remotePort

remotePort: number

Readonly writable

writable: boolean

Readonly writableCorked

writableCorked: number

Readonly writableEnded

writableEnded: boolean

Readonly writableFinished

writableFinished: boolean

Readonly writableHighWaterMark

writableHighWaterMark: number

Readonly writableLength

writableLength: number

Readonly writableObjectMode

writableObjectMode: boolean

Methods

[asyncIterator]

[asyncIterator](): AsyncIterableIterator<any>

Inherited from net.Socket.__@asyncIterator@22014
- Defined in node/stream.d.ts:131
Returns AsyncIterableIterator<any>

Optional _construct

_construct(callback: (error?: Error) => void): void

Inherited from net.Socket._construct
- Defined in node/stream.d.ts:43
Parameters
- callback: (error?: Error) => void
  - - (error?: Error): void
    - Parameters
      - Optional error: Error
      Returns void
Returns void

_destroy

_destroy(error: Error, callback: (error: Error) => void): void

Inherited from net.Socket._destroy
- Defined in node/stream.d.ts:261
Parameters
- error: Error
- callback: (error: Error) => void
  - - (error: Error): void
    - Parameters
      - error: Error
      Returns void
Returns void

_final

_final(callback: (error?: Error) => void): void

Inherited from net.Socket._final
- Defined in node/stream.d.ts:262
Parameters
- callback: (error?: Error) => void
  - - (error?: Error): void
    - Parameters
      - Optional error: Error
      Returns void
Returns void

_read

_read(size: number): void

Inherited from net.Socket._read
- Defined in node/stream.d.ts:44
Parameters
- size: number
Returns void

_write

_write(chunk: any, encoding: BufferEncoding, callback: (error?: Error) => void): void

Inherited from net.Socket._write
- Defined in node/stream.d.ts:259
Parameters
- chunk: any
- encoding: BufferEncoding
- callback: (error?: Error) => void
  - - (error?: Error): void
    - Parameters
      - Optional error: Error
      Returns void
Returns void

Optional _writev

_writev(chunks: { chunk: any; encoding: BufferEncoding }[], callback: (error?: Error) => void): void

Inherited from net.Socket._writev
- Defined in node/stream.d.ts:260
Parameters
- chunks: { chunk: any; encoding: BufferEncoding }[]
- callback: (error?: Error) => void
  - - (error?: Error): void
    - Parameters
      - Optional error: Error
      Returns void
Returns void

addListener

addListener(event: string, listener: (...args: any[]) => void): AMQPClient
addListener(event: "close", listener: (had_error: boolean) => void): AMQPClient
addListener(event: "connect", listener: () => void): AMQPClient
addListener(event: "data", listener: (data: Buffer) => void): AMQPClient
addListener(event: "drain", listener: () => void): AMQPClient
addListener(event: "end", listener: () => void): AMQPClient
addListener(event: "error", listener: (err: Error) => void): AMQPClient
addListener(event: "lookup", listener: (err: Error, address: string, family: string | number, host: string) => void): AMQPClient
addListener(event: "timeout", listener: () => void): AMQPClient

Inherited from net.Socket.addListener
- Defined in node/net.d.ts:110
events.EventEmitter
1. close
2. connect
3. data
4. drain
5. end
6. error
7. lookup
8. timeout
Parameters
- event: string
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:111
Parameters
- event: "close"
- listener: (had_error: boolean) => void
  - - (had_error: boolean): void
    - Parameters
      - had_error: boolean
      Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:112
Parameters
- event: "connect"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:113
Parameters
- event: "data"
- listener: (data: Buffer) => void
  - - (data: Buffer): void
    - Parameters
      - data: Buffer
      Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:114
Parameters
- event: "drain"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:115
Parameters
- event: "end"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:116
Parameters
- event: "error"
- listener: (err: Error) => void
  - - (err: Error): void
    - Parameters
      - err: Error
      Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:117
Parameters
- event: "lookup"
- listener: (err: Error, address: string, family: string | number, host: string) => void
  - - (err: Error, address: string, family: string | number, host: string): void
    - Parameters
      - err: Error
      - address: string
      - family: string | number
      - host: string
      Returns void
Returns AMQPClient
Inherited from net.Socket.addListener
- Defined in node/net.d.ts:118
Parameters
- event: "timeout"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient

address

address(): {} | AddressInfo

Inherited from net.Socket.address
- Defined in node/net.d.ts:78
Returns {} | AddressInfo

connect

connect(options: SocketConnectOpts, connectionListener?: () => void): AMQPClient
connect(port: number, host: string, connectionListener?: () => void): AMQPClient
connect(port: number, connectionListener?: () => void): AMQPClient
connect(path: string, connectionListener?: () => void): AMQPClient

Inherited from net.Socket.connect
- Defined in node/net.d.ts:67
Parameters
- options: SocketConnectOpts
- Optional connectionListener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.connect
- Defined in node/net.d.ts:68
Parameters
- port: number
- host: string
- Optional connectionListener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.connect
- Defined in node/net.d.ts:69
Parameters
- port: number
- Optional connectionListener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.connect
- Defined in node/net.d.ts:70
Parameters
- path: string
- Optional connectionListener: () => void
  - - (): void
    - Returns void
Returns AMQPClient

cork

cork(): void

Inherited from net.Socket.cork
- Defined in node/stream.d.ts:269
Returns void

destroy

destroy(error?: Error): void

Inherited from net.Socket.destroy
- Defined in node/stream.d.ts:55
Parameters
- Optional error: Error
Returns void

disconnect

disconnect(): void

- Defined in amqp/index.d.ts:16
Returns void

emit

emit(event: string | symbol, ...args: any[]): boolean
emit(event: "close", had_error: boolean): boolean
emit(event: "connect"): boolean
emit(event: "data", data: Buffer): boolean
emit(event: "drain"): boolean
emit(event: "end"): boolean
emit(event: "error", err: Error): boolean
emit(event: "lookup", err: Error, address: string, family: string | number, host: string): boolean
emit(event: "timeout"): boolean

Inherited from net.Socket.emit
- Defined in node/net.d.ts:120
Parameters
- event: string | symbol
- Rest ...args: any[]
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:121
Parameters
- event: "close"
- had_error: boolean
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:122
Parameters
- event: "connect"
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:123
Parameters
- event: "data"
- data: Buffer
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:124
Parameters
- event: "drain"
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:125
Parameters
- event: "end"
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:126
Parameters
- event: "error"
- err: Error
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:127
Parameters
- event: "lookup"
- err: Error
- address: string
- family: string | number
- host: string
Returns boolean
Inherited from net.Socket.emit
- Defined in node/net.d.ts:128
Parameters
- event: "timeout"
Returns boolean

end

end(cb?: () => void): void
end(buffer: string | Uint8Array, cb?: () => void): void
end(str: string | Uint8Array, encoding?: BufferEncoding, cb?: () => void): void

Inherited from net.Socket.end
- Defined in node/net.d.ts:95
Parameters
- Optional cb: () => void
  - - (): void
    - Returns void
Returns void
Inherited from net.Socket.end
- Defined in node/net.d.ts:96
Parameters
- buffer: string | Uint8Array
- Optional cb: () => void
  - - (): void
    - Returns void
Returns void
Inherited from net.Socket.end
- Defined in node/net.d.ts:97
Parameters
- str: string | Uint8Array
- Optional encoding: BufferEncoding
- Optional cb: () => void
  - - (): void
    - Returns void
Returns void

eventNames

eventNames(): (string | symbol)[]

Inherited from net.Socket.eventNames
- Defined in node/events.d.ts:87
Returns (string | symbol)[]

exchange

exchange(callback?: Callback<void>): AMQPExchange
exchange(exchangeName: string, callback?: Callback<void>): AMQPExchange
exchange(exchangeName: string, options: ExchangeOptions, callback?: Callback<void>): AMQPExchange

- Defined in amqp/index.d.ts:21
Parameters
- Optional callback: Callback<void>
Returns AMQPExchange
- Defined in amqp/index.d.ts:22
Parameters
- exchangeName: string
- Optional callback: Callback<void>
Returns AMQPExchange
- Defined in amqp/index.d.ts:23
Parameters
- exchangeName: string
- options: ExchangeOptions
- Optional callback: Callback<void>
Returns AMQPExchange

getMaxListeners

getMaxListeners(): number

Inherited from net.Socket.getMaxListeners
- Defined in node/events.d.ts:79
Returns number

isPaused

isPaused(): boolean

Inherited from net.Socket.isPaused
- Defined in node/stream.d.ts:49
Returns boolean

listenerCount

listenerCount(event: string | symbol): number

Inherited from net.Socket.listenerCount
- Defined in node/events.d.ts:83
Parameters
- event: string | symbol
Returns number

listeners

listeners(event: string | symbol): Function[]

Inherited from net.Socket.listeners
- Defined in node/events.d.ts:80
Parameters
- event: string | symbol
Returns Function[]

off

off(event: string | symbol, listener: (...args: any[]) => void): AMQPClient

Inherited from net.Socket.off
- Defined in node/events.d.ts:76
Parameters
- event: string | symbol
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient

on

on(event: string, listener: (...args: any[]) => void): AMQPClient
on(event: "close", listener: (had_error: boolean) => void): AMQPClient
on(event: "connect", listener: () => void): AMQPClient
on(event: "data", listener: (data: Buffer) => void): AMQPClient
on(event: "drain", listener: () => void): AMQPClient
on(event: "end", listener: () => void): AMQPClient
on(event: "error", listener: (err: Error) => void): AMQPClient
on(event: "lookup", listener: (err: Error, address: string, family: string | number, host: string) => void): AMQPClient
on(event: "timeout", listener: () => void): AMQPClient

Inherited from net.Socket.on
- Defined in node/net.d.ts:130
Parameters
- event: string
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:131
Parameters
- event: "close"
- listener: (had_error: boolean) => void
  - - (had_error: boolean): void
    - Parameters
      - had_error: boolean
      Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:132
Parameters
- event: "connect"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:133
Parameters
- event: "data"
- listener: (data: Buffer) => void
  - - (data: Buffer): void
    - Parameters
      - data: Buffer
      Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:134
Parameters
- event: "drain"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:135
Parameters
- event: "end"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:136
Parameters
- event: "error"
- listener: (err: Error) => void
  - - (err: Error): void
    - Parameters
      - err: Error
      Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:137
Parameters
- event: "lookup"
- listener: (err: Error, address: string, family: string | number, host: string) => void
  - - (err: Error, address: string, family: string | number, host: string): void
    - Parameters
      - err: Error
      - address: string
      - family: string | number
      - host: string
      Returns void
Returns AMQPClient
Inherited from net.Socket.on
- Defined in node/net.d.ts:138
Parameters
- event: "timeout"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient

once

once(event: string, listener: (...args: any[]) => void): AMQPClient
once(event: "close", listener: (had_error: boolean) => void): AMQPClient
once(event: "connect", listener: () => void): AMQPClient
once(event: "data", listener: (data: Buffer) => void): AMQPClient
once(event: "drain", listener: () => void): AMQPClient
once(event: "end", listener: () => void): AMQPClient
once(event: "error", listener: (err: Error) => void): AMQPClient
once(event: "lookup", listener: (err: Error, address: string, family: string | number, host: string) => void): AMQPClient
once(event: "timeout", listener: () => void): AMQPClient

Inherited from net.Socket.once
- Defined in node/net.d.ts:140
Parameters
- event: string
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:141
Parameters
- event: "close"
- listener: (had_error: boolean) => void
  - - (had_error: boolean): void
    - Parameters
      - had_error: boolean
      Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:142
Parameters
- event: "connect"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:143
Parameters
- event: "data"
- listener: (data: Buffer) => void
  - - (data: Buffer): void
    - Parameters
      - data: Buffer
      Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:144
Parameters
- event: "drain"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:145
Parameters
- event: "end"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:146
Parameters
- event: "error"
- listener: (err: Error) => void
  - - (err: Error): void
    - Parameters
      - err: Error
      Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:147
Parameters
- event: "lookup"
- listener: (err: Error, address: string, family: string | number, host: string) => void
  - - (err: Error, address: string, family: string | number, host: string): void
    - Parameters
      - err: Error
      - address: string
      - family: string | number
      - host: string
      Returns void
Returns AMQPClient
Inherited from net.Socket.once
- Defined in node/net.d.ts:148
Parameters
- event: "timeout"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient

pause

pause(): AMQPClient

Inherited from net.Socket.pause
- Defined in node/net.d.ts:73
Returns AMQPClient

pipe

pipe<T>(destination: T, options?: { end?: boolean }): T

Inherited from net.Socket.pipe
- Defined in node/stream.d.ts:6
Type parameters
- T: WritableStream<T>
Parameters
- destination: T
- Optional options: { end?: boolean }
  - Optional end?: boolean
Returns T

prependListener

prependListener(event: string, listener: (...args: any[]) => void): AMQPClient
prependListener(event: "close", listener: (had_error: boolean) => void): AMQPClient
prependListener(event: "connect", listener: () => void): AMQPClient
prependListener(event: "data", listener: (data: Buffer) => void): AMQPClient
prependListener(event: "drain", listener: () => void): AMQPClient
prependListener(event: "end", listener: () => void): AMQPClient
prependListener(event: "error", listener: (err: Error) => void): AMQPClient
prependListener(event: "lookup", listener: (err: Error, address: string, family: string | number, host: string) => void): AMQPClient
prependListener(event: "timeout", listener: () => void): AMQPClient

Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:150
Parameters
- event: string
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:151
Parameters
- event: "close"
- listener: (had_error: boolean) => void
  - - (had_error: boolean): void
    - Parameters
      - had_error: boolean
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:152
Parameters
- event: "connect"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:153
Parameters
- event: "data"
- listener: (data: Buffer) => void
  - - (data: Buffer): void
    - Parameters
      - data: Buffer
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:154
Parameters
- event: "drain"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:155
Parameters
- event: "end"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:156
Parameters
- event: "error"
- listener: (err: Error) => void
  - - (err: Error): void
    - Parameters
      - err: Error
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:157
Parameters
- event: "lookup"
- listener: (err: Error, address: string, family: string | number, host: string) => void
  - - (err: Error, address: string, family: string | number, host: string): void
    - Parameters
      - err: Error
      - address: string
      - family: string | number
      - host: string
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependListener
- Defined in node/net.d.ts:158
Parameters
- event: "timeout"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient

prependOnceListener

prependOnceListener(event: string, listener: (...args: any[]) => void): AMQPClient
prependOnceListener(event: "close", listener: (had_error: boolean) => void): AMQPClient
prependOnceListener(event: "connect", listener: () => void): AMQPClient
prependOnceListener(event: "data", listener: (data: Buffer) => void): AMQPClient
prependOnceListener(event: "drain", listener: () => void): AMQPClient
prependOnceListener(event: "end", listener: () => void): AMQPClient
prependOnceListener(event: "error", listener: (err: Error) => void): AMQPClient
prependOnceListener(event: "lookup", listener: (err: Error, address: string, family: string | number, host: string) => void): AMQPClient
prependOnceListener(event: "timeout", listener: () => void): AMQPClient

Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:160
Parameters
- event: string
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:161
Parameters
- event: "close"
- listener: (had_error: boolean) => void
  - - (had_error: boolean): void
    - Parameters
      - had_error: boolean
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:162
Parameters
- event: "connect"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:163
Parameters
- event: "data"
- listener: (data: Buffer) => void
  - - (data: Buffer): void
    - Parameters
      - data: Buffer
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:164
Parameters
- event: "drain"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:165
Parameters
- event: "end"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:166
Parameters
- event: "error"
- listener: (err: Error) => void
  - - (err: Error): void
    - Parameters
      - err: Error
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:167
Parameters
- event: "lookup"
- listener: (err: Error, address: string, family: string | number, host: string) => void
  - - (err: Error, address: string, family: string | number, host: string): void
    - Parameters
      - err: Error
      - address: string
      - family: string | number
      - host: string
      Returns void
Returns AMQPClient
Inherited from net.Socket.prependOnceListener
- Defined in node/net.d.ts:168
Parameters
- event: "timeout"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient

publish

publish(routingKey: string, body: any, options: {}, callback: (err?: boolean, msg?: string) => void): void

- Defined in amqp/index.d.ts:14
Parameters
- routingKey: string
- body: any
- options: {}
- callback: (err?: boolean, msg?: string) => void
  - - (err?: boolean, msg?: string): void
    - Parameters
      - Optional err: boolean
      - Optional msg: string
      Returns void
Returns void

push

push(chunk: any, encoding?: BufferEncoding): boolean

Inherited from net.Socket.push
- Defined in node/stream.d.ts:53
Parameters
- chunk: any
- Optional encoding: BufferEncoding
Returns boolean

queue

queue(queueName: string, callback?: Callback<QueueCallback>): AMQPQueue
queue(queueName: string, options: QueueOptions, callback?: Callback<QueueCallback>): AMQPQueue

- Defined in amqp/index.d.ts:18
Parameters
- queueName: string
- Optional callback: Callback<QueueCallback>
Returns AMQPQueue
- Defined in amqp/index.d.ts:19
Parameters
- queueName: string
- options: QueueOptions
- Optional callback: Callback<QueueCallback>
Returns AMQPQueue

rawListeners

rawListeners(event: string | symbol): Function[]

Inherited from net.Socket.rawListeners
- Defined in node/events.d.ts:81
Parameters
- event: string | symbol
Returns Function[]

read

read(size?: number): any

Inherited from net.Socket.read
- Defined in node/stream.d.ts:45
Parameters
- Optional size: number
Returns any

ref

ref(): AMQPClient

Inherited from net.Socket.ref
- Defined in node/net.d.ts:80
Returns AMQPClient

removeAllListeners

removeAllListeners(event?: string | symbol): AMQPClient

Inherited from net.Socket.removeAllListeners
- Defined in node/events.d.ts:77
Parameters
- Optional event: string | symbol
Returns AMQPClient

removeListener

removeListener(event: "close", listener: () => void): AMQPClient
removeListener(event: "data", listener: (chunk: any) => void): AMQPClient
removeListener(event: "end", listener: () => void): AMQPClient
removeListener(event: "error", listener: (err: Error) => void): AMQPClient
removeListener(event: "pause", listener: () => void): AMQPClient
removeListener(event: "readable", listener: () => void): AMQPClient
removeListener(event: "resume", listener: () => void): AMQPClient
removeListener(event: string | symbol, listener: (...args: any[]) => void): AMQPClient

Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:122
Parameters
- event: "close"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:123
Parameters
- event: "data"
- listener: (chunk: any) => void
  - - (chunk: any): void
    - Parameters
      - chunk: any
      Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:124
Parameters
- event: "end"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:125
Parameters
- event: "error"
- listener: (err: Error) => void
  - - (err: Error): void
    - Parameters
      - err: Error
      Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:126
Parameters
- event: "pause"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:127
Parameters
- event: "readable"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:128
Parameters
- event: "resume"
- listener: () => void
  - - (): void
    - Returns void
Returns AMQPClient
Inherited from net.Socket.removeListener
- Defined in node/stream.d.ts:129
Parameters
- event: string | symbol
- listener: (...args: any[]) => void
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
Returns AMQPClient

resume

resume(): AMQPClient

Inherited from net.Socket.resume
- Defined in node/net.d.ts:74
Returns AMQPClient

setDefaultEncoding

setDefaultEncoding(encoding: BufferEncoding): AMQPClient

Inherited from net.Socket.setDefaultEncoding
- Defined in node/stream.d.ts:265
Parameters
- encoding: BufferEncoding
Returns AMQPClient

setEncoding

setEncoding(encoding?: BufferEncoding): AMQPClient

Inherited from net.Socket.setEncoding
- Defined in node/net.d.ts:72
Parameters
- Optional encoding: BufferEncoding
Returns AMQPClient

setKeepAlive

setKeepAlive(enable?: boolean, initialDelay?: number): AMQPClient

Inherited from net.Socket.setKeepAlive
- Defined in node/net.d.ts:77
Parameters
- Optional enable: boolean
- Optional initialDelay: number
Returns AMQPClient

setMaxListeners

setMaxListeners(n: number): AMQPClient

Inherited from net.Socket.setMaxListeners
- Defined in node/events.d.ts:78
Parameters
- n: number
Returns AMQPClient

setNoDelay

setNoDelay(noDelay?: boolean): AMQPClient

Inherited from net.Socket.setNoDelay
- Defined in node/net.d.ts:76
Parameters
- Optional noDelay: boolean
Returns AMQPClient

setTimeout

setTimeout(timeout: number, callback?: () => void): AMQPClient

Inherited from net.Socket.setTimeout
- Defined in node/net.d.ts:75
Parameters
- timeout: number
- Optional callback: () => void
  - - (): void
    - Returns void
Returns AMQPClient

uncork

uncork(): void

Inherited from net.Socket.uncork
- Defined in node/stream.d.ts:270
Returns void

unpipe

unpipe(destination?: WritableStream): AMQPClient

Inherited from net.Socket.unpipe
- Defined in node/stream.d.ts:50
Parameters
- Optional destination: WritableStream
Returns AMQPClient

unref

unref(): AMQPClient

Inherited from net.Socket.unref
- Defined in node/net.d.ts:79
Returns AMQPClient

unshift

unshift(chunk: any, encoding?: BufferEncoding): void

Inherited from net.Socket.unshift
- Defined in node/stream.d.ts:51
Parameters
- chunk: any
- Optional encoding: BufferEncoding
Returns void

wrap

wrap(oldStream: ReadableStream): AMQPClient

Inherited from net.Socket.wrap
- Defined in node/stream.d.ts:52
Parameters
- oldStream: ReadableStream
Returns AMQPClient

write

write(buffer: string | Uint8Array, cb?: (err?: Error) => void): boolean
write(str: string | Uint8Array, encoding?: BufferEncoding, cb?: (err?: Error) => void): boolean

Inherited from net.Socket.write
- Defined in node/net.d.ts:64
Parameters
- buffer: string | Uint8Array
- Optional cb: (err?: Error) => void
  - - (err?: Error): void
    - Parameters
      - Optional err: Error
      Returns void
Returns boolean
Inherited from net.Socket.write
- Defined in node/net.d.ts:65
Parameters
- str: string | Uint8Array
- Optional encoding: BufferEncoding
- Optional cb: (err?: Error) => void
  - - (err?: Error): void
    - Parameters
      - Optional err: Error
      Returns void
Returns boolean

Hierarchy

Index

Properties

Methods

Properties

Readonly bufferSize

Readonly bytesRead

Readonly bytesWritten

Readonly connecting

Readonly destroyed

Readonly localAddress

Readonly localPort

readable

Readonly readableEncoding

Readonly readableEnded

Readonly readableFlowing

Readonly readableHighWaterMark

Readonly readableLength

Readonly readableObjectMode

Optional Readonly remoteAddress

Optional Readonly remoteFamily

Optional Readonly remotePort

Readonly writable

Readonly writableCorked

Readonly writableEnded

Readonly writableFinished

Readonly writableHighWaterMark

Readonly writableLength

Readonly writableObjectMode

Methods

[asyncIterator]

Returns AsyncIterableIterator<any>

Optional _construct

Parameters

callback: (error?: Error) => void

Parameters

Optional error: Error

Returns void

Returns void

_destroy

Parameters

error: Error

callback: (error: Error) => void

Parameters

error: Error

Returns void

Returns void

_final

Parameters

callback: (error?: Error) => void

Parameters

Optional error: Error

Returns void

Returns void

_read

Parameters

size: number

Returns void

_write

Parameters

chunk: any

encoding: BufferEncoding

callback: (error?: Error) => void

Parameters

Optional error: Error

Returns void

Returns void

Optional _writev

Parameters

chunks: { chunk: any; encoding: BufferEncoding }[]

callback: (error?: Error) => void

Parameters

Optional error: Error

Returns void

Returns void

addListener

Parameters

event: string

listener: (...args: any[]) => void

Parameters