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

Recommended Pages
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 application that manages immutable event without any notion of a pre-defined lifecycle. An event-driven application is a stateful application that: ingest events from one or more event streams...
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 publish-subscribe messaging system rethought 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

Something happened (Event), subscribe to it (Streams) Stream processing = transformations on stream data A pipeline is a query on a stream. Streaming Processing is also known as Incremental Processing....

Share this page:
Follow us:
Task Runner