Many solutions face challenges when streaming data from thousands of data sources. Smart cities operating IoT networks with sensors such as temperature, pressure, and flow meters are great examples of applications with devices that generate massive data in the scope of Microservices solutions supporting our cities nowadays.

ActiveMQ is a Java-based open-source message broker that supports REST API and wire-level protocols like MQTT, AMQP, and STOMP.

In this talk, we'll create a Java application with examples for each protocol. Then, we'll use a public dataset. ActiveMQ will support message-oriented middleware (MOM) to communicate between components and Reactive Stream Ingestion (RSI) to inject the data into an Oracle Database efficiently and non-blocking.