#AMQP

Fedify: an ActivityPub server framework's avatar
Fedify: an ActivityPub server framework

@[email protected]

now has an driver! This means you can use as Fedify's message queue. To use it, first install the @fedify/amqp package, then set it up like below:

import { createFederation } from "@fedify/fedify";
import { AmqpMessageQueue } from "@fedify/amqp";
import { connect } from "amqplib";

const federation = createFederation({
  queue: new AmqpMessageQueue(await connect("amqp://localhost")),
  // ... other configurations
});

Oh, and we've also added results from AmqpMessageQueue to our benchmarks.

The results of the benchmarks for Fedify's outbox queue.
Arturo's avatar
Arturo

@[email protected] · Reply to Arturo's post

📣 New Hop release 🎉

An client wrapper that provides easy work queue semantics

v1.0.0: github.com/mazingstudio/hop

Enhancements:
- AMQP channel pooling
- Connection recovery

Breaking Changes:
- `NewQueue` is no longer public

Arturo's avatar
Arturo

@[email protected]

New package 🎉

Hop — An client wrapper that provides easy work queue semantics

v0.1.0: github.com/mazingstudio/hop

Check it out and let me know if it's missing anything! 🙌