You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by cc...@apache.org on 2009/04/02 06:53:44 UTC

svn commit: r761167 - /servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/AbstractConsumerEndpoint.java

Author: ccustine
Date: Thu Apr  2 04:53:44 2009
New Revision: 761167

URL: http://svn.apache.org/viewvc?rev=761167&view=rev
Log:
SMXCOMP-497 - Successful InOnly MEP rolling back messages to JMS queue
- Change formatting to match 3.2 branch (making PMD happy)

Modified:
    servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/AbstractConsumerEndpoint.java

Modified: servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/AbstractConsumerEndpoint.java
URL: http://svn.apache.org/viewvc/servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/AbstractConsumerEndpoint.java?rev=761167&r1=761166&r2=761167&view=diff
==============================================================================
--- servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/AbstractConsumerEndpoint.java (original)
+++ servicemix/components/bindings/servicemix-jms/trunk/src/main/java/org/apache/servicemix/jms/endpoints/AbstractConsumerEndpoint.java Thu Apr  2 04:53:44 2009
@@ -427,10 +427,11 @@
 
     protected void processExchange(final MessageExchange exchange, final Session session, final JmsContext context) throws Exception {
         if (exchange instanceof InOnly) {
-            if ((ExchangeStatus.ERROR.equals(exchange.getStatus())) && (marshaler instanceof DefaultConsumerMarshaler)) {
-                if (((DefaultConsumerMarshaler)marshaler).isRollbackOnError()) {
-                    throw exchange.getError();
-                }
+            if ((ExchangeStatus.ERROR.equals(exchange.getStatus()))
+                && marshaler instanceof DefaultConsumerMarshaler
+                && ((DefaultConsumerMarshaler)marshaler).isRollbackOnError()) {
+
+                throw exchange.getError();
             }
             // For InOnly exchanges, ignore DONE exchanges or those where isRollbackOnError is false
             return;