Displaying 1 to 20 from 35 results

amqp.node - AMQP 0-9-1 library and client for Node.JS

  •    Javascript

A library for making AMQP 0-9-1 clients for Node.JS, and an AMQP 0-9-1 client for Node.JS v0.8-0.12, v4-v9, and the intervening io.js releases. This library does not implement AMQP 1.0 or AMQP 0-10.

coworkers - A RabbitMQ Microservice Framework in Node.js

  •    Javascript

Coworkers is a new microservice framework heavily inspired by Koa, which aims to be a simple, robust, and scalable foundation for creating RabbitMQ microservices. Through leveraging generators Coworkers allows you to ditch callbacks and greatly increase error-handling. Coworkers also uses Amqplib, a battle-tested AMQP client, under the hood to communicate with RabbitMQ and has best-practices baked in. Finally, Coworkers enables easy scalability by running each queue-consumer in its own process through node clustering (optional). Note: amqplib is a peer dependency. This give you flexibility in using any compatible version you please. npm@^3 does not install peer dependencies automatically, so you will have to install amqplib yourself.

node-celery - Celery client for Node.js

  •    Javascript

Note: When using AMQP as result backend with celery prior to version 3.1.7 the result queue needs to be non durable or it will fail with a: Queue.declare: (406) PRECONDITION_FAILED. For RabbitMQ backends, the entire broker options can be passed as an object that is handed off to AMQP. This allows you to specify parameters such as SSL keyfiles, vhost, and connection timeout among others.

servicebus - Simple service bus for sending events between processes using amqp.

  •    Javascript

Simple service bus for sending events between processes using amqp. Allows for send/receive and publish/subscribe pattern messaging over RabbitMQ. Simply running multiple versions of Process A, above, will cause servicebus to distribute sent messages evenly accross the list of listeners, in a round-robin pattern.




rabbitmq-perf-test - A load testing tool

  •    Javascript

A Java-based performance testing tool for RabbitMQ.

rabbitmq-website - RabbitMQ website and documentation guides

  •    Javascript

This repository contains source code for rabbitmq.com content.All changes that need to be deployed right away need to be committed to the live branch.

server - The backend server software layer which is the part of ONLYOFFICE Document Server and is the base for all other components

  •    Javascript

The backend server software layer which is the part of ONLYOFFICE Document Server and is the base for all other components.This instruction describes document service deployment for Windows based platform.


rabbus - A micro-service bus with built-in messaging patterns, for NodeJS and RabbitMQ

  •    Javascript

A highly opinionated, yet minimal, set of message bus abstractions for NodeJS. It is built on top of RabbitMQ, with rabbot as the primary library for working with RabbitMQ. The items on the left are "producers" as they produce a message for RabbitMQ to route and handle. Items on the right are "consumers" as they consume a message from a queue in RabbitMQ.

seneca-amqp-transport - Official AMQP transport plugin for Seneca

  •    Javascript

This plugin allows seneca listeners and clients to communicate over AMQP.Important: Starting from 2.2.0 this plugin will require the usage of the --harmony flag in order to run in node versions older than LTS (currently 6.x.x).

NodeRabbitMQAPN - Node.js结合RabbitMQ实现APN推送

  •    Javascript

Apple Push Notification service with Node.js and RabbitMQ. Written and maintained by Henter.

rabbitmq-web-mqtt-examples - Examples for the Web MQTT plugin

  •    Javascript

This RabbitMQ plugin contains few basic examples of RabbitMQ Web MQTT plugin usage. It starts a server that binds to port 15670 and serves a few static HTML files on port 15670 (e.g. http://127.0.0.1:15670). Note that Web STOMP examples use the same port, so these plugins cannot be enabled at the same time unless they are configured to use different ports.

servicebus-retry

  •    Javascript

servicebus-retry adds message acknowledge, reject, and retry capability to servicebus messages. A MemoryStore is available for testing and scenarios where processes to not exit/restart when a message is rejected. A RedisStore is available for multiprocess and crash-oriented design, where processes purposefully crash after a message reject and restart. servicebus-retry causes inocoming messages to have a .handle property with three available functions: acknowledge(fn), ack(fn) (shorthand for acknowledge), and reject(fn). The callback parameter in all methods is optional.

node-amqp-wrapper - A wrapper around https://github

  •    Javascript

A simple wrapper to https://github.com/squaremo/amqp.node. Allows you to have any number of publish queues, one consume queue and to perform consume and publish operations.

hare - Wrapper around amqp that provides a chainable API.

  •    Javascript

Hare is a wrapper around amqp providing a cleaner chainable API for some of the common patterns. Worker queues allow you to ditribute messages to workers, where only one worker will recieve the message. Allowing for the distribution of resource intensive tasks across a worker pool.

qlobber - Node.js globbing for amqp-like topics

  •    Javascript

Node.js globbing for amqp-like topics. The API is described here.

rx-amqplib - RxJS wrapper for the AMQP library from squaremo

  •    Javascript

rx-amqplib is a wrapper for using the squaremo amqplib NodeJS package with RxJS. To include this library in your project, all you need to do is install it using NPM.

rabbit-rpc - Simple RPC using RabbitMQ

  •    Javascript

Send strings, numbers, arrays, objects or buffers. Arguments are serialized to BSON using node-buffalo.