Packages · @purista/amqpbridge

@purista/amqpbridge

Package for using a AMQP broker like rabbitMQ as event bridge.

@purista/amqpbridge

Signature

@purista/amqpbridge.tstypescript
@purista/amqpbridge

Examples

example-1.tstypescript
import { AmqpBridge } from '@purista/amqpbridge'

// create and init our eventbridge
  const eventBridge = new AmqpBridge()
  await eventBridge.start()

Type Aliases

7 entries

AmqpBridgeConfig

Types

Source
AmqpBridgeConfig.tstypescript
type AmqpBridgeConfig = void

Configuration for AmqpBridge.

Encoder

Types

Source
Encoder.tstypescript
type Encoder = Record<string, EncoderFunctions>

Map of content-type to codec implementation. Example key: `application/json`.

EncoderFunctions

Types

Source
EncoderFunctions.tstypescript
type EncoderFunctions = void

Encode/decode contract for one content-type codec.

Encrypter

Types

Source
Encrypter.tstypescript
type Encrypter = Record<string, EncryptFunctions>

Map of content-encoding to encryption implementation. Example key: `utf-8`.

EncryptFunctions

Types

Source
EncryptFunctions.tstypescript
type EncryptFunctions = void

Encrypt/decrypt contract for one content-encoding implementation.

PausedSubscriptionState

Types

Source
PausedSubscriptionState.tstypescript
type PausedSubscriptionState = void

Runtime pause metadata for a subscription consumer managed by the AMQP bridge.

RegisteredSubscription

Types

Source
RegisteredSubscription.tstypescript
type RegisteredSubscription = void

Consumer registration tracked by the AMQP bridge for cleanup and retry handling.

Variables

1 entry

puristaVersion

Variables

Source
puristaVersion.tstypescript
const puristaVersion: "3.2.3"

Functions

3 entries

deserializeOtpFromAmqpHeader

Functions

Source
deserializeOtpFromAmqpHeader.tstypescript
deserializeOtpFromAmqpHeader(logger: Logger, message: ConsumeMessage | null, encrypter: Encrypter, encoder: Encoder): Promise<Context | undefined>

getDefaultConfig

Functions

Source
getDefaultConfig.tstypescript
getDefaultConfig(): Complete<AmqpBridgeConfig> & { exchangeName: string; url: string }

serializeOtpForAmqpHeader

Functions

Source
serializeOtpForAmqpHeader.tstypescript
serializeOtpForAmqpHeader(header: Record<string, string | undefined>): Record<string, string | undefined>

Event bridge

1 entry

AmqpBridge

Classes

Source
AmqpBridge.tstypescript
class AmqpBridge

EventBridge implementation for AMQP brokers such as RabbitMQ.