5 dépôts
Mechanisms for evaluating expressions or tags on the broker to deliver only specific messages to matching consumers.
Distinct from Message Routing: Candidates focus on UI alerts or notification groupings, not broker-level message filtering.
Explore 5 awesome GitHub repositories matching networking & communication · Server-Side Message Filtering. Refine with filters or upvote what's useful.
RocketMQ is a distributed messaging and streaming platform designed for building event-driven applications. It serves as middleware to decouple services using publish-subscribe and request-reply patterns, and functions as a transactional messaging system that ensures atomicity by linking message delivery to local transaction outcomes. The platform includes specialized capabilities as a Kubernetes-native message broker for container orchestration environments and an MQTT broker for ingesting event data from mobile applications and hardware terminals. The system covers high-throughput data str
Filters specific messages using expressions or tags to deliver only relevant data to intended consumers.
Postal is an open-source email infrastructure and self-hosted delivery platform. It functions as an SMTP mail server and inbound email gateway, providing the tools necessary to send and receive email through a privately managed infrastructure. The system manages SMTP infrastructure for outgoing message delivery and provides capabilities for custom email receiving. It allows for the routing of incoming external emails to internal applications or websites for automated processing. The platform includes support for multi-tenant domain mapping, event-driven webhook notifications, and plugin-base
Provides programmable filters for incoming mail to block spam or route messages to specific endpoints.
libzmq is a C++ based asynchronous messaging engine and networking core designed for routing non-blocking messages between distributed nodes. It functions as a distributed message queue that implements the ZMTP wire-format framing protocol to standardize how data moves across different network transport layers. The library provides a multi-transport abstraction that allows a single interface to route data across TCP, IPC, and in-process memory. It incorporates a cryptographic layer to encrypt and authenticate transmissions between nodes and employs topology-based messaging patterns, such as p
Implements broker-level filtering so receivers only process messages matching defined subscription criteria.
Maddy is a modular mail server that assembles a complete email system by connecting small, single-purpose modules through a declarative configuration file. Rather than a monolithic stack, it lets operators compose message processing, storage, authentication, and security enforcement from interchangeable building blocks, with each module handling a specific function like receiving SMTP connections, verifying credentials, or applying policy checks. The server distinguishes itself through its flexible authentication and security architecture. It delegates user verification to external systems in
Contacts a rspamd server over HTTP to evaluate incoming messages and apply spam-filtering decisions.
Console est un outil de gestion basé sur le web pour surveiller et administrer les clusters Kafka. Il fournit une interface graphique pour gérer les topics, les groupes de consommateurs et les flux de données en temps réel. Le projet inclut des gestionnaires dédiés pour Kafka Connect et le Schema Registry, permettant le déploiement de connecteurs de données et la gouvernance des schémas de données. Il dispose d'un tableau de bord de cluster pour suivre la santé des brokers, l'utilisation du stockage et l'état des racks, ainsi qu'une interface pour le contrôle d'accès basé sur les rôles et l'inspection des journaux d'audit. La plateforme couvre la navigation et le filtrage des données, la coordination des groupes de consommateurs et la construction de pipelines de données. Elle prend également en charge la surveillance des tâches de transformation de données et la gestion des autorisations des utilisateurs via un moteur de politique centralisé.
Implements server-side filtering to search for specific records using text queries or partition offsets.