Category: apache Activemq

Apache ActiveMQ – Features ”; Previous Next ActiveMQ is designed to provide high availability, scalability, reliability, performance and security for enterprise level messaging applications. Following are some of the salient features of ActiveMQ. JMS Compliant − ActiveMQ is fully compliant with JMS 1.1 standards. JMS spec provides a standard mechanism for synchronous or asynchronous message delivery, once-and-only-once message delivery, message durability for subscribers, etc. Connectivity Options − ActiveMQ supports HTTP/S, multicast, SSL, Stomp, TCP, UDP, XMPP, thus providing a wide range of options for connectivity and allows various systems to communicate using their choice of protocols. Pluggable Architecture − ActiveMQ allows to choose a persistence mechanism and also provides options to customize security for authentication and authorization as per the application needs. Multi-Platform − ActiveMQ provides client APIs for many popular languages like Java, C, C++, .NET, Perl, PHP, Python, Ruby etc. ActiveMQ Broker will run in JVM but clients can be written using any of the supported languages. Broker Cluster − ActiveMQ allows to prepare a network of brokers for scalability and can support different types of topologies. Features Rich − ActiveMQ provides many advanced features for both broker and clients and support Apache Camel. Simple Administration Interface − ActiveMQ administration console is easy to use but still provides many powerful administration features. Print Page Previous Next Advertisements ”;

Apache ActiveMQ – Environment Setup ”; Previous Next This chapter will guide you on how to prepare a development environment to start your work with ActiveMQ. It will also teach you how to set up JDK, Maven and Eclipse on your machine before you set up ActiveMQ − Setup Java Development Kit (JDK) You can download the latest version of SDK from Oracle”s Java site − Java SE Downloads. You will find instructions for installing JDK in downloaded files, follow the given instructions to install and configure the setup. Finally set PATH and JAVA_HOME environment variables to refer to the directory that contains java and javac, typically java_install_dir/bin and java_install_dir respectively. If you are running Windows and have installed the JDK in C:jdk-11.0.11, you would have to put the following line in your C:autoexec.bat file. set PATH=C:jdk-11.0.11;%PATH% set JAVA_HOME=C:jdk-11.0.11 Alternatively, on Windows NT/2000/XP, you will have to right-click on My Computer, select Properties → Advanced → Environment Variables. Then, you will have to update the PATH value and click the OK button. On Unix (Solaris, Linux, etc.), if the SDK is installed in /usr/local/jdk-11.0.11 and you use the C shell, you will have to put the following into your .cshrc file. setenv PATH /usr/local/jdk-11.0.11/bin:$PATH setenv JAVA_HOME /usr/local/jdk-11.0.11 Alternatively, if you use an Integrated Development Environment (IDE) like Borland JBuilder, Eclipse, IntelliJ IDEA, or Sun ONE Studio, you will have to compile and run a simple program to confirm that the IDE knows where you have installed Java. Otherwise, you will have to carry out a proper setup as given in the document of the IDE. Setup Eclipse IDE All the examples in this tutorial have been written using Eclipse IDE. So we would suggest you should have the latest version of Eclipse installed on your machine. To install Eclipse IDE, download the latest Eclipse binaries from www.eclipse.org/downloads/. Once you download the installation, unpack the binary distribution into a convenient location. For example, in C:eclipse on Windows, or /usr/local/eclipse on Linux/Unix and finally set PATH variable appropriately. Eclipse can be started by executing the following commands on Windows machine, or you can simply double-click on eclipse.exe %C:eclipseeclipse.exe Eclipse can be started by executing the following commands on Unix (Solaris, Linux, etc.) machine − $/usr/local/eclipse/eclipse After a successful startup, if everything is fine then it should display the following result − Set Maven In this tutorial, we are using maven to run and build the spring based examples to run ActiveMQ based applications. Follow the Maven – Environment Setup to install maven. Download ActiveMQ You can download the latest stable version of ActiveMQ from its official page. Follow the Download ActivMQ to download ActiveMQ. We”ve used the 5.13.4 released on Feb 15th, 2022. Extract the content of archive in the folder of your choice. We”ve extracted to F:/ → Apache → apache-activemq-5.16.4. Print Page Previous Next Advertisements ”;

Apache ActiveMQ – Admin Console ”; Previous Next Once ActiveMQ server is up and running. You can use the admin console to manage queues, topics, subscribers, connections, network etc. Open http://127.0.0.1:8161/admin/ in your browser. It will ask for credentials. Use admin/admin as username/password and it will load the ActiveMQ admin console where you can check Queues, Topics, Connections etc. Queue Click on Queue tab, enter a queue name as testQueue and click on create button. Now you can see the queue in the list. Topic Similarly, you can create Topic and check topics in Topics tab. Others In the same way, you can explore subscribers, connections, network bridges, schedulers details. Send Send tab allows to send a JMS Message to a particular queue or topic by specifying the destination and other details. Print Page Previous Next Advertisements ”;

Apache ActiveMQ – Running Broker Server ”; Previous Next We”ve downloaded the latest version of ActiveMQ as mentioned in ActiveMQ – Environment Setup. Now go to the folder F:/ → Apache → apache-activemq-5.16.4/bin and type the following command. Example F:Apacheapache-activemq-5.16.4bin>activemq start Output You”ll see the similar output and ActiveMQ will start running. Java Runtime: Oracle Corporation 11.0.11 C:Program FilesJavajdk-11.0.11 Heap sizes: current=1048576k free=1041918k max=1048576k JVM args: -Dcom.sun.management.jmxremote -Xms1G -Xmx1G -Djava.util.logging.config.file=logging.properties -Djava.security.auth.login.config=F:Apacheapache-activemq-5.16.4bin..conflogin.config -Dactivemq.classpath=F:Apacheapache-activemq-5.16.4bin..conf;F:Apacheapache-activemq-5.16.4bin../conf;F:Apacheapache-activemq-5.16.4bin../conf; -Dactivemq.home=F:Apacheapache-activemq-5.16.4bin.. -Dactivemq.base=F:Apacheapache-activemq-5.16.4bin.. -Dactivemq.conf=F:Apacheapache-activemq-5.16.4bin..conf -Dactivemq.data=F:Apacheapache-activemq-5.16.4bin..data -Djava.io.tmpdir=F:Apacheapache-activemq-5.16.4bin..datatmp Extensions classpath: [F:Apacheapache-activemq-5.16.4bin..lib,F:Apacheapache-activemq-5.16.4bin..libcamel,F:Apacheapache-activemq-5.16.4bin..liboptional,F:Apacheapache-activemq-5.16.4bin..libweb,F:Apacheapache-activemq-5.16.4bin..libextra] ACTIVEMQ_HOME: F:Apacheapache-activemq-5.16.4bin.. ACTIVEMQ_BASE: F:Apacheapache-activemq-5.16.4bin.. ACTIVEMQ_CONF: F:Apacheapache-activemq-5.16.4bin..conf ACTIVEMQ_DATA: F:Apacheapache-activemq-5.16.4bin..data Loading message broker from: xbean:activemq.xml INFO | Refreshing org.apache.activemq.xbean.XBeanBrokerFactory$1@53fe15ff: startup date [Sat Feb 26 12:50:18 IST 2022]; root of context hierarchy INFO | Using Persistence Adapter: KahaDBPersistenceAdapter[F:Apacheapache-activemq-5.16.4bin..datakahadb] INFO | PListStore:[F:Apacheapache-activemq-5.16.4bin..datalocalhosttmp_storage] started INFO | Apache ActiveMQ 5.16.4 (localhost, ID:DESKTOP-86KD9FC-52669-1645860020983-0:1) is starting INFO | Listening for connections at: tcp://DESKTOP-86KD9FC:61616?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector openwire started INFO | Listening for connections at: amqp://DESKTOP-86KD9FC:5672?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector amqp started INFO | Listening for connections at: stomp://DESKTOP-86KD9FC:61613?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector stomp started INFO | Listening for connections at: mqtt://DESKTOP-86KD9FC:1883?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector mqtt started INFO | Starting Jetty server INFO | Creating Jetty connector WARN | [email protected]@4f966719{/,null,STARTING} has uncovered http methods for path: / INFO | Listening for connections at ws://DESKTOP-86KD9FC:61614?maximumConnections=1000&wireFormat.maxFrameSize=104857600 INFO | Connector ws started INFO | Apache ActiveMQ 5.16.4 (localhost, ID:DESKTOP-86KD9FC-52669-1645860020983-0:1) started INFO | For help or more information please see: http://activemq.apache.org INFO | ActiveMQ WebConsole available at http://127.0.0.1:8161/ INFO | ActiveMQ Jolokia REST API available at http://127.0.0.1:8161/api/jolokia/ Verification Now open http://127.0.0.1:8161/admin/ in your browser. It will ask for credentials. Use admin/admin as username/password and it will load the ActiveMQ admin console where you can check Queues, Topics, Connections etc. Print Page Previous Next Advertisements ”;

Apache ActiveMQ – Consumer Application ”; Previous Next Now let”s create a consumer application which will receive message from the ActiveMQ Queue. Create Project Using eclipse, select File → New → Maven Project. Tick the Create a simple project(skip archetype selection) and click Next. Enter the details, as shown below − groupId − com.tutorialspoint artifactId − consumer version − 0.0.1-SNAPSHOT name − ActiveMQ Consumer Click on Finish button and a new project will be created. pom.xml Now update the content of pom.xml to include dependencies for ActiveMQ. <project xmlns=”http://maven.apache.org/POM/4.0.0″ xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance” xsi:schemaLocation=”http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd”> <modelVersion>4.0.0</modelVersion> <groupId>com.tutorialspoint.activemq</groupId> <artifactId>consumer</artifactId> <version>0.0.1-SNAPSHOT</version> <name>ActiveMQ Consumer</name> <dependencies> <dependency> <groupId>org.apache.geronimo.specs</groupId> <artifactId>geronimo-jms_1.1_spec</artifactId> <version>1.1</version> </dependency> <dependency> <groupId>org.apache.qpid</groupId> <artifactId>qpid-jms-client</artifactId> <version>0.40.0</version> </dependency> </dependencies> <build> <plugins> <plugin> <groupId>org.apache.maven.plugins</groupId> <artifactId>maven-compiler-plugin</artifactId> <version>2.1</version> <configuration> <source>1.6</source> <target>1.6</target> </configuration> </plugin> <plugin> <groupId>org.fusesource.mvnplugins</groupId> <artifactId>maven-uberize-plugin</artifactId> <version>1.14</version> <executions> <execution> <phase>package</phase> <goals><goal>uberize</goal></goals> </execution> </executions> </plugin> </plugins> </build> </project> Now create a Consumer class which will receive message from the ActiveMQ Queue. package com.tutorialspoint.activemq; import java.io.Console; import javax.jms.Connection; import javax.jms.Destination; import javax.jms.Message; import javax.jms.MessageConsumer; import javax.jms.MessageProducer; import javax.jms.Session; import javax.jms.TextMessage; import org.apache.qpid.jms.JmsConnectionFactory; public class Consumer { public static void main(String[] args) throws Exception { // Create a connection to ActiveMQ JMS broker using AMQP protocol JmsConnectionFactory factory = new JmsConnectionFactory(“amqp://localhost:5672”); Connection connection = factory.createConnection(“admin”, “password”); connection.start(); // Create a session Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); // Create a queue Destination destination = session.createQueue(“MyFirstQueue”); // Create a consumer specific to queue MessageConsumer consumer = session.createConsumer(destination); Console c = System.console(); String response; do { // Receive the message Message msg = consumer.receive(); response = ((TextMessage) msg).getText(); System.out.println(“Received = “+response); } while (!response.equalsIgnoreCase(“Quit”)); // Close the connection connection.close(); } } Consumer class creates a connection, starts the session, creates a consumer and then receives message from queue if there is any. If queue contains quit as message then application terminates else it will keep polling queue for messages. We”ll run this application in ActiveMQ – Test Application chapter. Print Page Previous Next Advertisements ”;