You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2012/01/31 14:06:40 UTC
svn commit: r1238481 - in /camel/branches/camel-2.9.x: ./
camel-core/src/main/java/org/apache/camel/
camel-core/src/main/java/org/apache/camel/impl/
camel-core/src/main/java/org/apache/camel/processor/
camel-core/src/main/java/org/apache/camel/util/ co...
Author: davsclaus
Date: Tue Jan 31 13:06:39 2012
New Revision: 1238481
URL: http://svn.apache.org/viewvc?rev=1238481&view=rev
Log:
CAMEL-4961: Added isTransactedRedelivered to Exchange, which allows to better track redelivered messages, from ex JMS brokers. Makes easier to correlate in logs and whatnot. Improved TX logging in TransactedErrorHandler. Polished the scala RichExchange as well, as slight API change in Exchange.
Added:
camel/branches/camel-2.9.x/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTestTest.java
- copied unchanged from r1238463, camel/trunk/components/camel-jms/src/test/java/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTestTest.java
camel/branches/camel-2.9.x/components/camel-jms/src/test/resources/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTestTest.xml
- copied unchanged from r1238463, camel/trunk/components/camel-jms/src/test/resources/org/apache/camel/component/jms/tx/JMSTransactionIsTransactedRedeliveredTestTest.xml
Modified:
camel/branches/camel-2.9.x/ (props changed)
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/Exchange.java
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultExchange.java
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultMessage.java
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java
camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java
camel/branches/camel-2.9.x/components/camel-jaxb/ (props changed)
camel/branches/camel-2.9.x/components/camel-jaxb/src/test/ (props changed)
camel/branches/camel-2.9.x/components/camel-jms/ (props changed)
camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java
camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessageHelper.java
camel/branches/camel-2.9.x/components/camel-jms/src/test/resources/log4j.properties
camel/branches/camel-2.9.x/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala
camel/branches/camel-2.9.x/components/camel-spring/src/main/java/org/apache/camel/spring/spi/TransactionErrorHandler.java
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Tue Jan 31 13:06:39 2012
@@ -1 +1 @@
-/camel/trunk:1235643,1236639,1236667,1237666,1237807,1238225,1238229,1238387
+/camel/trunk:1235643,1236639,1236667,1237666,1237807,1238225,1238229,1238387,1238463
Propchange: camel/branches/camel-2.9.x/
------------------------------------------------------------------------------
Binary property 'svnmerge-integrated' - no diff available.
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/Exchange.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/Exchange.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/Exchange.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/Exchange.java Tue Jan 31 13:06:39 2012
@@ -397,6 +397,17 @@ public interface Exchange {
boolean isTransacted();
/**
+ * Returns true if this exchange is redelivered from a transacted source (such as a JMS broker)
+ * <p/>
+ * <b>Important: </b> It is not always possible to determine if the transacted is a redelivery
+ * or not, and therefore <tt>null</tt> is returned. Such an example would be a JDBC message.
+ * However JMS brokers provides details if a transacted message is redelivered.
+ *
+ * @return <tt>true</tt> if redelivered, <tt>false</tt> if not, <tt>null</tt> if not able to determine
+ */
+ Boolean isTransactedRedelivered();
+
+ /**
* Returns true if this exchange is marked for rollback
*/
boolean isRollbackOnly();
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultExchange.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultExchange.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultExchange.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultExchange.java Tue Jan 31 13:06:39 2012
@@ -331,6 +331,17 @@ public final class DefaultExchange imple
}
}
+ public Boolean isTransactedRedelivered() {
+ // lets avoid adding methods to the Message API, so we use the
+ // DefaultMessage to allow component specific messages to extend
+ // and implement the isTransactedRedelivered method.
+ DefaultMessage msg = getIn(DefaultMessage.class);
+ if (msg != null) {
+ return msg.isTransactedRedelivered();
+ }
+ return null;
+ }
+
public boolean isRollbackOnly() {
return Boolean.TRUE.equals(getProperty(Exchange.ROLLBACK_ONLY)) || Boolean.TRUE.equals(getProperty(Exchange.ROLLBACK_ONLY_LAST));
}
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultMessage.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultMessage.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultMessage.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/impl/DefaultMessage.java Tue Jan 31 13:06:39 2012
@@ -237,6 +237,21 @@ public class DefaultMessage extends Mess
// do nothing by default
}
+ /**
+ * A strategy for component specific messages to determine whether the
+ * message is redelivered or not.
+ * <p/>
+ * <b>Important: </b> It is not always possible to determine if the transacted is a redelivery
+ * or not, and therefore <tt>null</tt> is returned. Such an example would be a JDBC message.
+ * However JMS brokers provides details if a transacted message is redelivered.
+ *
+ * @return <tt>true</tt> if redelivered, <tt>false</tt> if not, <tt>null</tt> if not able to determine
+ */
+ protected Boolean isTransactedRedelivered() {
+ // return null by default
+ return null;
+ }
+
public void addAttachment(String id, DataHandler content) {
if (attachments == null) {
attachments = createAttachments();
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/processor/RedeliveryErrorHandler.java Tue Jan 31 13:06:39 2012
@@ -568,7 +568,7 @@ public abstract class RedeliveryErrorHan
// keep the Exchange.EXCEPTION_CAUGHT as property so end user knows the caused exception
// create log message
- String msg = "Failed delivery for exchangeId: " + exchange.getExchangeId();
+ String msg = "Failed delivery for " + ExchangeHelper.logIds(exchange);
msg = msg + ". Exhausted after delivery attempt: " + data.redeliveryCounter + " caught: " + caught;
msg = msg + ". Handled and continue routing.";
@@ -656,7 +656,7 @@ public abstract class RedeliveryErrorHan
// only log if not failure handled or not an exhausted unit of work
if (!ExchangeHelper.isFailureHandled(exchange) && !ExchangeHelper.isUnitOfWorkExhausted(exchange)) {
- String msg = "Failed delivery for exchangeId: " + exchange.getExchangeId()
+ String msg = "Failed delivery for " + ExchangeHelper.logIds(exchange)
+ ". On delivery attempt: " + data.redeliveryCounter + " caught: " + e;
logFailedDelivery(true, false, false, exchange, msg, data, e);
}
@@ -764,7 +764,7 @@ public abstract class RedeliveryErrorHan
}
// create log message
- String msg = "Failed delivery for exchangeId: " + exchange.getExchangeId();
+ String msg = "Failed delivery for " + ExchangeHelper.logIds(exchange);
msg = msg + ". Exhausted after delivery attempt: " + data.redeliveryCounter + " caught: " + caught;
if (processor != null) {
msg = msg + ". Processed by failure processor: " + processor;
@@ -858,7 +858,7 @@ public abstract class RedeliveryErrorHan
}
if (exchange.isRollbackOnly()) {
- String msg = "Rollback exchangeId: " + exchange.getExchangeId();
+ String msg = "Rollback " + ExchangeHelper.logIds(exchange);
Throwable cause = exchange.getException() != null ? exchange.getException() : exchange.getProperty(Exchange.EXCEPTION_CAUGHT, Throwable.class);
if (cause != null) {
msg = msg + " due: " + cause.getMessage();
Modified: camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java (original)
+++ camel/branches/camel-2.9.x/camel-core/src/main/java/org/apache/camel/util/ExchangeHelper.java Tue Jan 31 13:06:39 2012
@@ -653,23 +653,37 @@ public final class ExchangeHelper {
exchange.setOut(null);
}
}
-
+
+ /**
+ * Gets both the messageId and exchangeId to be used for logging purposes.
+ * <p/>
+ * Logging both ids, can help to correlate exchanges which may be redelivered messages
+ * from for example a JMS broker.
+ *
+ * @param exchange the exchange
+ * @return a log message with both the messageId and exchangeId
+ */
+ public static String logIds(Exchange exchange) {
+ String msgId = exchange.hasOut() ? exchange.getOut().getMessageId() : exchange.getIn().getMessageId();
+ return "(MessageId: " + msgId + " on ExchangeId: " + exchange.getExchangeId() + ")";
+ }
+
public static Exchange copyExchangeAndSetCamelContext(Exchange exchange, CamelContext context) {
DefaultExchange answer = new DefaultExchange(context, exchange.getPattern());
if (exchange.hasProperties()) {
answer.setProperties(safeCopy(exchange.getProperties()));
}
// Need to hand over the completion for async invocation
- exchange.handoverCompletions(answer);
+ exchange.handoverCompletions(answer);
answer.setIn(exchange.getIn().copy());
if (exchange.hasOut()) {
answer.setOut(exchange.getOut().copy());
}
answer.setException(exchange.getException());
return answer;
-
+
}
-
+
private static Map<String, Object> safeCopy(Map<String, Object> properties) {
if (properties == null) {
return null;
Propchange: camel/branches/camel-2.9.x/components/camel-jaxb/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Tue Jan 31 13:06:39 2012
@@ -1 +1 @@
-/camel/trunk/components/camel-jaxb:1235643,1236403-1236663,1236667,1237148,1237666,1237807,1238225,1238229,1238387
+/camel/trunk/components/camel-jaxb:1235643,1236403-1236663,1236667,1237148,1237666,1237807,1238225,1238229,1238387,1238463
Propchange: camel/branches/camel-2.9.x/components/camel-jaxb/src/test/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Tue Jan 31 13:06:39 2012
@@ -1 +1 @@
-/camel/trunk/components/camel-jaxb/src/test:1235643,1236403-1236663,1236667,1237148,1237230,1237666,1237807,1238225,1238229,1238387
+/camel/trunk/components/camel-jaxb/src/test:1235643,1236403-1236663,1236667,1237148,1237230,1237666,1237807,1238225,1238229,1238387,1238463
Propchange: camel/branches/camel-2.9.x/components/camel-jms/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Tue Jan 31 13:06:39 2012
@@ -1 +1 @@
-/camel/trunk/components/camel-jms:1235643,1236639,1236667,1237666,1237807,1238060,1238225,1238229,1238387
+/camel/trunk/components/camel-jms:1235643,1236639,1236667,1237666,1237807,1238060,1238225,1238229,1238387,1238463
Modified: camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java (original)
+++ camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessage.java Tue Jan 31 13:06:39 2012
@@ -232,6 +232,15 @@ public class JmsMessage extends DefaultM
}
}
+ @Override
+ protected Boolean isTransactedRedelivered() {
+ if (jmsMessage != null) {
+ return JmsMessageHelper.getJMSRedelivered(jmsMessage);
+ } else {
+ return null;
+ }
+ }
+
private String getDestinationAsString(Destination destination) throws JMSException {
String result;
if (destination == null) {
Modified: camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessageHelper.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessageHelper.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessageHelper.java (original)
+++ camel/branches/camel-2.9.x/components/camel-jms/src/main/java/org/apache/camel/component/jms/JmsMessageHelper.java Tue Jan 31 13:06:39 2012
@@ -218,6 +218,22 @@ public final class JmsMessageHelper {
}
/**
+ * Gets the JMSRedelivered from the message.
+ *
+ * @param message the message
+ * @return <tt>true</tt> if redelivered, <tt>false</tt> if not, <tt>null</tt> if not able to determine
+ */
+ public static Boolean getJMSRedelivered(Message message) {
+ try {
+ return message.getJMSRedelivered();
+ } catch (Exception e) {
+ // ignore if JMS broker do not support this
+ }
+
+ return null;
+ }
+
+ /**
* Sets the JMSDeliveryMode on the message.
*
* @param exchange the exchange
Modified: camel/branches/camel-2.9.x/components/camel-jms/src/test/resources/log4j.properties
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-jms/src/test/resources/log4j.properties?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-jms/src/test/resources/log4j.properties (original)
+++ camel/branches/camel-2.9.x/components/camel-jms/src/test/resources/log4j.properties Tue Jan 31 13:06:39 2012
@@ -31,6 +31,7 @@ log4j.rootLogger=INFO, out
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %m%n
+#log4j.appender.stdout.layout.ConversionPattern=%d [%-15.15t] %-5p %-30.30c{1} - %-10.10X{exchangeId} - %-10.10X{messageId} - %m%n
# File appender
log4j.appender.out=org.apache.log4j.FileAppender
Modified: camel/branches/camel-2.9.x/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala (original)
+++ camel/branches/camel-2.9.x/components/camel-scala/src/main/scala/org/apache/camel/scala/RichExchange.scala Tue Jan 31 13:06:39 2012
@@ -27,45 +27,47 @@ import java.lang.{String, Class}
*/
class RichExchange(val exchange : Exchange) extends Exchange {
- def in_=(message: Any) = exchange.getIn().setBody(message)
+ def in_=(message: Any) { exchange.getIn.setBody(message) }
- def in(header:String) : Any = exchange.getIn().getHeader(header)
+ def in(header:String) : Any = exchange.getIn.getHeader(header)
- def in = exchange.getIn().getBody()
- def in[T](implicit manifest: Manifest[T]) : T = exchange.getIn().getBody(manifest.erasure).asInstanceOf[T]
+ def in = exchange.getIn.getBody
+ def in[T](implicit manifest: Manifest[T]) : T = exchange.getIn.getBody(manifest.erasure).asInstanceOf[T]
- def out : Any = exchange.getOut().getBody()
+ def out : Any = exchange.getOut.getBody
- def out(header:String) : Any = exchange.getOut().getHeader(header)
+ def out(header:String) : Any = exchange.getOut.getHeader(header)
- def out_=(message:Any) = exchange.getOut().setBody(message)
+ def out_=(message:Any) { exchange.getOut.setBody(message) }
// Delegation methods
//-------------------------------------------------------------------------
- def setUnitOfWork(unitOfWork: UnitOfWork) = exchange.setUnitOfWork(unitOfWork)
+ def setUnitOfWork(unitOfWork: UnitOfWork) { exchange.setUnitOfWork(unitOfWork) }
- def setProperty(name: String, value: Any) = exchange.setProperty(name, value)
+ def setProperty(name: String, value: Any) { exchange.setProperty(name, value) }
- def setPattern(pattern: ExchangePattern) = exchange.setPattern(pattern)
+ def setPattern(pattern: ExchangePattern) { exchange.setPattern(pattern) }
- def setOut(out: Message) = exchange.setOut(out)
+ def setOut(out: Message) { exchange.setOut(out) }
- def setIn(in: Message) = exchange.setIn(in)
+ def setIn(in: Message) { exchange.setIn(in) }
- def setFromEndpoint(fromEndpoint: Endpoint) = exchange.setFromEndpoint(fromEndpoint)
+ def setFromEndpoint(fromEndpoint: Endpoint) { exchange.setFromEndpoint(fromEndpoint) }
- def setFromRouteId(routeId: String) = exchange.setFromRouteId(routeId)
+ def setFromRouteId(routeId: String) { exchange.setFromRouteId(routeId) }
- def setExchangeId(id: String) = exchange.setExchangeId(id)
+ def setExchangeId(id: String) { exchange.setExchangeId(id) }
- def setException(t: Throwable) = exchange.setException(t)
+ def setException(t: Throwable) { exchange.setException(t) }
def removeProperty(name: String) = exchange.removeProperty(name)
def isTransacted = exchange.isTransacted
+ def isTransactedRedelivered = exchange.isTransactedRedelivered;
+
def isRollbackOnly = exchange.isRollbackOnly
def isFailed = exchange.isFailed
@@ -110,9 +112,9 @@ class RichExchange(val exchange : Exchan
def copy = new RichExchange(exchange.copy)
- def addOnCompletion(onCompletion: Synchronization) = exchange.addOnCompletion(onCompletion)
+ def addOnCompletion(onCompletion: Synchronization) { exchange.addOnCompletion(onCompletion) }
- def handoverCompletions(exchange : Exchange) = exchange.handoverCompletions(exchange)
+ def handoverCompletions(exchange : Exchange) { exchange.handoverCompletions(exchange) }
def handoverCompletions = exchange.handoverCompletions
}
Modified: camel/branches/camel-2.9.x/components/camel-spring/src/main/java/org/apache/camel/spring/spi/TransactionErrorHandler.java
URL: http://svn.apache.org/viewvc/camel/branches/camel-2.9.x/components/camel-spring/src/main/java/org/apache/camel/spring/spi/TransactionErrorHandler.java?rev=1238481&r1=1238480&r2=1238481&view=diff
==============================================================================
--- camel/branches/camel-2.9.x/components/camel-spring/src/main/java/org/apache/camel/spring/spi/TransactionErrorHandler.java (original)
+++ camel/branches/camel-2.9.x/components/camel-spring/src/main/java/org/apache/camel/spring/spi/TransactionErrorHandler.java Tue Jan 31 13:06:39 2012
@@ -25,6 +25,7 @@ import org.apache.camel.processor.Redeli
import org.apache.camel.processor.RedeliveryPolicy;
import org.apache.camel.processor.exceptionpolicy.ExceptionPolicyStrategy;
import org.apache.camel.util.CamelLogger;
+import org.apache.camel.util.ExchangeHelper;
import org.apache.camel.util.ObjectHelper;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
@@ -111,20 +112,31 @@ public class TransactionErrorHandler ext
}
protected void processInTransaction(final Exchange exchange) throws Exception {
+ // is the exchange redeliveried, for example JMS brokers support such details
+ Boolean redelivery = exchange.isTransactedRedelivered();
+ final String redelivered = redelivery != null ? redelivery.toString() : "unknown";
+ final String ids = ExchangeHelper.logIds(exchange);
+
try {
// mark the beginning of this transaction boundary
exchange.getUnitOfWork().beginTransactedBy(transactionKey);
- log.debug("Transaction begin ({}) for ExchangeId: {}", transactionKey, exchange.getExchangeId());
+ if (log.isDebugEnabled()) {
+ log.debug("Transaction begin ({}) redelivered({}) for {})", new Object[]{transactionKey, redelivered, ids});
+ }
doInTransactionTemplate(exchange);
- log.debug("Transaction commit ({}) for ExchangeId: {}", transactionKey, exchange.getExchangeId());
+ if (log.isDebugEnabled()) {
+ log.debug("Transaction commit ({}) redelivered({}) for {})", new Object[]{transactionKey, redelivered, ids});
+ }
} catch (TransactionRollbackException e) {
// ignore as its just a dummy exception to force spring TX to rollback
- log.debug("Transaction rollback ({}) for ExchangeId: {} due exchange was marked for rollbackOnly", transactionKey, exchange.getExchangeId());
+ if (log.isDebugEnabled()) {
+ log.debug("Transaction rollback ({}) redelivered({}) for {} due exchange was marked for rollbackOnly", new Object[]{transactionKey, redelivered, ids});
+ }
} catch (Throwable e) {
- log.warn("Transaction rollback (" + transactionKey + ") for ExchangeId: " + exchange.getExchangeId() + " due exception: " + e.getMessage());
+ log.warn("Transaction rollback ({}) redelivered({}) for {} caught: {}", new Object[]{transactionKey, redelivered, ids, e.getMessage()});
exchange.setException(e);
} finally {
// mark the end of this transaction boundary
@@ -135,14 +147,13 @@ public class TransactionErrorHandler ext
Boolean onlyLast = (Boolean) exchange.removeProperty(Exchange.ROLLBACK_ONLY_LAST);
if (onlyLast != null && onlyLast) {
if (log.isDebugEnabled()) {
- // log exception if there was a cause exception so we have the stacktrace
+ // log exception if there was a cause exception so we have the stack trace
Exception cause = exchange.getException();
if (cause != null) {
- log.debug("Transaction rollback (" + transactionKey + ") for ExchangeId: " + exchange.getExchangeId()
- + " due exchange was marked for rollbackOnlyLast and due exception: ", cause);
+ log.debug("Transaction rollback (" + transactionKey + ") redelivered(" + redelivered + ") for "
+ + ids + " due exchange was marked for rollbackOnlyLast and caught: ", cause);
} else {
- log.debug("Transaction rollback ({}) for ExchangeId: {} due exchange was marked for rollbackOnlyLast",
- transactionKey, exchange.getExchangeId());
+ log.debug("Transaction rollback ({}) redelivered(" + redelivered + ") for {} due exchange was marked for rollbackOnlyLast", transactionKey, ids);
}
}
// remove caused exception due we was marked as rollback only last