Skip to main content
Home
Browse packagesDocsSign in

@fedify/redis@0.4.0
Built and signed on GitHub Actions

latest
fedify-dev/fedify

Redis drivers for Fedify

This package works with Node.js, Deno, Bun
This package works with Node.js
This package works with Deno
This package works with Bun
JSR Score
100%
Published
4 months ago (0.4.0)
class RedisMessageQueue
implements MessageQueue, Disposable

A message queue that uses Redis as the underlying storage.

Examples

Example 1

import { createFederation } from "@fedify/fedify";
import { RedisMessageQueue } from "@fedify/redis";
import { Redis } from "ioredis";

const federation = createFederation({
  // ...
  queue: new RedisMessageQueue(() => new Redis()),
});

Constructors

new
RedisMessageQueue(
redis: () => Redis,
)

Creates a new Redis message queue.

Methods

enqueue(
message: any,
): Promise<void>
enqueueMany(
messages: any[],
): Promise<void>
listen(
handler: (message: any) => void | Promise<void>,
): Promise<void>

New Ticket: Report package

Please provide a reason for reporting this package. We will review your report and take appropriate action.

Please review the JSR usage policy before submitting a report.

Add Package

deno add jsr:@fedify/redis

Import symbol

import { RedisMessageQueue } from "@fedify/redis/mq";
or

Import directly with a jsr specifier

import { RedisMessageQueue } from "jsr:@fedify/redis/mq";

Add Package

pnpm i jsr:@fedify/redis
or (using pnpm 10.8 or older)
pnpm dlx jsr add @fedify/redis

Import symbol

import { RedisMessageQueue } from "@fedify/redis/mq";

Add Package

yarn add jsr:@fedify/redis
or (using Yarn 4.8 or older)
yarn dlx jsr add @fedify/redis

Import symbol

import { RedisMessageQueue } from "@fedify/redis/mq";

Add Package

vlt install jsr:@fedify/redis

Import symbol

import { RedisMessageQueue } from "@fedify/redis/mq";

Add Package

npx jsr add @fedify/redis

Import symbol

import { RedisMessageQueue } from "@fedify/redis/mq";

Add Package

bunx jsr add @fedify/redis

Import symbol

import { RedisMessageQueue } from "@fedify/redis/mq";