Generic PubSub with WCF Support

  •        111

This is a specific implementation of publisher subscriber, in this implementation we can use specific model subscribe and publish instead of string.



Related Projects

Gizmo - A Microservice Toolkit from The New York Times

Gizmo Microservice Toolkit toolkit provides packages to put together server and pubsub daemons with the following features like Standardized configuration and logging, Health check endpoints with configurable strategies, Configuration for managing pprof endpoints and log levels, Structured logging containing basic request information, Useful metrics for endpoints, Graceful shutdowns, Basic interfaces to define our expectations and vocabulary and lot more.

atmosphere-samples - Atmosphere's samples.

Recommended samples for getting started are the chat, which demonstrate usage of all transports using an AtmosphereHandler, or the jquery-pubsub, which demonstrate how to switch from one transport to another using a Jersey Resources. If you are interested to write WebSocket only application, take a look at the atmosphere-websockethandler-pubsub sample. The pubsub sample contains a lot of small demonstration on how the Jersey extension can be used. If you are interested to write HTML5 Server Side Events application, take a look at the atmosphere-sse-xxx samples. If you plan to use Spring or GWT, take a look at their specific samples.

kraken - Distributed Pubsub Server for Realtime Apps

Distributed Pubsub Server for Realtime Apps


Bogor-PubSub is a set of extensions to the Bogor model checker enabling accurate, automatic verification of Publish-Subscribe infrastructures.

watercoolr - pubsub via webhooks

pubsub via webhooks

Generic WCF Hosting Service

The Generic Host Service provides a simple, reusable, and reliable mechanism for hosting WCF services.

Generic Data Storage Component for .Net

This component allows you to save data objects by its XML-Serialization easily in generic data storages (e.g. XML-File, SQL Server database ...)

django-pubsub - A django app to help you create Twitter-like instant notifications

A django app to help you create Twitter-like instant notifications

Aeron - Efficient reliable unicast and multicast transport protocol

Aeron is an efficient reliable unicast and multicast transport protocol. The Aeron protocol is designed to be run directly over many different types of transmission media, including shared memory/IPC, InfiniBand/RDMA, UDP, TCP, Raw IP, HTTP, WebSocket, BLE, etc.

NSQ - A realtime distributed messaging platform in Go

NSQ is a realtime distributed messaging platform designed to operate at scale, handling billions of messages per day. It promotes distributed and decentralized topologies without single points of failure, enabling fault tolerance and high availability coupled with a reliable message delivery guarantee. It scales horizontally, without any centralized brokers. Built-in discovery simplifies the addition of nodes to the cluster.

hermes - Fast and reliable message broker built on top of Kafka.

Hermes is an asynchronous message broker built on top of Kafka. We provide reliable, fault tolerant REST interface for message publishing and adaptive push mechanisms for message sending.Questions? We are on gitter.

graphql-subscriptions - :newspaper: A small module that implements GraphQL subscriptions for Node.js

GraphQL subscriptions is a simple npm package that lets you wire up GraphQL with a pubsub system (like Redis) to implement subscriptions in GraphQL.You can use it with any GraphQL client and server (not only Apollo).

axon - message-oriented socket library for node.js heavily inspired by zeromq

Axon is a message-oriented socket library for node.js heavily inspired by zeromq. For a light-weight UDP alternative you may be interested in punt.Backed by node-amp-message you may pass strings, objects, and buffers as arguments.

WampSharp - A C# implementation of WAMP (The Web Application Messaging Protocol)

The implementation supports WAMPv2 and includes both Json and MsgPack support, and both Router (Broker and Dealer roles) and Client (Publisher/Subscriber and Callee/Caller) roles. See here for a list of implemented advanced profile features.The implementation also supports WAMPv1, both client and server roles.

hemera - 🔬 Writing reliable & fault-tolerant microservices with

Hemera (/ˈhɛmərə/; Ancient Greek: Ἡμέρα [hɛːméra] "day") is a small wrapper around the NATS driver. NATS is a simple, fast and reliable solution for the internal communication of a distributed system. It chooses simplicity and reliability over guaranteed delivery. We want to provide a toolkit to develop micro services in an easy and powerful way. We provide a pattern matching RPC style. You don't have to worry about the transport. NATS is powerful.Hemera has not been designed for high performance on a single process. It has been designed to create lots of microservices doesn't matter where they live. It choose simplicity and reliability as primary goals. It act together with NATS as central nervous system of your distributed system. Transport independency was not considered to be a relevant factor. In addition we use pattern matching which is very powerful. The fact that Hemera needs a broker is an argument which should be taken into consideration when you compare hemera with other frameworks. The relevant difference between microservice frameworks like senecajs, molecurer is not the performance or modularity its about the complexity you need to manage. Hemera is expert in providing an interface to work with lots of services in the network, NATS is the expert to deliver the message at the right place. Hemera is still a subscriber of NATS with some magic in routing and extensions. We don't have to worry about all different aspects in a distributed system like routing, load-balancing, service-discovery, clustering, health-checks ...

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

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.