Packages · @purista/amqpbridge

@purista/amqpbridge

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

@purista/amqpbridge

Signature

@purista/amqpbridge.ts typescript 
@purista/amqpbridge

Examples

example-1.ts typescript 
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.ts typescript 
type AmqpBridgeConfig = void

Configuration for AmqpBridge.

Encoder

Types

Source
Encoder.ts typescript 
type Encoder = Record<string, EncoderFunctions>

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

EncoderFunctions

Types

Source
EncoderFunctions.ts typescript 
type EncoderFunctions = void

Encode/decode contract for one content-type codec.

Encrypter

Types

Source
Encrypter.ts typescript 
type Encrypter = Record<string, EncryptFunctions>

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

EncryptFunctions

Types

Source
EncryptFunctions.ts typescript 
type EncryptFunctions = void

Encrypt/decrypt contract for one content-encoding implementation.

PausedSubscriptionState

Types

Source
PausedSubscriptionState.ts typescript 
type PausedSubscriptionState = void

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

RegisteredSubscription

Types

Source
RegisteredSubscription.ts typescript 
type RegisteredSubscription = void

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

Variables

1 entry

puristaVersion

Variables

Source
puristaVersion.ts typescript 
const puristaVersion: "3.0.1"

The PURISTA package version embedded in the published runtime build.

Functions

3 entries

deserializeOtpFromAmqpHeader

Functions

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

getDefaultConfig

Functions

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

serializeOtpForAmqpHeader

Functions

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

Event bridge

1 entry

AmqpBridge

Classes

Source
AmqpBridge.ts typescript 
class AmqpBridge

EventBridge implementation for AMQP brokers such as RabbitMQ.