Displaying 1 to 18 from 18 results

primus - :zap: Primus, the creator god of the transformers & an abstraction layer for real-time to prevent module lock-in

  •    Javascript

Primus, the creator god of transformers but now also known as universal wrapper for real-time frameworks. There are a lot of real-time frameworks available for Node.js and they all have different opinions on how real-time should be done. Primus provides a common low level interface to communicate in real-time using various real-time frameworks.If you deploy your application behind a reverse proxy (Nginx, HAProxy, etc.) you might need to add WebSocket specific settings to its configuration files. If you intend to use WebSockets, please ensure that these settings have been added. There are some example configuration files available in the observing/balancerbattle repository.

wsify - Just a tiny, simple and real-time self-hosted pub/sub messaging service

  •    Go

I wanted to create a tiny solution that can replace pusher and similar services and learning more about the realtime world, so I dispatched this project.

mubsub - Pub/sub for Node.js and MongoDB

  •    Javascript

Mubsub is a pub/sub implementation for Node.js and MongoDB. It utilizes Mongo's capped collections and tailable cursors to notify subscribers of inserted documents that match a given query. A channel maps one-to-one with a capped collection (Mubsub will create these if they do not already exist in the database). Optionally specify the byte size of the collection and/or the max number of documents in the collection when creating a channel.




Portage - Fast pub/sub for JS

  •    Javascript

Works with AMD, CommonJS, global (as portage) and ES6.Portage is utilizing a tree structure to quickly match publications with subscriptions; including support for subscriptions with wild cards (see below).

pubjs - A node.js templating language with arbitrary nesting

  •    Javascript

Yet another node.js templating system. It differs from all others we've seen because it offer arbitrary nesting of code and HTML output.

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.

transmitter - A tiny pub sub library that just subscribes and publishes

  •    Javascript

Subscribes to change events. Returns an object which contains the method dispose which removes the current subscription. Emit a change to all the subscribers.


mqemitter - An Opinionated Message Queue with an emitter-style API

  •    Javascript

An Opinionated Message Queue with an emitter-style API, but with callbacks. MQEmitter is the class and function exposed by this module. It can be created by MQEmitter() or using new MQEmitter().

mqstreams - MQ pub/sub as streams - based on mqemitter

  •    Javascript

Publish-Subscribe node streams style, based on mqemitter. Extends the MQEmitter with the readable() and writable() methods.

multines - Multi-process nes backend, turn nes into a fully scalable solution

  •    Javascript

Multi-process nes backend, turn nes into a fully scalable solution. multines connect multiple instances of Hapi and nes through an external pub/sub broker, currently only redis and mongodb are supported.

leverage - Leverage provides awesome (lua) enhancements on top of the regular redis client for Nodejs

  •    Javascript

Leverage is an abstraction on top of the fabulous redis client for Node.js. It makes it much easier to work with lua scripting in Redis as well as provide some some missing features in Redis through the power of lua scripting. To introduce these methods, the module searches for a lua or leverage folder in the root of your application folder (which contains the node_modules folder that has this module installed). It only accepts files with a .lua extension. These files will be introduced as methods on the Leverage prototype. So if you have a hello.lua file in the leverage folder we will automatically make a leverage.hello() method.

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.

oja - Structure your application business logic - lightweight pub/sub module with event backlog, timeout support that maps events to promises and back as well as chains them to other topics

  •    Javascript

Lightweight pub/sub module with event backlog, timeout support that maps events to promises and back as well as chains them to other topics. Use it to structure application business logic. The main reason for creation of this module is to allow decoupling business logic into smaller isolated stage components in the application via pub/sub API that leads to a simpler/isolated unit testing with easy mocking of input data and easy composition of components into higher async structures.

multipub - Clustered redis pub/sub

  •    Javascript

Multi-redis pub/sub allowing you to publish and subscribe to and from N redis nodes. Options are passed to node_redis's .createClient().

WatchUsBuild-ImageStreamingAppWithNodePubSubServer

  •    Javascript

We changed the name of this series to "Watch Us Build," so you may see an occasional reference to its former name ("Soup to Bits") in this repository. This repo is the source code for the Code School Node.js Watch Us Build Pub/Sub Server.

tab-emitter - :speech_balloon: An event emitter for same-origin tab communication

  •    Javascript

tab-emitter is a client-side javascript module that allows you to send events between browser tabs/windows. The sending/recieving web pages must have the same origin. You can not emit events between browsers, only between the same browser. tab-emitter is written to work with browserify, and is extremely easy to implement in your code.