This release is 1 version behind 1.7.3 — the latest version of @fedify/fedify. Jump to latest

@fedify/fedify@1.7.2
Built and signed on GitHub Actions
Built and signed on GitHub Actions

An ActivityPub/fediverse server framework

Published

a week ago (1.7.2)

class DenoKvMessageQueue

implements MessageQueue, Disposable

Represents a message queue adapter that uses Deno KV store.

Constructors

new



DenoKvMessageQueue(kv: Deno.Kv)

Constructs a new DenoKvMessageQueue adapter with the given Deno KV store.

readonly



nativeRetrial: boolean

Deno KV queues provide automatic retry with exponential backoff.



[Symbol.dispose](): void



enqueue(message: any,
options?: MessageQueueEnqueueOptions | undefined,
): Promise<void>



listen(handler: (message: any) => void | Promise<void>,
options?: MessageQueueListenOptions,
): Promise<void>

Add Package

deno add jsr:@fedify/fedify

Import symbol

import { DenoKvMessageQueue } from "@fedify/fedify/x/denokv";

Import directly with a jsr specifier

import { DenoKvMessageQueue } from "jsr:@fedify/fedify/x/denokv";

Add Package

pnpm i jsr:@fedify/fedify

or (using pnpm 10.8 or older)

pnpm dlx jsr add @fedify/fedify

Import symbol

import { DenoKvMessageQueue } from "@fedify/fedify/x/denokv";

Add Package

yarn add jsr:@fedify/fedify

or (using Yarn 4.8 or older)

yarn dlx jsr add @fedify/fedify

Import symbol

import { DenoKvMessageQueue } from "@fedify/fedify/x/denokv";

Add Package

vlt install jsr:@fedify/fedify

Import symbol

import { DenoKvMessageQueue } from "@fedify/fedify/x/denokv";

Add Package

npx jsr add @fedify/fedify

Import symbol

import { DenoKvMessageQueue } from "@fedify/fedify/x/denokv";

Add Package

bunx jsr add @fedify/fedify

Import symbol

import { DenoKvMessageQueue } from "@fedify/fedify/x/denokv";