jms

ActiveMQ Consumer / Producer Connection Listener

I can't seem to find a way to listen for new producer and consumer connections (or connection interrupts) in ActiveMQ (Java Version). I want to be able to tell the consumers (or they can find out themselves) that the producer's connection dropped. The other way around (the producer finding out that a certain consumer disconnected) is als...

OPEN MQ - Help with asynchronous

Hi guys, I'm testing open MQ for send and receive messages in my project. I have no problem to configure it to send a synchronous message, but i can't find any way in the official documentation to configure the message to be consumed 15 minutes after the producer send a message, and continue call the consumer if an error appears. offic...

.NET to consume BW Soap over JMS Service

Hi All, I am able to consume a BW Soap over HTTP service in C#.NET but struggling with BW Soap over JMS Service. When I included the WSDL file under web references and compiled. Here is the warning that is displayed. "At least one import binding for the ServiceDescription is an unsupported type and has been ignored" My understanding...

Best solution for Java HTTP push (messaging)

We want to push data from a server to clients but can only use HTTP (port 80). What is the best solution for messaging? One idea is Comet. Are there other ideas or frameworks which offer lets say JMS over HTTP. (Yes, ActiveMQ supports it too, but waggly IMHO. And JXTA supports it too but the configuration is complicated. Something simple...

How to Request-Response JMS with JMeter + Weblogic

I'm sending a message to a Queue using JMeter. At the end of the process (3 MDBs talking among them) a response message is sent to a second Queue. Using JMeter Request Only everything goes fine, but my interest is to collect the time taken to a message reach the second Queue. Using JMeter with Request Response and the second Queue JNDI...

How can we have JBOSS MDB retry its connection if it fails at startup?

Hello all. We have a server app that is deployed across to server machines, each running JBOSS 4.2.2. We use JBOSS messaging with MDBs to communicate between the systems. Currently we need to start the servers in a very specific order so that JBOSS can connect properly. If a server starts and doesn't see its resources it never tries agai...

Python message oriented middleware (i.e. JMS for Python)

What message oriented middle ware with a Python API are out there? What ones did you use and recommend (or not)? ...

Maximum number of messages sent to a Queue in OpenMQ ?

I am currently using Glassfish v2.1 and I have set up a queue to send and receive messages from with Sesion beans and MDBs respectively. However, I have noticed that I can send only a maximum of 1000 messages to the queue. Is there any reason why I cannot send more than 1000 messages to the queue? I do have a "developer" profile setup fo...

DefaultMessageListenerContainer not working with Websphere MQ

Hello everyone, I am using spring 2.5.6 and spring-integration 1.0.3 and MQ client 6.0.2.2 I have had to add a message selector to my message-driven-channel-adapter, but now I am getting the following error: MQJMS2008: failed to open MQ queue ; nested exception is com.ibm.mq.MQException: MQJE001: Completion Code 2, Reason 2085 It wor...

Using Websphere MQ with JMS from a .NET application.

I'm trying to send a message to a java server over a Websphere MQ which uses JMS as the transport protocol. I can happily drop messages on the MQ using the IBM supplied libraries, but the server rejects them. I'm assuming (hopefully correctly) that this is because I'm missing various JMS specific headers/properties on the MQ message. ...

PostgreSQL and JMS (Or other Pub-Sub/Callback Mechanism)

I want to have my PostgreSQL server send out notifications when a piece of data changes, preferably over JMS, but also considering any other Pub-Sub mechanism or Callback. Any ideas if this is possible? Are there any available Java Add-on Packages that replicate this sort of functionality? ...

post message to a remote JMS provider

I want to be able to send messages to a remote JBoss server (JBoss MQ). I can do it for a local one but i'm stuck when trying with a remote one. can anyone explain to me how to do it ? are there any specific steps to take ? [what i've tried so far] I need to send a message to a remote server's queue (running "JBoss MQ") so that it ca...

Does Pentaho Kettle have a way to accept JMS messages?

Does Pentaho's ETL system, Kettle (http://kettle.pentaho.org/) have a plugin to accept information from JMS messages? I'd like to set up a job that can read messages each containing a hash, extract certain data, and stuff it into a table. Has anyone had any experience with this? Is this a good idea? Any pitfalls? Thanks. ...

How to optimize activemq

I'm using ActiveMQ on a simulation of overloading servers in Java. And mainly it goes ok, but when I get over 600 requests the thing just go WTF! I think the bottleneck is my Master Server which is this guy below. I'm already reusing the connection and creating various sessions to consume messages from clients. Like I said, I'm using a...

Is it possible to have a JMS server without an application server?

Hi, does anyone here knows if there exists a JMS server that could be executed on Tomcat or without an application server? ...

Anyone using multicast with ActiveMQ

I'm having trouble setting up multicast transport using ActiveMQ. I noticed with version 5.2 there is a bug that prevents it from even building the correct factory (fixed in 5.3). The fact this bug exists makes me wonder if anyone is using multicast at all. How can this be tested when it only recently has been enabled? Just knowing that...

Enabling global transactions on WAS for MQ + JDBC data sources

Can someone help me with the settings required for enabling global transactions on a queue listener and data source. I am able to achieve it with database, but my listeners stop working I am using following configuration for it: <tx:jta-transaction-manager/> <jms:listener-container connection-factory="jmsConnectionFactory" transaction-...

ActiveMQ: how to dequeue older messages?

Hi, I'm learning how to use ActiveMQ and now we are facing the following problem. Suppose that I have a topic named topic.test on ActiveMQ which have two subscribers. In a given moment, I have only one of those subscribers waiting for messages, and a producer send a message for the topic I mentioned above. Ok, the connected subscriber...

Deliver JMS message to all nodes in the cluster in Weblogic

Is there a way to configure WebLogic 9.x cluster to receive a JMS message on a single JMS queue address from remote client and that the message is delivered to each cluster node? Any links would be great. ...

Jboss and OPEN MQ integration

Hello can anyone help me integrating OPENMQ (resource adaptor) into JBOSS 4.0.3 . ...