Stream - Messaging System

Event Centric Thinking


Messaging systems implements near-realtime asynchronous computation. A messaging system is a fairly low-level piece of infrastructure—it stores messages and waits for consumers to consume them as stream source.

Messages can be added to:

when something happens.

Downstream consumers read messages from these systems, and process them or take actions based on the message contents.

Can birds deliver messages ?


Suppose you have a website, and every time someone loads a page, you send a “user viewed page” event to a messaging system. You might then have consumers which do any of the following:

  • Store the message in Hadoop for future analysis
  • Count page views and update a dashboard
  • Trigger an alert if a page view fails
  • Send an email notification to another user
  • Join the page view event with the user’s profile, and send the message back to the messaging system

A messaging system lets you decouple all of this work from the actual web page serving.

Same as Event-Data Application.

Documentation / Reference

Discover More
Event Centric Thinking
(Stream|Pipe|Message Queue|Event Processing)

From an abstract point of view, a stream is a sequence of aninfinite cardinality (size) delivered at unknown time intervals. list Streams: are inputs and outputs of operations may be also buffers...
Event Centric Thinking
Data Stream - Source (Provider)

The stream source is the source of the stream (known also as the provider) Finite collection (list, sequence,...) Iteration See
Card Puncher Data Processing
Event-Data Application

are event-driven application that reports / analyze the immutable event collected (without any notion of a pre-defined lifecycle). An event-driven application is a stateful application that: ingest...
HTML - (Cross-document|Web) Messaging

Two mechanisms for communicating between browsing contexts in HTML documents. A messaging system that allows documents to communicate with each other regardless of their source domain, in a way designed...
Java Conceptuel Diagram
Java - Java Message Service (JMS)

The JMS is a messaging standard that allows J2EE application components to create, send, receive, and read messages. It enables distributed communication that is loosely coupled, reliable, and asynchronous....
Kafka Commit Log Messaging Process
Kafka (Event Hub)

Apache Kafka is a broker application that stores the message as a distributed commit log. The entire data storage system is just a transaction log. |data feeds Data Systems are exposing data, ...
Event Centric Thinking
Stream - Message Queue System

Message Queue System is one type of implementation of a messaging system It's a stream source RabbitMQ, Beanstalkd, ActiveMQ, IBM MQ Series, Tuxedo Amazon SQS If the server fails,...
Event Centric Thinking
Stream - Processing

Stream processing is the reactive design of data processing. Something happened (Event), Subscribe to it (Streams) Streaming Processing is also known as : Incremental Processing. or reactive...
Card Puncher Data Processing
What is an Event Driven Architecture (EDA)?

This page is the architecture components of a event driven architecture. It's publish-subscribe messaging system. A receives messages (event) from publishers and delivers them to subscribers. ...
Card Puncher Data Processing
What is an Event-Driven processing model?

An event-oriented model is a system that is driven from an event point of view, not from a state point of view. Ie: when an event occurs, transformation happens to the entities that change their...

Share this page:
Follow us:
Task Runner