Right now I'm getting this exception from a simple JMS client I wrote to just test to see if I can connect to the JBoss JMS. Here is the snippet of my code below: Properties props = new Properties(); props.setProperty("java.naming.factory.initial","org.jnp.interfaces.NamingContextFactory"); props.setProperty("java.naming.fac...
I'm trying to create an Apache Camel route that sends a jms message to a topic and if it does not receive a reply within a certain amount of time it starts a route using Spring DSL. The problem I am having is that it appears the foTopic call is asynchronous. I expect it to block and wait for a message or until the timeout is reached,...
I configured a queue and a QueueConnectionFactory using the V5 Messaging provider in WAS6.1. I also have a ListenerPort configured for this destination. Now it throws an exception when I try to connect to this queue using the queue connection factory or when the Message Listener listening to this ListenerPort starts up. javax.jms.JMSExc...
Is there an easy way of copying off the properties from one JMS message to another? I can imagine something like this: private void copyMessageProperties (Message msg1, Message msg2) throws JMSException { Enumeration srcProperties = msg1.getPropertyNames(); while (srcProperties.hasMoreElements()) { String pr...
Hi All , I am trying to publish the messages from the .Net to the weblogic jms queues.I am using the weblogic .net api for this .I can successfully send the text messages but when i try to send the large messages , I am getting exception - can not marshall string larger than 32767 characters.I tested it and i can send messages with char...
So far I have seen non-Java client support only for open source message brokers like Apache ActiveMQ, JBoss HornetQ and Open Message Queue (OpenMQ). Are there also closed-source products like WebSphere, WebLogic or Tibco which offer non-Java access to their MOM brokers, using a documented wire protocol (opposite to a closed-source binar...
Hello, We have a WMQ - WAS/JMS client setup through server connection channels where we are trying to put in security through user Ids. Now, we set up a local user id on the MQ box, mquserid, and left the channel's MCAUSER blank. We thought: the id running the MQ client (WAS in our case) wasuserid, when passed to MQ will fail as it is...
I am working on a multithreaded JMS receiver and publisher code. XML message is received from a Queue, stored procedures(takes 70 sec to execute) are called and response is send to Topic within 90 sec. I need to handle a condition when broker is down. i.e. a condition in which messages are received from Queue and are being processed in ...
Hello, I´m new in this area and I am experiencing the following issue: 2010-09-02 17:18:37,499 ERROR [org.jboss.resource.adapter.jms.inflow.JmsActivation] {WorkManager(2)-3} Unable to reconnect org.jboss.resource.adapter.jms.inflow.JmsActivationSpec@e733bb(ra=org.jboss.resource.adapter.jms.JmsResourceAdapter@329cb9 destination=queue/A...
Concerning ActiveMQ: I have a scenario where I have one producer which sends small (around 10KB) files to the consumers. Although the files are small, the consumers need around 10 seconds to analyze them and return the result to the producer. I've researched a lot, but I still cannot find answers to the following questions: How do I ma...
Hi, I want to load balance JMS messages using message selectors. A message has a property "EntitiyIX". The selectors shall be like: "EntitiyIX Modulus 2 == 0" ==> route to queue A "EntitiyIX Modulus 2 != 0" ==> route to queue B What's the operator to calculated the modulus in a JMS message selector? Thanks, Alex ...
Our code runs in weblogic and we MQ 6.0. No matter if I use the default createQueueConnection() or createQueueConnection("myuserid","mypassword") it always seems to use userid mqm. See code below. When I connect from version 6.0 to an older mq installion 5 it seems to throw the following error javax.jms.JMSSecurityException: MQJMS2013: ...
My application does batch processing by reading messages from ActiveMQ. I read using the async JMS API by implementing MessageListener. But I ACK the messages only when the batch processing succeeds by calling message.acknowldge() [1]. What I ideally want is that till the batch processing is going on I do not receive any messages from t...
I have an application in C++, but it'll need to 'talk' to Java based message-service. In the past we used WebSphere MQ and used their C++ libraries to do the 'talking'. So I am in search of (ideally) free C++ to Java solution which doesn't hold the whole JVM in memory. The other option I've looked into is SOAP. I've looked into Axis2...
Sites like Twitter and Facebook scale to hundreds of thousands of users. Most of their architectural overviews are available online as talks and slideshows. However, my question is more oriented towards any messaging middleware/layer that these sites use. I understand that it would be different for different sites - but are there any com...
Edited Question : I am working on a multithreaded JMS receiver and publisher code (stand alone multithreaded java application). MOM is MQSonic. XML message is received from a Queue, stored procedures(takes 70 sec to execute) are called and response is send to Topic within 90 sec. I need to handle a condition when broker is down or appli...
I am looking for something which is just a single jar file prerably and I can run with: java -jar jarname.jar ...
Howdy, I'm running into problems with JMS in Oracle AS 10.1.3.3. The error I am getting is 'connectors\ojms.rar (The system cannot find the path specified)' from EM. Below are a few bullets on the environment. This is on a Windows XP SP3 machine. All configuration is through EM. The EM is a local instance that has been used for ov...
What is the best free, or GNU licensed JMS server. We want something that is easy to install and will "just work" without too much intervention on our part. We are open to other non JMS and even non Java messing solutions, but there would have to be a compelling reason to use a different non Java based solution with our Java application...
Hi, how can I configure OpenEJB to work with an external instance of ActiveMQ? We already tried the configuration on this link http://openejb.apache.org/3.0/jms-resources-and-mdb-container.html but it did'nt work at all. What should we do? ...