Options
All
  • Public
  • Public/Protected
  • All
Menu

Class AMQPService<Data>

Type parameters

  • Data

Hierarchy

  • Database
    • AMQPService

Implements

  • Component

Index

Constructors

Properties

Methods

Constructors

constructor

Properties

Protected channels

channels: Channel<Data>[] = []

Protected Optional connection

connection: Connection

logger

logger: LoggerInstance

options

options: AMQPServiceOptions

type

type: DATABASE

Methods

channel

connect

  • connect(options?: AMQPOptions.Connect): Promise<DatabaseOptions>

  • Parameters

    • Optional options: AMQPOptions.Connect

    Returns Promise<DatabaseOptions>

describe

  • describe(): { context: {}; name: string; status: string }

  • Describes the database instance for the framework.

    Returns { context: {}; name: string; status: string }

    • context: {}
      • [x: string]: any
    • name: string
    • status: string

disconnect

  • disconnect(): Promise<void>

  • Disconnects from AMQP server.

    Returns Promise<void>

drop

  • drop(...args: any[]): Promise<any>

  • Drops the current database schema.

    Parameters

    • Rest ...args: any[]

    Returns Promise<any>

Protected ensureConnection

  • ensureConnection(): void

  • Ensures the database is connected.

    Returns void

entities

  • entities(): {}

  • Returns {}

    • [name: string]: any

isConnected

  • isConnected(): boolean

  • Returns boolean

migrate

  • migrate(...args: any[]): Promise<any>

  • Migrates the current database schema.

    Parameters

    • Rest ...args: any[]

    Returns Promise<any>

onInit

  • onInit(): Promise<void>

  • Handles the database initialization routine, connecting to remote server.

    Returns Promise<void>

onMount

  • onMount(server: BaseServer): void

  • Mounts the database, registering the models and query builders.

    Parameters

    • server: BaseServer

      The base server instance.

    Returns void

onReady

  • onReady(server: BaseServer): Promise<void>

  • Handles server post-initialization, not so relevant for a Database component that will be already initialized.

    Parameters

    • server: BaseServer

      The base server instance.

    Returns Promise<void>

onUnmount

  • onUnmount(): void

  • Handles the database unmounting routines and disconnect.

    Returns void

query

  • query(): Promise<void>

  • Returns Promise<void>

Generated using TypeDoc