jms

Determine number of subscribers per topic in JMS

I'm building a small statistics application for Java Message Service. I have a container with several topic and loads of subscribers (consumers) to each topic. JMS provider: SonicMQ I've gotten the program to the state where I: Create a session Create a MessageConsumer to the topic Listen for messages Collect the statistics And it'...

EJB JMS Timer, any sample?

I am using Spring on Tomcat. I want to use JMS Timer. Is there any example? ...

JMS, Detect when a temp queue is destroyed

I have a "server" application receiving messages from a JMS queue. And client applications which create a temp queue, and then send a message to the server, setting the JMSReplyTo header to the temp queue. The server replies back to the client using the temp queue. However the server has a lot of replies back to the client all sent over...

Message Queues: Are messages lost on network failure?

I am wondering about the reliabilty of message delivery in messaging systems such as WebsphereMQ or ActiveMQ (used via JMS). As far as I know messages can be buffered if the recepient is unavailable and will be delivered later. Now I am wondering what happens if the sender temporarily cannot reach the network. Is there some kind of loca...

Why is this being garbage collected

My developers and I are having an issue with objects being garbage collected in our application when we don't want them to be. We are using Java with Weblogic 10g3. We are programming a singleton pattern to handle all of our JMS connections. There are two classes involved: public class JMSObject { ... private MessageProducer _produce...

How to Configuring ConnectionFactory JMS on JBossAS5?

Hi Friends.. :) This is the first my question in this forum.. :) please help me about how to configuring JMS ConnectionFactory on JBossAS5.. i have created a simple MDB application : @MessageDriven(name = "MessageMDBSample", activationConfig = { @ActivationConfigProperty(propertyName = "destinationType", propertyValue = "javax.jms...

Messaging Middleware - how to avoid reentrance with wildcard subscription?

Messaging middleware solutions (JSM, Tibco, etc.) allow publish/subscribe with "topic" filtering using wildcards to subscribe to all messages of a certain "topic", e.g. SUBSCRIBE("ACCOUNT.*") topic allows you to subscribe to both "ACCOUNT.WITHDRAW" message and "ACCOUNT.CHECKBALANCE" message. The problem is that such subscription also re...

JMS bridge in WebSphere 7.0

How can I define a JMS bridge in WebSphere 7.0 application server? ...

Threads or JMS Which is better?

If i want to run a process (time taken to complete this process is in hours) in multi-user environment (thru tomcat-servlet) Which is better to implement this process in? 1) In Threads or 2) In JMS what are advantages and disadvantages? ...

Sharing JMS and Hibernate transactions in a Spring MDB using Oracle Streams AQ?

I'm using Oracle 11g for my database and its Oracle Streams AQ feature as JMS implementation. For all I know, it should be possible to implement a Spring based message-driven POJO (MDP) that uses the same data source for both transactional data access and JMS transactions -- all without XA-Transactions (IIRC, this was marketed as a feat...

JMS Performance: BytesMessage vs ObjectMessage

In terms of JMS performance, I have read that ObjectMessage should be avoided for performance reasons. How bad are ObjectMessage performance-wise? Should I serialize to a BytesMessage and manually deserialize? ...

JMS without JNDI?

We are running portlets in WebSphere 6.01, using Java 1.4. We want to send JMS messages to a JBoss 5 queue, running Java 5 (or maybe 6, but it's certainly newer than 1.4). Trying to connect using JNDI is not working, since we have to include the JBoss client jars in the classpath of the portlet, and they are Java 1.5. So I get an unsuppo...

Does Terracotta make JMS an unneeded layer?

We're currently writing an application for which IT has already purchased hardware for. Their approach was to buy big hardware on which we would deploy. In order to add more processing, they plan on adding additional servers with identical software. In order to accomodate this design, we are using Terracotta to provide the ability to run...

How to pause JMS topic subscriber from receiving messages

My setup: JBoss Messaging 1.4 running on JBoss 4.2.3 I have a couple of MDB's that subscribes on one topic, and the MDB's onMessage() tries to deliver the received message to one web service each. My problem is that I can't figure out how to pause the subscriptions in the case when the web service is offline. My plan is to do the foll...

ActiveMQ c++ tutorial

Does anyone recommend a good tutorial on JMS with c++ and ActiveMQ? ...

JBoss Messaging per EAR configuration

I'm using JBoss Messaging 1.4.3.GA (inside JBoss AS 5.1.0.GA). I'm packaging the definitions of my queues inside my EAR using an mbean. This means applications can define and use queues without having to change our company's stock JBoss installation. Is it possible to configure message persistence on a per application basis (inside the ...

JMS Websphere MQ BytesMessge and TextMessage

I have a Java application that sets a listener on a queue, the onMessage(Message) gets a subclass of javax.jms.TextMessage, how can i make it get a subclass of javax.jms.BytesMessage Note: I don't have access to the application that sends the messages. ...

How to create custom object pools in Java application server

Suppose I have a message driven bean (MDB) in a Java application server. The MDB receives a message from a JMS queue and passes it to a message processor. In my case, a message processor is an extremely heavy weight object that requires extensive initialization so I don't want to create a new one to handle each message. Instead I would l...

JNDI Context :: Name jms not bound in this Context

I am trying to configure a JMS server (OpenJMS) into a Spring application and when I refer the resources using the notation "jms/<> I get a "name" not bound exception. Any clue what is missing? javax.naming.NameNotFoundException: Name jms is not bound in this Context at org.apache.naming.NamingContext.lookup(NamingContext.java:768)...

How can I get this external JMS client to terminate?

I'm working through the 'Simple Point-to-Point Example' section of the Sun JMS tutorial (sender source, receiver source), using Glassfish as my JMS provider. I've set up the QueueConnectionFactory and Queue in the Glassfish admin UI, and added the relevant JARs to my classpath and the receiver is receiving the messages sent by the sende...