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;