Functions — github.com/abreits/amqp-ts

CodeHub MCPcopy Create free account

hub / github.com/abreits/amqp-ts / functions

Functions96 in github.com/abreits/amqp-ts

⨍ Functions 96 ◇ Types & classes 36

↓ 104 callersFunctioncleanup

(connection, done, error?)

src/amqp-ts.spec.ts:65

↓ 65 callersMethoddeclareQueue

(name: string, options?: Queue.DeclarationOptions)

src/amqp-ts.ts:283

↓ 54 callersFunctiongetAmqpConnection

src/amqp-ts.spec.ts:43

↓ 48 callersMethoddeclareExchange

(name: string, type?: string, options?: Exchange.DeclarationOptions)

src/amqp-ts.ts:275

↓ 41 callersMethodcompleteConfiguration

* Make sure the whole defined connection topology is configured: * return promise that fulfills after all defined exchanges, queues and bindings ar

src/amqp-ts.ts:231

↓ 39 callersFunctionnextQueueName

src/amqp-ts.spec.ts:36

↓ 38 callersMethodactivateConsumer

(onMessage: (msg: Message) => any, options: Queue.ActivateConsumerOptions = {})

src/amqp-ts.ts:919

↓ 36 callersMethodgetContent

src/amqp-ts.ts:371

↓ 34 callersFunctionnextExchangeName

src/amqp-ts.spec.ts:31

↓ 29 callersMethodbind

(source: Exchange, pattern = "", args: any = {})

src/amqp-ts.ts:1105

↓ 28 callersMethodclose

src/amqp-ts.ts:1077

↓ 27 callersMethodsend

(message: Message)

src/amqp-ts.ts:841

↓ 22 callersMethoddelete

src/amqp-ts.ts:1042

↓ 20 callersMethodpublish

* deprecated, use 'queue.send(message: Message)' instead

src/amqp-ts.ts:815

↓ 16 callersMethodstopConsumer

src/amqp-ts.ts:1019

↓ 15 callersMethodstartConsumer

* deprecated, use 'queue.activateConsumer(...)' instead

src/amqp-ts.ts:900

↓ 14 callersMethodid

(destination: Exchange | Queue, source: Exchange, pattern?: string)

src/amqp-ts.ts:1253

↓ 10 callersMethod_initialize

src/amqp-ts.ts:758

↓ 10 callersMethodsendTo

(destination: Exchange | Queue, routingKey: string = "")

src/amqp-ts.ts:379

↓ 9 callersMethodack

(allUpTo?: boolean)

src/amqp-ts.ts:417

↓ 8 callersMethod_rebuildAll

src/amqp-ts.ts:168

↓ 8 callersMethodremoveBindingsContaining

(connectionPoint: Exchange | Queue)

src/amqp-ts.ts:1258

↓ 6 callersMethod_initializeConsumer

src/amqp-ts.ts:935

↓ 6 callersMethodconsumerQueueName

src/amqp-ts.ts:655

↓ 5 callersMethodrpc

(requestParameters: any)

src/amqp-ts.ts:845

↓ 4 callersMethod_packMessageContent

(content: any, options: any)

src/amqp-ts.ts:794

↓ 4 callersFunctioncallback

lib/amqp-ts.js:442

↓ 4 callersFunctioncleanup

(connection, done, error?)

src/amqp-ts.spec-i.ts:54

↓ 4 callersMethodprefetch

(count: number)

src/amqp-ts.ts:876

↓ 4 callersFunctionprocessRpc

lib/amqp-ts.js:509

↓ 4 callersMethodrebuildConnection

src/amqp-ts.ts:71

↓ 4 callersFunctionsendMessage

lib/amqp-ts.js:348

↓ 3 callersMethoddeleteConfiguration

* Delete the whole defined connection topology: * return promise that fulfills after all defined exchanges, queues and bindings have been removed

src/amqp-ts.ts:255

↓ 3 callersMethodnack

(allUpTo?: boolean, requeue?: boolean)

src/amqp-ts.ts:423

↓ 2 callersMethod_unpackMessageContent

(msg: AmqpLib.Message)

src/amqp-ts.ts:804

↓ 2 callersFunctiongenerateUuid

lib/amqp-ts.js:504

↓ 2 callersMethodrecover

src/amqp-ts.ts:883

↓ 2 callersMethodreject

(requeue = false)

src/amqp-ts.ts:429

↓ 2 callersFunctionrestart

lib/amqp-ts.js:130

↓ 2 callersFunctionrestartAmqpServer

src/amqp-ts.spec-i.ts:29

↓ 2 callersMethodsetContent

src/amqp-ts.ts:360

↓ 2 callersMethodtryToConnect

(thisConnection: Connection, retry: number, callback: (err: any) => void)

src/amqp-ts.ts:112

↓ 2 callersMethodunbind

(source: Exchange, pattern = "", args: any = {})

src/amqp-ts.ts:1110

↓ 1 callersMethod_initialize

src/amqp-ts.ts:471

↓ 1 callersMethod_initialize

src/amqp-ts.ts:1181

↓ 1 callersMethoddeclareTopology

(topology: Connection.Topology)

src/amqp-ts.ts:291

↓ 1 callersFunctionextendStatics

lib/amqp-ts.js:10

↓ 1 callersFunctionfibonacci

tutorials/6_rpc/rpc_server.js:22

FunctionBinding

(destination, source, pattern, args)

lib/amqp-ts.js:1072

FunctionConnection

(url, socketOptions, reconnectStrategy)

lib/amqp-ts.js:48

FunctionExchange

(connection, name, type, options)

lib/amqp-ts.js:407

FunctionMessage

(content, options)

lib/amqp-ts.js:318

(connection, name, options)

lib/amqp-ts.js:687

lib/amqp-ts.js:18

MethodactivateConsumer

(onMessage: (msg: Message) => any, options?: Queue.ActivateConsumerOptions)

src/amqp-ts.ts:681

FunctionactivateConsumerWrapper

lib/amqp-ts.js:915

MethodactivateConsumerWrapper

(msg: AmqpLib.Message)

src/amqp-ts.ts:974

src/amqp-ts.spec.ts:51

(source: Exchange, pattern = "", args: any = {})

src/amqp-ts.ts:646

src/amqp-ts.ts:480

src/amqp-ts.ts:767

src/amqp-ts.ts:209

src/amqp-ts.ts:620

Functioncompile

Methodconstructor

(url = "amqp://localhost", socketOptions: any = {}, reconnectStrategy: Connection.

src/amqp-ts.ts:56

Methodconstructor

(content?: any, options: any = {})

src/amqp-ts.ts:353

Methodconstructor

(connection: Connection, name: string, type?: string, options: Exchange.DeclarationOptions = {})

src/amqp-ts.ts:463

Methodconstructor

(connection: Connection, name: string, options: Queue.DeclarationOptions = {})

src/amqp-ts.ts:750

Methodconstructor

(destination: Exchange | Queue, source: Exchange, pattern = "", args: any = {})

src/amqp-ts.ts:1172

src/amqp-ts.ts:587

src/amqp-ts.ts:1221

MethodgenerateUuid

src/amqp-ts.ts:536

MethodgetConnection

src/amqp-ts.ts:324

src/amqp-ts.ts:455

src/amqp-ts.ts:746

FunctiononClose

lib/amqp-ts.js:136

src/amqp-ts.ts:149

MethodprocessRpc

src/amqp-ts.ts:542

MethodprocessRpc

src/amqp-ts.ts:847

FunctionprocessedMsgConsumer

lib/amqp-ts.js:877

MethodprocessedMsgConsumer

(msg: AmqpLib.Message)

src/amqp-ts.ts:936

* deprecated, use 'exchange.send(message: Message, routingKey?: string)' instead

src/amqp-ts.ts:507

FunctionrawConsumer

(message: AmqpLib.Message, channel: AmqpLib.Channel)

src/amqp-ts.spec.ts:150

FunctionrawMsgConsumer

lib/amqp-ts.js:906

MethodrawMsgConsumer

(msg: AmqpLib.Message)

src/amqp-ts.ts:965

src/amqp-ts.ts:142

(requestParameters: any, routingKey = "", callback?: (err, message: Message) => void)

src/amqp-ts.ts:533

(message: Message, routingKey = "")

src/amqp-ts.ts:529

MethodsendMessage

src/amqp-ts.ts:381

MethodsendMessage

src/amqp-ts.ts:817

MethodstartConsumer

* deprecated, use 'exchange.activateConsumer(...)' instead

src/amqp-ts.ts:662

MethodstopConsumer

src/amqp-ts.ts:700

FunctionswallowError

src/amqp-ts.ts:459

(source: Exchange, pattern = "", args: any = {})

src/amqp-ts.ts:651