Hi. I have already working Camel configuration that is watching a database table (through spring and hibernate), and when something shows up in DB, Camel consumes it and sends message to JMS broker. This works flawlessly. And is built in DSL in MyOwnMessageRouteBuilder.configure() Now I'd like to add monitoring that do something if no...
I need to see the messages in Queues and Topics configured on WebSphere 6.1. I tried to configure HermesJMS, but just couldn't make it work. If someone knows how to make it work with WebSphere 6.1, it would be great! Else... what are the alternatives? ...
I'm trying to learn more information on how apache Qpid works and I do so by following examples from official svn : http://svn.apache.org/repos/asf I was looking at : http://svn.apache.org/repos/asf/qpid/trunk/qpid/java/client/example/src/main/java/org/apache/qpid/example/Hello.java Which uses this configuration/property file : htt...
Hi, I have a system based on JMS queues that enable the whole system to work in async fashion. Now, for some periodic tasks I need to execute some non time consuming tasks in sync way, so that I can do something with the result right away, without using a database for storing request and pairing it with result (as with async operation)...
I am running my application on a group of unclustered tomcat servers. It serves restlet web-services. As per restful paradigm, each call is stateless. In this environment, I want the application to periodically review the database for status changes and take action. Since one of the actions is to fire off an email, I want to ensure t...
Hi all, I'm developing a solution to retrieve poison messages from a backout queue in Websphere 6.1. My question is: when this msg (ie. TextMessage) is re-queue from a regular queue to backout queue, what is the queue name in msg.getJMSDestination() and msg.getJMSReplyTo()? For example: I've got a msg with destination to myQueue. Howe...
Hi, I am running a listener program on a JMS queue hosted in Sun Java System Application Server 9.1_02 (build b08-p03) After receiving a message I will extract and log some details in to a log file. I observed that when running listener for really long hours, it stops receiving messages. I had to manually stop the program and start it...
I need to create a variable number of these based on a configuration value, the intention is to have multiple consumers where each corresponds to a physical resource that can only be used by one thing at a time to process the message. ...
I am trying to run a class I made however I get this error: Exception in thread "main" java.lang.NoClassDefFoundError: javax/jms/Destination I don't understand why it's not working even when I include the necessary jars in the classpath: java consumer1 -cp activemq-all-5.3.2.jar ...
Hi, Just wondering if someone knows how to send/receive XML messages between iPhone & Java Message Service. Regards ...
Hi, I have a JSE application which currently uses JMS, it was written by a developer which is no longer with the company. For some reason, I really don't know if it was justified or not, the JMS session were not created as transacted. I now want to change this as to have all Producers using transacted sessions; This in itself is very sim...
I have a JMS queue with a gazillion messages to be processed. I'm going to have a good few listeners that I'm implementing using spring-jms to read from this queue. I'm getting a bit lost on the different ListenerContainers and their possible configurations. My requirements are: Obviously asynchronous processing. No need for transacti...
There is a message(text), which format and content i definitely know. For now,class in Java,that parses and reads this message from file,is implemented. In real world, this message will come from Message Queue. For now I should simulate, mock or generate Message Queue on my local PC for testing purposes. Java spec(java jms): JMS prov...
I have a listener bean which calls on a session beans method in the MDBs onMessage method. If an exception occurs, such as IllegalStateException (which I throw) or NPE, then JBoss keeps logging the exception, and also keeps retrying to deliver the same message, again spamming the logs, then it sends the message to DLQ, and again calls on...
We are in the process of testing OpenEJB solution that embeds ActiveMQ 4.1.1. We observe various problems with messaging (bugs, performance, stability). One option is to upgrade to just released OpenEJB 3.1.3 that comes with later ActiveMQ 5.1.3. But I am trying to evaluate other options in case these problems won't go away. Is it poss...
I am using a message-driven-channel-adapter to read messages off MQ queue, and this has been working fine in development. Now, in preparation for the first production release, I have to read a secured queue instead. What do I need to do? I think I need to make sure the following are set as system properties, but with what values? jav...
I have a stand-alone JMS app that subscribes to several different JMS topics. Each topic has its own session and onMessage() listener. Each onMessage() method updates a common current value table - all the onMessage() methods update the same current value table. I've read that the onMessage method is actually called on the JMS provider'...
Hi, After adding a destination(Queue) to Destination Resources from Admin Console at Resources/JMS Resources/Destination Resources, no physical destinations are displayed at server(Admin Server)/JMS Physical Destinations .Instead, the following error message is displayed below the heading: An error has occured Unable to list JMS Destin...
Dear readers I'm working on updating an existing Mule configuration and the task is to enhance it to route messages to different endpoints depending on some properties of the messages, therefore it would be nice to have some pros and cons on the two options I have at hand: 1) Add properties on the message, using the "message-properties...
In my project I have two JMS queues one data Queue and one Business queue. multiple threads reads data from those two queues and submit it to grid of multiple engines. Grid is having multiple engines which may execute tasks in parallel both sync and async manner. Problem statement : Events from business queue should take priority ov...