Jboss EAP 7 - Configure (ActiveMQ) JMS in EAP 7

[@joesphkuruvila5571]

Thank you so much for such a great content sir 🙏 i personally think contacting you for learning JBoss was the best decision i made .Thank you so much for being calm and making me understand even the smallest details regarding jboss and the mock interview we had.Its only because of your preparation and mock i was able to clear my interview.Forever grateful sir 🙏Bless you !!

[@navdeepbhatia5030]

Thanks for sharing Sir , very useful ,saved lot of time

[@166.62]

Thank you Veera.You explained it properly and it is very helpful.

[@LearningJboss]

Thanks

[@middleclassmaheshmcm9740]

Thankq so much Bro 🙏👍

[@lagoawb]

Thank you Veera for sharing this.

[@rjcdz06]

Excelent explanation !

[@nisargashinde5696]

Thanks alot... It is really helpful

[@joca1128]

Hello i am from Colombia, I have a question, Do i need to integrate the activeMQ implementation of apache to jboss to do this or jboss already has the implementation and all i need to use it for JMS services? and the steps shown here are the same for widfly21?

[@chrischen3627]

very helpful!

[@devjyotidey7165]

What jars are used in the jms client program?

[@ashish23081991]

thanks for making this

[@noureddinelahia2036]

good work thanks

[@maverick_9922]

+Learning Jboss : this video helped me a lot to understand queue clustering. Question: how will the system react for "topic" clustering? Will all servers in the cluster receive the topic's message?

[@haroldadrianbolanos]

do you have any example whit topic but another remote instancie where is working a topic? i have a problem, when I use another instance like standalone_02

[@devjyotidey7165]

Got all the jars correct now. But getting "Unable to validate even after creating a user with guest role

[@LearningJboss]

See the below code or you can get it from standard GIT github.com/wildfly/quickstart OR import java.util.logging.Logger; import java.util.Properties; import javax.jms.ConnectionFactory; import javax.jms.Destination; import javax.jms.JMSConsumer; import javax.jms.JMSContext; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; public class HelloWorldJMSClient { private static final Logger log = Logger.getLogger(HelloWorldJMSClient.class.getName()); // Set up all the default values private static final String DEFAULT_MESSAGE = "Hello"; private static final String DEFAULT_CONNECTION_FACTORY = "jms/RemoteConnectionFactory"; private static final String DEFAULT_DESTINATION = "jms/queue/DistributedQueue"; private static final String DEFAULT_MESSAGE_COUNT = "10"; private static final String DEFAULT_USERNAME = "admin"; private static final String DEFAULT_PASSWORD = "admin123"; private static final String INITIAL_CONTEXT_FACTORY = "org.jboss.naming.remote.client.InitialContextFactory"; private static final String PROVIDER_URL = "http-remoting://127.0.0.1:8080"; public static void main(String[] args) { Context namingContext = null; try { String userName = System.getProperty("username", DEFAULT_USERNAME); String password = System.getProperty("password", DEFAULT_PASSWORD); // Set up the namingContext for the JNDI lookup final Properties env = new Properties(); env.put(Context.INITIAL_CONTEXT_FACTORY, INITIAL_CONTEXT_FACTORY); env.put(Context.PROVIDER_URL, System.getProperty(Context.PROVIDER_URL, PROVIDER_URL)); env.put(Context.SECURITY_PRINCIPAL, userName); env.put(Context.SECURITY_CREDENTIALS, password); namingContext = new InitialContext(env); // Perform the JNDI lookups String connectionFactoryString = System.getProperty("connection.factory", DEFAULT_CONNECTION_FACTORY); log.info("Attempting to acquire connection factory \"" + connectionFactoryString + "\""); ConnectionFactory connectionFactory = (ConnectionFactory) namingContext.lookup(connectionFactoryString); log.info("Found connection factory \"" + connectionFactoryString + "\" in JNDI"); String destinationString = System.getProperty("destination", DEFAULT_DESTINATION); log.info("Attempting to acquire destination \"" + destinationString + "\""); Destination destination = (Destination) namingContext.lookup(destinationString); log.info("Found destination \"" + destinationString + "\" in JNDI"); int count = Integer.parseInt(System.getProperty("message.count", DEFAULT_MESSAGE_COUNT)); String content = System.getProperty("message.content", DEFAULT_MESSAGE); try (JMSContext context = connectionFactory.createContext(userName, password)) { log.info("Sending " + count + " messages with content: " + content); // Send the specified number of messages for (int i = 0; i < count; i++) { context.createProducer().send(destination, content); } // Create the JMS consumer /* JMSConsumer consumer = context.createConsumer(destination); // Then receive the same number of messages that were sent for (int i = 0; i < count; i++) { String text = consumer.receiveBody(String.class, 5000); log.info("Received message with content " + text); }*/ } } catch (NamingException e) { log.severe(e.getMessage()); } finally { if (namingContext != null) { try { namingContext.close(); } catch (NamingException e) { log.severe(e.getMessage()); } } } } }

[@CarlosRafaelLabradaArceperfil]

thanks

[@pranytt3485]

Thank you Veera for sharing this. Really appreciate it. It helped me learn jboss eap with activemq quickly for diagnosing a production issue. I have a question. You have shown how to see message and delete a message. But the displayed data doesn't show "Hello" which is the actual message you published. How do we see the actual payload of the message on the topic/queue ? It seems ActiveMQBrowser_2.5.2.8ForJDK1.6 can do this but it works using jmx. If I want to connect using jmx to the activemq broker that comes with EAP, what endpoint should I use? How to find this information? Thanks

[@rexsam3134]

on a Windows based EAP 7.3, this option of Runtime - Subsystems is not visible for the ActiveMQ

[@LearningJboss]

I guess there is no difference in jboss windows or Linux level . For both same software bundle will use

[@rexsam3134]

@@LearningJboss I meant even if I add in the xml file the activemq is not visible. Tried using jboss-cli command too. Will try with EAP 7.0 now

[@LearningJboss]

It's visible only on standalone-full.xml and standalone-full-ha.xml only

[@rexsam3134]

@@LearningJboss Thanks Veera I was using the Eclipse to launch the same rather than the command prompt where you specified one of the xml file

[@vijaytomar5503]

Thank you Veera, it was really helpful. I followed this video and configured AMQ in my machine. Thanks a lot.... I need one more help, We are using EAP 7 and AMQ broker 7.2.0 and I am trying to connect this AMQ 7 using springs in beans but actually not able to get through, could you please help me in this regard. It will be really helpful.

[@stanislaviliev4869]

Hello Vijay Tomar , do you have any success to connect this AMQ 7 using springs in bean, because I'm trying to do the same thing. If you have success with that please share you experience will be very helpfull

[@balajisn]

Hi Veera, The video is really useful. Have a question. Do we have any setup to trigger custom java code for out bound queue? I need to perform some DB operation as soon as message is queued. And don't want to run any utility(Standalone java utility) for this.

[@LearningJboss]

Hi Balaji, Thanks for watching my videos :) . I am not into java but , Yes you can do custom trigger just do some r & d on MDB Listener !!.

[@balajisn]

Thank you for the quick reply. I will look into it.

[@mohanbabu1715]

Hi sir, Can you explain what is JMS , the importance of JMS and why we need to use JMS in jboss.

[@LearningJboss]

Mohan Babu please go through below URL given best real time example stackoverflow.com/questions/1035949/real-world-use-of-jms-message-queues

[@mohanbabu1715]

Thank you very much Sir,that was very useful.Can you explain the configuration of SSL in jboss.

[@LearningJboss]

Mohan Babu sure soon I upload SSL topic

[@mohanbabu1715]

Sir,can you please send me that programing code or any link from where i can copy that code?

[@LearningJboss]

use below link to download all EAP7 projects demo. github.com/jboss-developer/jboss-eap-quickstarts

[@vijo3510]

I need your help veera

[@javierparedes2410]

Hello, thanks for the video. I ask you a question, I'm trying (without success) to connect Jboss 6.4 to an IBM MQ Series. Do you have any instructions that can help me? The truth is that I have tried everything I found on the internet and I can not make it work. I configure the resource "wmq.jmsra.rar", but then I can not reach it from my code. I do not understand how a Connection Factory is configured. From already thank you very much Regards!

[@anuragray7121]

Hi veera, Thanks for the video.I am facing security exception even after adding the user to application realm with guest group.please suggest

[@LearningJboss]

what is the exception , can you paste here.

[@gdevelek]

Please do a complete job and provide the Java code you used... Thanks.

[@LearningJboss]

You can download each module related projects and import into eclipse and start work. github.com/wildfly/quickstart

[@gdevelek]

Yes I can, but your code doesn't seem to be in there. Either I'm missing something or you don't want to share it like so many other youtubers do when they post instructional videos.

[@LearningJboss]

github.com/wildfly/quickstart/blob/master/helloworld-jms/src/main/java/org/jboss/as/quickstarts/jms/HelloWorldJMSClient.java

[@nareshv555]

Hi Veera ..i am trying to write consumer.As your screen is not visible fully not able to understand how you created context..can you please share your java file

[@LearningJboss]

github.com/veeras/helloworld-mdb github.com/veeras/helloworld-jms

[@nareshv555]

@@LearningJboss thanks for quick response

[@shivakumarbhootham4576]

could you please send source code