Apache ActiveMQ "Message Queue" and its implementation using java

Hello Guys , Hope you all are doing good , Today we will learn more about activemq so lets get start.

What is ActiveMQ ?
Apache ActiveMQ ™ is the most popular and powerful open source messaging and Integration Patterns server.

Apache ActiveMQ is fast, supports many Cross Language Clients and Protocols, comes with easy to use Enterprise Integration Patterns and many advanced features while fully supporting JMS 1.1 and J2EE 1.4. Apache ActiveMQ is released under the Apache 2.0 License

It provide message queue which we can use to publish our message and can create subscriber to get the data from message topic

What is the use of Active MQ ?
Active MQ  where "MQ" stands for message queue  is widely used for the distributed systems where we want one system should not wait for the other system to complete it task , so what basically we do , we provide active mq where one (System A) complete it task put the data in message queue and starts working on other task , (System B ) will get the data stored in message queue by System A and will starts its working on that also , there is a Data delivery Guarantee also a key feature.

So lets see the implementation of Active MQ using java

Download the ActiveMQ Server from here : DOWNLOAD NOW

Maven Dependency

<dependency>
    <groupId>org.apache.activemq</groupId>
    <artifactId>activemq-core</artifactId>
    <version>5.7.0</version>
</dependency>

<dependency>
    <groupId>com.thoughtworks.xstream</groupId>
    <artifactId>xstream</artifactId>
    <version>1.4.10</version>
</dependency>

<dependency>
    <groupId>org.apache.httpcomponents</groupId>
    <artifactId>httpclient</artifactId>
    <version>4.5.3</version>
</dependency>




Consumer Code
Producer Code

Main Class

The Full Source Code you can download from my git respository : DOWNLOAD FULL SOURCE

If you have any issue regarding the program execution , leave me a comment , Will try our best to resolve the program

Thanks for reading
-Noeik