My subscriber is non-durable. Performance of non-durable should be better than a durable
one. So, I don't think this will make a difference.
My client code i.e. MessageListener looks like this:
| public class FMEventSubscriber implements MessageListener {
|
| public void onMessage(Message message) {
| if ( message instanceof ObjectMessage){
| ObjectMessage objMessage = (ObjectMessage)message;
| Integer responseMsgType;
| try {
| handleFMEvent(responseMsgType, objMessage.getObject() );
| }catch (Exception e ){
| log.error("Un-Expected error in message processing. ..");
| }
| }else{
| log.error("Unknow type of FM message receiv...");
| }
| }
|
Here, handleFMEvent calls other sessionbeans.
I have noticed that if I comment out the call to handleFMEvent() then the message
processing is fast. But, the main question here is that it(consumer) should not block a
producer.
Do I have the queue up the messages myself and then have a QueueEventprocessor publish the
messages in a background thread?
-Poonam.
View the original post :
http://www.jboss.org/index.html?module=bb&op=viewtopic&p=4266756#...
Reply to the post :
http://www.jboss.org/index.html?module=bb&op=posting&mode=reply&a...