#AMQP

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

@fedify@hollo.social

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.
ALT text detailsThe results of the benchmarks for Fedify's outbox queue.
Arturo's avatar
Arturo

@arturovm@mastodon.social · 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

@arturovm@mastodon.social

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! 🙌