You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2023/04/18 06:34:31 UTC
[camel] 03/04: (chores) camel-jta: removed unused parameters
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b687c003036767ce369d64932da2cc9216b8820b
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Tue Apr 18 07:12:23 2023 +0200
(chores) camel-jta: removed unused parameters
---
.../apache/camel/jta/JtaTransactionErrorHandlerReifier.java | 12 ++++++------
1 file changed, 6 insertions(+), 6 deletions(-)
diff --git a/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java b/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java
index b1aac621340..db1b75288e1 100644
--- a/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java
+++ b/components/camel-jta/src/main/java/org/apache/camel/jta/JtaTransactionErrorHandlerReifier.java
@@ -49,13 +49,13 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
@Override
public Processor createErrorHandler(final Processor processor) throws Exception {
- JtaTransactionPolicy transactionPolicy = resolveTransactionPolicy(definition, camelContext);
+ JtaTransactionPolicy transactionPolicy = resolveTransactionPolicy(definition);
ObjectHelper.notNull(transactionPolicy, "transactionPolicy", this);
// optimize to use shared default instance if using out of the box settings
RedeliveryPolicy redeliveryPolicy = resolveRedeliveryPolicy(definition, camelContext);
- CamelLogger logger = resolveLogger(definition, camelContext);
- LoggingLevel rollbackLoggingLevel = resolveRollbackLoggingLevel(definition, camelContext);
+ CamelLogger logger = resolveLogger(definition);
+ LoggingLevel rollbackLoggingLevel = resolveRollbackLoggingLevel(definition);
JtaTransactionErrorHandler answer = new JtaTransactionErrorHandler(
camelContext, processor, logger,
@@ -73,7 +73,7 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
}
private JtaTransactionPolicy resolveTransactionPolicy(
- JtaTransactionErrorHandlerDefinition definition, CamelContext camelContext) {
+ JtaTransactionErrorHandlerDefinition definition) {
JtaTransactionPolicy answer = (JtaTransactionPolicy) definition.getTransactedPolicy();
if (answer == null && definition.getTransactedPolicyRef() != null) {
@@ -107,7 +107,7 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
return answer;
}
- private CamelLogger resolveLogger(TransactionErrorHandlerDefinition definition, CamelContext camelContext) {
+ private CamelLogger resolveLogger(TransactionErrorHandlerDefinition definition) {
CamelLogger answer = definition.getLoggerBean();
if (answer == null && definition.getLoggerRef() != null) {
answer = mandatoryLookup(definition.getLoggerRef(), CamelLogger.class);
@@ -121,7 +121,7 @@ public class JtaTransactionErrorHandlerReifier extends ErrorHandlerReifier<JtaTr
return answer;
}
- private LoggingLevel resolveRollbackLoggingLevel(TransactionErrorHandlerDefinition definition, CamelContext camelContext) {
+ private LoggingLevel resolveRollbackLoggingLevel(TransactionErrorHandlerDefinition definition) {
LoggingLevel answer = LoggingLevel.WARN;
if (definition.getRollbackLoggingLevel() != null) {
answer = parse(LoggingLevel.class, definition.getRollbackLoggingLevel());