jms

How to ignore hostname in SSH tunnel

Here is a trivia question for any ssh/ssl experts. In our corporate office we have a JMS app (Tibco EMS) running on a server behind a firewall which blocks most ports. I can ssh into this server but can not send messages to the JMS app because the port isn't open. So using putty I created an ssh tunnel to the server so that instead of s...

How to resend a message from the JBoss 4.2.2 message queue after retry expired

Is there a way to resend expired messages in a JBoss 4.2.2 message queue? The issue is they exceeded their retry amounts, but now the problem is fixed, so is there a way to resend them? In JBoss 3 they were just text files that you could move around. Now that it is stored in a database, how can you do it? ...

How do specify clientId and subscriptionName for EJB3 message driven bean durable subscription without hard coding the values?

I have a server running JBoss4.2.1 containing a JMS Topic. I also have multiple terminals, each running their own JBoss with an EJB3 message driven bean that need to subscribe to the topic using durable subscriptions. Since each subscription needs to specify a unique clientId and subscriptionName I can't hard code the values in the Activ...

WebSphere MQ using JMS

I have an application that uses WebSphere MQ Java API along with a configuration (xml) file to access MQ. I would like to migrate to WebSphere JMS API. For this i try creating 1) WebSphere MQ Queue Connection factory and 2) WebSphere MQ Queue destinations from my local WAS. When i configure my Queue destinations and try to set my MQ Con...

importing an existing x509 certificate and private key in Java keystore to use in ActiveMQ ssl context

I have this in activemq config <sslContext> <sslContext keyStore="file:/home/alex/work/amq/broker.ks" keyStorePassword="password" trustStore="file:${activemq.base}/conf/broker.ts" trustStorePassword="password"/> </sslContext> I have a pair of x509 cert and a key file How do I import those two to be used in ssl and ssl+st...

How do I remove messages from a JBoss JMS Topic?

I have configured my Topic in jbossmq-destinations-service.xml as follows: <mbean code="org.jboss.mq.server.jmx.Topic" name="jboss.mq.destination:service=Topic,name=myTopicName"> <depends optional-attribute-name="DestinationManager"> jboss.mq:service=DestinationManager</depends> <depends optional-attribute-name="Secur...

ATOM for messaging service for "enterprise"

I went to Jim Webber presentation and in the middle of his apresentation he stated that ATOM is a good replace for JMS in many cases. Since JMS is a messaging service, I'm curious about that. Are you guys using ATOM as a messaging service? Is it reliable and scalable? The greatest advantage of JMS is that it uses the push method (the se...

Weblogic 10 - JMS - This RJVM has already been shutdown

Any idea why the following errors comes up.This is happening when posting a JMS message to a queue deployed on Admin server from the application on managed server. 009-06-02 11:21:18,688 (com.xxx.util.servicelocator.ServiceLocator:612) ERROR - Error while loading Queue ProfilerNotify javax.naming.CommunicationException [Root exception ...

Spring JMS Message Listener Container

Hi, I'm new to JMS and I am working on setting up ActiveMQ with Tomcat 6 and Spring. I have most of the basic things configured however I'm a little bit confused with the Message Listener Containers that Spring provides. Reading the documentation it sounds like the Message Listener Container is used to "handle" subscribing (I'm worki...

OpenMQ 4.2 cluster stops delivering messages

Hi. We have a system running an application connecting to a cluster of OpenMQ brokers (non-HA). It's been running for about a week without restart. This week we noticed the cluster stopped delivering messages to the consumers (I believe these were the messages on second broker). After checking it in the morning we saw it did not deliver ...

SocketException in ActiveMQ when exiting listener application

Hi, I am currently setting up a Tomcat Server that is running an embedded ActiveMQ broker. I'm using Spring to configure JMS. I wrote a test application to listen to topics and when I exit the test application the ActiveMQ broker throws a SocketException. Here is the exception: 2009-06-09 13:12:48,005 DEBUG Transport:229 - Transpor...

Platform independent streams

We have two systems, one based on JMS and another based on MQ series. There is client A which send a message to a Topic configured in JMS. Another client B which receives this message through the Topic configured in MQ series. How can I make this communication happen? What are the considerations while building this bridge? If bridge is ...

Do you know any good introduction to JMS for IBM MQ (MQSeries) person?

I've been looking for a good JMS introduction for the person who knows IBM MQ (MQSeries) very well. She is very experienced working with MQ-based systems on mainframe, but she asked me about the overview of the JMS to see how JMS relates to MQ and what is important when implementedin the application using JMS provided by MQ. Any URLs wou...

Display contents of Oracle AQ SYS.AQ$_JMS_TEXT_MESSAGE

I have an application that uses JMS op top of Oracle advanced queuing. I would like to do a query on the queue table that shows the content of the message (which in my case is XML). So when I do a 'select user_data from [queue_table]' I get 'AQ SYS.AQ$_JMS_TEXT_MESSAGE' as a response. Is there a function so that the contents of this me...

How to gracefully shut down a Spring JMS MessageListenerAdapter

I have a message handler, which consumes from a JMS queue and that sends results to another JMS queue. The message handler lives in a Spring DefaultMessageListenerContainer. When the container shuts down, I would like for it to finish handling any requests that it already consumed and send out the results. At the same time, it should no ...

Real world use of JMS/message queues ?

I was just reading abit about JMS and Apache ActiveMQ. And was wondering what real world use have people here used JMS or similar message queue technologies for ? ...

Sending messages to a remote JMS Topic

I am writing a small utility to send JMS messages to a remote server, but I am failing to configure correctly the InitialContext (or so it seems) code to init the Context: Properties p = new Properties(); p.put(Context.INITIAL_CONTEXT_FACTORY, "org.jnp.interfaces.NamingContextFactory"); p.put(Context.URL_...

Post a message to a remote JMS queue using JBoss

This looks simple but I can't find a simple answer. I want to open a connection to a remote JMS broker (IP and port are known), open a session to the a specific queue (name known) and post a message to this queue. Is there any simple Java API (standard if possible) to do that ? EDIT Ok I understand now that JMS is a driver spec jus...

JMS File Store tuning

We are using Weblogic JMS as the JMS provider for our application. We use file store as the persistent store. Is there any mechanism to condfigure the file store size so that after the file has reached the specified size, a new file is generated. Right now I have seen that all the messages till today are persisted into one single file. I...

How can I test a JBossMQ JMS Queue with JMeter

I'd like to use JMeter test that I can send a message to a JBossMQ (JBoss 4.2.3 JMS Queue). If I get that far then I will be able to build some load and other tests. JBoss is pretty much straight out of the box and is a server called servername. Since there are some queues set up by default, lets use Queue A which according to ${JBOSS_H...