A High-Speed Data Ingestion Solution in Java Using MQTT, AMQP, STOMP, and Virtual Threads

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.

Juarez Junior

Software Engineering, Solutions Architecture, Developer Relations

Dublin, Ireland


Please note that Sessionize is not responsible for the accuracy or validity of the data provided by speakers. If you suspect this profile to be fake or spam, please let us know.

Jump to top