Class SQSQueue<T>

Type parameters

T: SQSQueueParameters

Hierarchy

Queue<T>
- SQSQueue

Implements

CloudFormationContributor

Constructors

Properties

_createException

_initTime

_name

_timeout

_webda

callback

logger

pause

sqs

defaultMaxListeners

Methods

__clean

_getQueueInfosFromUrl

_workerReceiveMessage

addRoute

computeParameters

emit

emitSync

getCloudFormation

getMaxListeners

getName

getWebda

init

listeners

log

off

on

onAsync

once

prependListener

prependOnceListener

reinit

removeAllListeners

resolve

setMaxListeners

size

stop

worker

getModda

Constructors

new SQSQueue(webda: Core, name: string, params?: any): SQSQueue

Inherited from CloudWatchLogger.constructor

Parameters
- webda: Core
  
  The main instance of Webda
- name: string
  
  The name of the service
- Optional params: any
  
  The parameters block define in the configuration file
Returns SQSQueue
- Defined in packages/core/lib/services/service.d.ts:42

Properties

_createException: string

_initException: any

_initTime: number

_interrupt: boolean

_name: string

Service name

_timeout: any

_webda: Core

Webda Core object

callback: Function

logger: Logger

Logger with class context

parameters: T

Hold the parameters for your service

It will be bring from the webda.config.json

pause: number

sqs: any

defaultMaxListeners: number

Methods

__clean(): Promise<unknown>

Overrides CloudWatchLogger.__clean

Returns Promise<unknown>
- Defined in packages/aws/src/services/sqsqueue.ts:84

_getQueueInfosFromUrl(): object

Returns object
- accountId: string
- name: string
- region: string
- Defined in packages/aws/src/services/sqsqueue.ts:110

_workerReceiveMessage(): Promise<void>

Inherited from SQSQueue._workerReceiveMessage

Returns Promise<void>
- Defined in packages/core/lib/queues/queueservice.d.ts:15

_workerResume(): Promise<void>

Inherited from SQSQueue._workerResume

Returns Promise<void>
- Defined in packages/core/lib/queues/queueservice.d.ts:14

addListener(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.addListener

Overrides EventEmitter.addListener

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:32
Returns this
- Defined in node_modules/@types/node/events.d.ts:32

addRoute(url: string, methods: HttpMethodType[], executer: Function, openapi?: object, allowPath?: boolean): void

Inherited from CloudWatchLogger.addRoute

Add a route dynamicaly

Parameters
- url: string
  
  of the route can contains dynamic part like {uuid}
- methods: HttpMethodType[]
- executer: Function
  
  Method to execute for this route
- Optional openapi: object
- Optional allowPath: boolean
Returns void
- Defined in packages/core/lib/services/service.d.ts:80

computeParameters(): void

Inherited from CloudWatchLogger.computeParameters

Used to compute or derivate input parameter to attribute

Returns void
- Defined in packages/core/lib/services/service.d.ts:59

deleteMessage(receipt: any): Promise<any>

Overrides Queue.deleteMessage

Parameters
- receipt: any
Returns Promise<any>
- Defined in packages/aws/src/services/sqsqueue.ts:75

emit(event: string | symbol, ...args: any[]): boolean

Inherited from CloudWatchLogger.emit

Overrides EventEmitter.emit

Parameters
- event: string | symbol
- Rest ...args: any[]
Returns boolean
- Defined in node_modules/@types/node/events.d.ts:44

emitSync(event: any, data: any): Promise<any[]>

Inherited from CloudWatchLogger.emitSync

Emit the event with data and wait for Promise to finish if listener returned a Promise

Parameters
- event: any
- data: any
Returns Promise<any[]>
- Defined in packages/core/lib/services/service.d.ts:108

eventNames(): Array<string | symbol>

Inherited from CloudWatchLogger.eventNames

Overrides EventEmitter.eventNames

Returns Array<string | symbol>
- Defined in node_modules/@types/node/events.d.ts:45

getARNPolicy(): object

Returns object
- Action: string[]
- Effect: string
- Resource: string[]
- Sid: string
- Defined in packages/aws/src/services/sqsqueue.ts:127

getCloudFormation(deployer: CloudFormationDeployer): object

Parameters
- deployer: CloudFormationDeployer
Returns object
- Defined in packages/aws/src/services/sqsqueue.ts:144

getMaxListeners(): number

Inherited from CloudWatchLogger.getMaxListeners

Overrides EventEmitter.getMaxListeners

Returns number
- Defined in node_modules/@types/node/events.d.ts:41

getName(): string

Inherited from CloudWatchLogger.getName

Get service name

Returns string
- Defined in packages/core/lib/services/service.d.ts:129

getParameters(): T

Inherited from CloudWatchLogger.getParameters

Get the service parameters

Returns T
- Defined in packages/core/lib/services/service.d.ts:63

getService<T>(service: string): T

Inherited from CloudWatchLogger.getService

Return a webda service

Type parameters
- T: Service<ServiceParameters>
Parameters
- service: string
  
  name to retrieve
Returns T
- Defined in packages/core/lib/services/service.d.ts:120

getWebda(): Core

Inherited from CloudWatchLogger.getWebda

Return WebdaCore

Returns Core
- Defined in packages/core/lib/services/service.d.ts:67

init(): Promise<void>

Overrides AWSSecretsManager.init

Returns Promise<void>
- Defined in packages/aws/src/services/sqsqueue.ts:34

initRoutes(): void

Inherited from CloudWatchLogger.initRoutes

Init the routes

Returns void
- Defined in packages/core/lib/services/service.d.ts:84

listenerCount(type: string | symbol): number

Inherited from CloudWatchLogger.listenerCount

Overrides EventEmitter.listenerCount

Parameters
- type: string | symbol
Returns number
- Defined in node_modules/@types/node/events.d.ts:46

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

Inherited from CloudWatchLogger.listeners

Overrides EventEmitter.listeners

Parameters
- event: string | symbol
Returns Function[]
- Defined in node_modules/@types/node/events.d.ts:42

loadParameters(params: any): SQSQueueParameters

Overrides Queue.loadParameters

Load the parameters

Parameters
- params: any
Returns SQSQueueParameters
- Defined in packages/aws/src/services/sqsqueue.ts:30

log(level: WorkerLogLevel, ...args: any[]): void

Inherited from CloudWatchLogger.log

Parameters
- level: WorkerLogLevel
  
  to log
- Rest ...args: any[]
Returns void
- Defined in packages/core/lib/services/service.d.ts:145

off(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.off

Overrides EventEmitter.off

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:38
Returns this
- Defined in node_modules/@types/node/events.d.ts:38

on(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.on

Overrides EventEmitter.on

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:33
Returns this
- Defined in node_modules/@types/node/events.d.ts:33

onAsync(event: any, callback: any, queue?: string): void

Inherited from CloudWatchLogger.onAsync

Listen to an event as on(...) would do except that it will be asynchronous

Parameters
- event: any
- callback: any
- Optional queue: string
  
  Name of queue to use, can be undefined, queue name are used to define differents priorities
Returns void
- Defined in packages/core/lib/services/service.d.ts:115

once(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.once

Overrides EventEmitter.once

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:34
Returns this
- Defined in node_modules/@types/node/events.d.ts:34

prependListener(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.prependListener

Overrides EventEmitter.prependListener

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:35
Returns this
- Defined in node_modules/@types/node/events.d.ts:35

prependOnceListener(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.prependOnceListener

Overrides EventEmitter.prependOnceListener

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:36
Returns this
- Defined in node_modules/@types/node/events.d.ts:36

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

Inherited from CloudWatchLogger.rawListeners

Overrides EventEmitter.rawListeners

Parameters
- event: string | symbol
Returns Function[]
- Defined in node_modules/@types/node/events.d.ts:43

receiveMessage(): Promise<any>

Overrides Queue.receiveMessage

Returns Promise<any>
- Defined in packages/aws/src/services/sqsqueue.ts:65

reinit(config: any): Promise<void>

Inherited from CloudWatchLogger.reinit

Parameters
- config: any
  
  new parameters for the service
Returns Promise<void>
- Defined in packages/core/lib/services/service.d.ts:104

removeAllListeners(event?: string | symbol): this

Inherited from CloudWatchLogger.removeAllListeners

Overrides EventEmitter.removeAllListeners

Parameters
- Optional event: string | symbol
Returns this
- Defined in node_modules/@types/node/events.d.ts:39

removeListener(event: string | symbol, listener: function): this

Inherited from CloudWatchLogger.removeListener

Overrides EventEmitter.removeListener

Parameters
- event: string | symbol
- listener: function
  - - (...args: any[]): void
    - Parameters
      - Rest ...args: any[]
      Returns void
      Defined in node_modules/@types/node/events.d.ts:37
Returns this
- Defined in node_modules/@types/node/events.d.ts:37

resolve(): void

Inherited from CloudWatchLogger.resolve

Resolve parameters Call initRoutes and initBeanRoutes

Returns void
- Defined in packages/core/lib/services/service.d.ts:72

sendMessage(params: any): Promise<any>

Overrides Queue.sendMessage

Parameters
- params: any
Returns Promise<any>
- Defined in packages/aws/src/services/sqsqueue.ts:54

setMaxListeners(n: number): this

Inherited from CloudWatchLogger.setMaxListeners

Overrides EventEmitter.setMaxListeners

Parameters
- n: number
Returns this
- Defined in node_modules/@types/node/events.d.ts:40

size(): Promise<number>

Overrides Queue.size

Returns Promise<number>
- Defined in packages/aws/src/services/sqsqueue.ts:41

stop(): void

Inherited from SQSQueue.stop

Returns void
- Defined in packages/core/lib/queues/queueservice.d.ts:17

toPublicJSON(object: any): string

Inherited from CloudWatchLogger.toPublicJSON

Convert an object to JSON using the Webda json filter

Parameters
- object: any
  
  The object to export
Returns string

The export of the strip object ( removed all attribute with _ )
- Defined in packages/core/lib/services/service.d.ts:92

worker(callback: any): Promise<void>

Inherited from SQSQueue.worker

Parameters
- callback: any
Returns Promise<void>
- Defined in packages/core/lib/queues/queueservice.d.ts:16

getModda(): ModdaDefinition

Overrides Queue.getModda

Returns ModdaDefinition
- Defined in packages/aws/src/services/sqsqueue.ts:164

listenerCount(emitter: EventEmitter, event: string | symbol): number

Inherited from CloudWatchLogger.listenerCount

deprecated

since v4.0.0

Parameters
- emitter: EventEmitter
- event: string | symbol
Returns number
- Defined in node_modules/@types/node/events.d.ts:29

Generated using TypeDoc