Thanks for giving us the begning steps in ActiveMQ springboot integration. i was able to use both Queue and topic from same application using jmstemplate and setting it as pubsub as true and false.
Thanks man. I was actually planning to make a part two of this video about pub/sub in activeMQ using topics. Great to know you were able to implement these capabilities.
Great tutorial to get started. the only thing for me that didnt work is the setConcurrency(5-10) which I put in my code in the Activemq admin console there only one consumer and not 5. I'll try to figure that out myself.
Hello, this is @Kirivuth from Cambodia and the video is a good knowledge. anyway can we have another video demo how to get the message from the MQ Thanks,
Hey man. Can you tell what exactly the problem is? I'm using maven to get all my dependencies. You can just make use of Spring Initializr to easily get the spring dependencies for this project like the spring-boot-starter-activemq and spring-boot-starter-web. start.spring.io/
Hi Nice video. I just want to understand in this video you have set concurrency 5-10.Which means minimum 5 and maximum 10 consumers can be created. So in this each consumer will receive separate message? Means will each message deliver to exactly one consumer? Or are they thread safe or we need to take care about thread safety?
A message can only be delivered to a certain consumer at any given time. So for example, if you initially set 5 consumers (lower limit) then only one of those 5 consumers can receive the message. It's the broker who takes care of the routing. If more messages are coming in, making the initial 5 consumers insufficient then it will scale up as necessary up to the max limit of consumers that you set. With regards to thread safety, I think that each listening consumer will be running on its own thread so thread safety is not guaranteed and you must handle it on your own. ~ AJ of Bridging Code
hi, at time i am able to push the messages to the queue. but listeners are not able receive the message. This is not happening all the time and if the issue is there I have to restart the application to continue. Am i missing some thing?
@@BridgingCode yes. as i have mentioned, the listener is working for few minutes after application starts up and then after few messages being pushed , its not listening anymore.
@@joelgeorge1064 Okay. I can't really get a clear context of your issue from here. But I do have some suspicions which may or may not be helpful for your case, so please bear with me. 1. It's possibly a network issue. Router, firewall or whatever (I'm not good with network stuff) that automatically closes your tcp connection during inactivity. You might wanna search up about enabling heart beats on ActiveMQ connections, which I have not tried yet. 2. How are you acknowledging the message, or are you certain that you're acknowledging them at all? ActiveMQ has this configuration called "prefetch buffer" and if you exceed this limit with your messages going unacknowledged, it may cause your listener app to stop working. Please verify that you're able to properly acknowledge the incoming messages from listener side.
@@BridgingCode i resolved it by adding folloing line activeMQConnectionFactory.setTrustedPackages(Arrays.asList("com.mq.active.model")); where package name should be SystemMessage package.Thanks for providing first steps in activemq.
Thank you for your video! Is it possible to use ActiveMQ to send a file to the client? For instance, we have an application (which can be used by multiple users at the same time) that has CRUD operations. Also, in the Frontend we have a button to create an excel file and send it to the user that pressed the button. How can we implement something like this? Do we need something else other than ActiveMQ to make this functionality?
I think you can send a file through ActiveMQ by first converting it to a ByteMessage. You can google the code for that. I'm not really sure about your other requirements so I probably can't give you a credible advice, but if you have like an MVC done in Java EE or Spring, just remember that any file upload would have to be taken as a type of java.io.File. Now you can convert this to ByteMessage and send it over to your queue.
Why are the activemq username and password being displayed in plain text view in application.properties? Shouldn't passwords be kept private and secure?
Literally everyone knows that, thanks for bringing up a common knowledge. Obviously, this is just for demonstration purposes so I couldn't care less. But please, do try out the credentials in the video and check if you can login, if that's something that bothers you. Do you have anything that's actually about the topic of this content?
Thanks for giving us the begning steps in ActiveMQ springboot integration. i was able to use both Queue and topic from same application using jmstemplate and setting it as pubsub as true and false.
Thanks man. I was actually planning to make a part two of this video about pub/sub in activeMQ using topics. Great to know you were able to implement these capabilities.
great and easy explanation. thank you so much
Great tutorial to get started. the only thing for me that didnt work is the setConcurrency(5-10) which I put in my code in the Activemq admin console there only one consumer and not 5. I'll try to figure that out myself.
Hi video is awesome I have just started learning ActiveMQ. Thanks man.
thanking you for the best explanation
Could you please share a github repo link for the code used in your demo?
Well explained also please explain how to listen from a different domain and production
Great work sir
Hello, this is @Kirivuth from Cambodia and the video is a good knowledge. anyway can we have another video demo how to get the message from the MQ
Thanks,
bro,do you know why some people creating connection ,session,producer ,consumer object by themselves for implementing activemq? was that old way?
Thanks Man, that was so helpful (y)
I am not able to import springframework how did you do that? Please reply asap
Hey man. Can you tell what exactly the problem is? I'm using maven to get all my dependencies. You can just make use of Spring Initializr to easily get the spring dependencies for this project like the spring-boot-starter-activemq and spring-boot-starter-web. start.spring.io/
Responded from a my personal account earlier. Hope this solved your issue.
Hi Nice video. I just want to understand in this video you have set concurrency 5-10.Which means minimum 5 and maximum 10 consumers can be created. So in this each consumer will receive separate message? Means will each message deliver to exactly one consumer? Or are they thread safe or we need to take care about thread safety?
A message can only be delivered to a certain consumer at any given time. So for example, if you initially set 5 consumers (lower limit) then only one of those 5 consumers can receive the message. It's the broker who takes care of the routing. If more messages are coming in, making the initial 5 consumers insufficient then it will scale up as necessary up to the max limit of consumers that you set. With regards to thread safety, I think that each listening consumer will be running on its own thread so thread safety is not guaranteed and you must handle it on your own.
~ AJ of Bridging Code
Thanks can you please upload few vidios of various configurations of active mq in spring boot.
hi, at time i am able to push the messages to the queue. but listeners are not able receive the message. This is not happening all the time and if the issue is there I have to restart the application to continue. Am i missing some thing?
Hi. Did you configure your broker URL correctly? Did you also set the correct queue name in destination param of JmsListener annotation?
@@BridgingCode yes. as i have mentioned, the listener is working for few minutes after application starts up and then after few messages being pushed , its not listening anymore.
@@joelgeorge1064 Okay. I can't really get a clear context of your issue from here. But I do have some suspicions which may or may not be helpful for your case, so please bear with me.
1. It's possibly a network issue. Router, firewall or whatever (I'm not good with network stuff) that automatically closes your tcp connection during inactivity. You might wanna search up about enabling heart beats on ActiveMQ connections, which I have not tried yet.
2. How are you acknowledging the message, or are you certain that you're acknowledging them at all? ActiveMQ has this configuration called "prefetch buffer" and if you exceed this limit with your messages going unacknowledged, it may cause your listener app to stop working. Please verify that you're able to properly acknowledge the incoming messages from listener side.
@@BridgingCode i resolved it by adding folloing line activeMQConnectionFactory.setTrustedPackages(Arrays.asList("com.mq.active.model")); where package name should be SystemMessage package.Thanks for providing first steps in activemq.
Great video, thank you
Very helpful.. thanks
Thank you for your video! Is it possible to use ActiveMQ to send a file to the client? For instance, we have an application (which can be used by multiple users at the same time) that has CRUD operations. Also, in the Frontend we have a button to create an excel file and send it to the user that pressed the button. How can we implement something like this? Do we need something else other than ActiveMQ to make this functionality?
I think you can send a file through ActiveMQ by first converting it to a ByteMessage. You can google the code for that.
I'm not really sure about your other requirements so I probably can't give you a credible advice, but if you have like an MVC done in Java EE or Spring, just remember that any file upload would have to be taken as a type of java.io.File. Now you can convert this to ByteMessage and send it over to your queue.
@@BridgingCode Thank you!!! 🙂
Nice video
There's no Application A and Application B on this example. You just started one application
thanks sir, it help me a lot
Thank you
Why are the activemq username and password being displayed in plain text view in application.properties? Shouldn't passwords be kept private and secure?
Literally everyone knows that, thanks for bringing up a common knowledge. Obviously, this is just for demonstration purposes so I couldn't care less. But please, do try out the credentials in the video and check if you can login, if that's something that bothers you. Do you have anything that's actually about the topic of this content?
@@BridgingCode are you offended by this question?