TorqueBox 3.1.2

org.torquebox.messaging
Class MessageProcessor

java.lang.Object
  extended by org.projectodd.polyglot.messaging.BaseMessageProcessor
      extended by org.torquebox.messaging.MessageProcessor
All Implemented Interfaces:
javax.jms.MessageListener, org.hornetq.api.core.client.MessageHandler

public class MessageProcessor
extends org.projectodd.polyglot.messaging.BaseMessageProcessor


Field Summary
static org.jboss.logging.Logger log
           
 
Constructor Summary
MessageProcessor()
           
 
Method Summary
protected  void clearCurrentRuntime()
           
protected  void commitXATransaction()
           
protected  void ensureCurrentRuntime()
           
 void onMessage(javax.jms.Message message)
           
protected  void prepareTransaction()
           
protected  void rollbackXATransaction(Throwable e)
           
 
Methods inherited from class org.projectodd.polyglot.messaging.BaseMessageProcessor
getConsumer, getCoreSession, getGroup, getHornetQSession, getSession, getTransactionManager, initialize, isXAEnabled, onMessage
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

log

public static final org.jboss.logging.Logger log
Constructor Detail

MessageProcessor

public MessageProcessor()
Method Detail

onMessage

public void onMessage(javax.jms.Message message)

prepareTransaction

protected void prepareTransaction()
Overrides:
prepareTransaction in class org.projectodd.polyglot.messaging.BaseMessageProcessor

rollbackXATransaction

protected void rollbackXATransaction(Throwable e)

commitXATransaction

protected void commitXATransaction()

ensureCurrentRuntime

protected void ensureCurrentRuntime()
                             throws Exception
Throws:
Exception

clearCurrentRuntime

protected void clearCurrentRuntime()

TorqueBox 3.1.2

Copyright © 2015 JBoss by Red Hat. All Rights Reserved.