The spec says "Acknowledging a consumed message automatically acknowledges the receipt of all messages that have been delivered by its session" - but what I need to know is what it means by 'delivered'. For example, if I call consumer.receive() 6 times, and then call .acknowledge on the 3rd message - is it (a) just the first 3 messages...
For the following scenario I am looking for your advices and tips on best practices: In a distributed (mainly Java-based) system with: many (different) client applications (web-app, command-line tools, REST API) a central JMS message broker (currently in favor of using ActiveMQ) multiple stand-alone processing nodes (running on multip...
I am currently evaluating JMS and I don't get what I could use it for. Currently, I believe this would be a Usecase: I want to create a SalesInvoice PDF and print it when an SalesOrder leaves the Warehouse, so during the Delivery transaction I could send a transactional print request which just begins when the SalesOrder transaction co...
Hi All, I'm pretty new to the JMS functionality. I need to test a remote JMS which is on Jboss 4.2.1. I want to develop an external test (e.g from a main class) which sends and receives messages to/from the app. server. (I do have full access to the remote server.) My questions are: 1) How do I send messages to the Jboss JMS? 2) Wh...
Suppose I decide to call acknowledgment() on a JMS message several times. Say the first call fails (for non-permanent reason). Does the success of the second (or any subsequent) call guarantee that the message is now acknowledged? Is the exact behavior of acknowledgement() specified anywhere? ...
As a seasoned Spring user I was assuming that Spring Integration would make the most sense in a recent project requiring some (JMS) messaging capabilities (more details). After some days working with Spring Integration it still feels like a lot of configuration overhead given the amount of channels you have to configure to bring some req...
Hello - We are stumped and looking for advice.. Were running: jdk1.6.0_20 , jboss-5.1.0.GA, messaging-2.0.0.BETA4 And trying to add a Topic or Queue but we are getting this error: Failed to add Resource: java.lang.IllegalStateException:Failed to find template for: TopicTemplate any advice? ...
Hello, I am trying to deploy a spring message message driven POJO on weblogic 8.1. It is a simple POJO, and it works fine being run outside of an application server, but the messages do not seem to be picked up at all. I have created empty home and remote interfaces, as well as a container bean class that contains an instance of the poj...
What is the most likely root cause of the following exception: [weblogic.jms.common.TransactionRolledBackException: Attempt to resume an inactive transaction: BEA1-72F9873FF02A158778E0:error resuming transacted session's internal transaction]; attempts will be made to (re-)start message delivery (auto reconnect mode). ...
Note that I'd like multiple message listeners to handle successive messages from the topic concurrently. In addition I'd like each message listener to operate transactionally so that a processing failure in a given message listener would result in that listener's message remaining on the topic. The spring DefaultMessageListenerContaine...
Is it possible to send complex messages via JMS? I can send TextMessages, Messages etc .. but when I try to send my custom object type MyObject trough send() method of MessageProducer I get compile error. Then I tried to cast it, I get cast exception like MyObject cannot be cast to javax.jms.Message Here is a code I tried : MessagePro...
I'm trying to send a JMS message from one JBoss AS 5.1 instance to the other. For my test I have them both running on localhost, the client JBoss AS instance with the normal port settings and the server JBoss AS with the setting where all ports are offset by 100. In an EAR project on the client, I've defined a JMS provider loader in a f...
I have Java programs running on various machines (A) that should send messages via server (B) to Flex clients running on other machines (C). The server is running a Grails (Java) application on Tomcat with standalone ApacheMQ and the whole setup is currently working nicely using GraniteDS to communicate between Grails and Flex. (The way ...
I am using Embedded ActiveMQ for sending messages from Server to Client using NetworkConnector using a static address and using a local Broker URL to connect to this Network Connector. This is working fine when Network Connectivity betweeen Local Machine(local URL) and NetworkConnector URL is present. However, when connectivity fails bet...
Is there a (Linux) command to move all messages from one queue in Websphere MQ 6 to another queue? I have a queue that has a defined backout queue, but I want to know how to transfer all the messages back to the original queue once the error preventing the messages from being processed has been corrected. Is there a GUI tool that can d...
I have a java class Processor that is listening to a jms topic and it is struggling to keep up with the speed in which messages are arriving so we've decided to go concurrent: A single class listening to the topic who's job is to hand the messages out to a pool of worker threads, effectively being a load balancer. It also has to preven...
Hi, Im doing a JMS project. can anybody point out a reference on running ActiveMQ(JMS) on two different pc using eclipse on both pc? tnx -jaded ...
Hi, I was wondering if there is any way to receive JMS messages from some provider like ActiveMQ or WebMQ in a Haskell program. I've seen that there is a Haskell client for ActiveMQ but it seems to be unmaintained. Has anybody experience with this or any kind of advise? ...
I am trying to execute the following command MQConnectionFactory connFactory = new MQConnectionFactory(); and i get a null pointer that i can't seem to track down, i have attached the stack trace, any help would be greatly appreciated. java.lang.NullPointerException at com.ibm.msg.client.jms.internal.JmsFactoryFactoryImpl.getIns...
Hi all ActiveMQ experts! I had a look via WireShark what's happening under the hood when ActiveMQ "/examples" producer sends messages and it revealed that every TextMessage shorter than 1000 bytes is padded with spaces (' ' or HEX 20) until it fills exactly 1000 bytes. (using the ActiveMQ's "native" transport - TCP "OpenWire") Wonder w...