Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/1608f76e Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/1608f76e Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/1608f76e Branch: refs/heads/master Commit: 1608f76e74098751e449b1c7090b8a3f5bc288f9 Parents: 1eeba05 Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Apr 29 11:22:37 2016 +0200 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Apr 29 11:24:29 2016 +0200 ---------------------------------------------------------------------- .../component/netty/NettyConsumerClientModeTest.java | 4 +++- .../camel/component/netty/NettyRedeliveryTest.java | 2 +- .../camel/component/olingo2/api/impl/UriType.java | 2 +- .../optaplanner/OptaPlannerDaemonSolverTest.java | 2 +- .../component/pdf/text/DefaultLineBuilderStrategy.java | 5 ++--- .../apache/camel/component/printer/PrintDocument.java | 2 +- .../camel/component/quickfixj/MessageCorrelator.java | 2 +- .../camel/component/quickfixj/QuickfixjEngine.java | 2 +- .../camel/component/quickfixj/QuickfixjEngineTest.java | 2 +- .../quickfixj/examples/trading/TradeExecutor.java | 2 +- .../examples/trading/TradeExecutorComponent.java | 2 +- .../apache/camel/component/rabbitmq/RabbitConsumer.java | 5 +---- .../camel/component/rabbitmq/RabbitMQConsumer.java | 2 +- .../rabbitmq/reply/TemporaryQueueReplyManager.java | 2 +- .../component/rabbitmq/RabbitMQProducerIntTest.java | 2 +- .../java/org/apache/camel/rx/CamelOperatorTest.java | 12 ++++++------ .../java/org/apache/camel/rx/ObservableBodyTest.java | 4 ++-- .../java/org/apache/camel/rx/ObservableMessageTest.java | 4 ++-- .../org/apache/camel/rx/ToObservableAndMapTest.java | 6 +++--- .../java/org/apache/camel/rx/ToObservableBodyTest.java | 6 +++--- .../test/java/org/apache/camel/rx/ToObservableTest.java | 8 ++++---- .../java/org/apache/camel/rx/ToObservableUoWTest.java | 6 +++--- .../api/dto/analytics/reports/FormatEnum.java | 2 +- .../component/salesforce/internal/OperationName.java | 2 +- .../salesforce/internal/client/DefaultRestClient.java | 2 +- .../internal/client/SalesforceSecurityHandler.java | 2 +- .../salesforce/internal/dto/NotifyForFieldsEnum.java | 2 +- .../internal/dto/NotifyForOperationsEnum.java | 2 +- .../org/apache/camel/builder/script/ScriptBuilder.java | 2 +- .../org/apache/camel/builder/script/Jsr223Test.java | 2 +- .../camel/component/servicenow/ServiceNowProducer.java | 2 +- .../shiro/security/ShiroAuthenticationBase64Test.java | 2 +- ...AuthenticationReauthenticateFalseAndNewUserTest.java | 2 +- .../shiro/security/ShiroAuthenticationTest.java | 2 +- .../shiro/security/ShiroAuthorizationTest.java | 2 +- .../shiro/security/ShiroRolesAuthorizationTest.java | 2 +- .../camel/component/sjms/batch/SessionCompletion.java | 2 +- .../camel/component/sjms/batch/SjmsBatchConsumer.java | 4 ++-- .../component/sjms/jms/SessionAcknowledgementType.java | 2 +- .../component/sjms/batch/SjmsBatchConsumerTest.java | 2 +- .../apache/camel/component/smpp/SmppCommandType.java | 2 +- .../org/apache/camel/dataformat/soap/name/TypeInfo.java | 5 +---- .../spark/annotations/AnnotatedRddCallbackProxy.java | 4 ++-- .../java/org/apache/camel/component/splunk/Helper.java | 4 ++-- .../spring/batch/support/CamelJobExecutionListener.java | 2 +- .../spring/integration/SpringIntegrationConsumer.java | 2 +- .../spring/integration/SpringIntegrationProducer.java | 2 +- .../spring/integration/adapter/CamelSourceAdapter.java | 2 +- .../component/spring/ws/type/EndpointMappingType.java | 2 +- .../apache/camel/component/syslog/SyslogConverter.java | 2 +- .../apache/camel/component/syslog/NettyRfc5425Test.java | 2 +- .../aggregate/tarfile/TarAggregationStrategy.java | 2 +- .../consumer/timeline/AbstractStatusConsumer.java | 2 +- .../component/twitter/CamelTwitterTestSupport.java | 6 +++--- .../camel/component/undertow/UndertowProducer.java | 2 +- .../camel/component/websocket/WebsocketComponent.java | 6 ++---- .../xmlsecurity/api/XmlSignatureProperties.java | 2 +- .../xmlsecurity/XAdESSignaturePropertiesTest.java | 2 +- .../camel/component/xmpp/XmppPrivateChatProducer.java | 3 +-- .../xstream/XStreamDataFormatOmitFieldsTest.java | 4 ++-- .../camel/dataformat/zipfile/ZipInputStreamWrapper.java | 4 ++-- .../aggregate/zipfile/ZipAggregationStrategy.java | 2 +- .../main/java/org/apache/camel/zipkin/ZipkinTracer.java | 3 ++- .../component/zookeeper/NaturalSortComparator.java | 2 +- .../component/zookeeper/ZooKeeperConnectionManager.java | 2 +- .../camel/component/zookeeper/ZooKeeperProducer.java | 2 +- .../component/zookeeper/policy/ZooKeeperElection.java | 2 +- .../zookeeper/policy/FailoverRoutePolicyTest.java | 2 +- .../apache/camel/example/cxf/httptojms/JmsBroker.java | 2 +- .../camel/example/cxf/jaxrs/CamelRouterBuilder.java | 2 +- .../camel/loanbroker/queue/version/JmsBroker.java | 2 +- .../apache/camel/example/spring/javaconfig/MyRoute.java | 6 +++--- .../camel/example/spring/javaconfig/SomeBean.java | 6 +++--- .../src/main/java/sample/camel/ClientApplication.java | 6 +++--- .../client/src/main/java/sample/camel/ClientRoute.java | 6 +++--- .../src/main/java/sample/camel/Service2Application.java | 6 +++++- .../camel/catalog/UnsafeUriCharactersEncoder.java | 2 +- .../camel/test/cxf/blueprint/CxfConsumerSoap12Test.java | 2 +- .../cxf/blueprint/CxfPayloadProviderRouterTest.java | 2 +- .../itest/customerrelations/CustomerServicesTest.java | 3 ++- .../camel/itest/greeter/CamelGreeterConsumerTest.java | 4 ++-- .../org/apache/camel/itest/http/Http4RouteTest.java | 2 +- .../org/apache/camel/itest/http/HttpTestServer.java | 2 +- .../main/java/org/apache/camel/guice/maven/RunMojo.java | 2 +- 84 files changed, 126 insertions(+), 128 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConsumerClientModeTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConsumerClientModeTest.java b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConsumerClientModeTest.java index 0f71042..231d80f 100644 --- a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConsumerClientModeTest.java +++ b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyConsumerClientModeTest.java @@ -91,9 +91,11 @@ public class NettyConsumerClientModeTest extends BaseNettyTest { private static class MyServer { private int port; private ServerBootstrap bootstrap; - public MyServer(int port) { + + MyServer(int port) { this.port = port; } + public void start() { // Configure the server. bootstrap = new ServerBootstrap( http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyRedeliveryTest.java ---------------------------------------------------------------------- diff --git a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyRedeliveryTest.java b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyRedeliveryTest.java index af7ff76..f8825fa 100644 --- a/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyRedeliveryTest.java +++ b/components/camel-netty/src/test/java/org/apache/camel/component/netty/NettyRedeliveryTest.java @@ -196,7 +196,7 @@ public class NettyRedeliveryTest extends CamelTestSupport { private class ClosingClientRunnable implements Runnable { private final Socket socket; - public ClosingClientRunnable(Socket socket) { + ClosingClientRunnable(Socket socket) { this.socket = socket; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-olingo2/camel-olingo2-api/src/main/java/org/apache/camel/component/olingo2/api/impl/UriType.java ---------------------------------------------------------------------- diff --git a/components/camel-olingo2/camel-olingo2-api/src/main/java/org/apache/camel/component/olingo2/api/impl/UriType.java b/components/camel-olingo2/camel-olingo2-api/src/main/java/org/apache/camel/component/olingo2/api/impl/UriType.java index f2468a3..ce25292 100644 --- a/components/camel-olingo2/camel-olingo2-api/src/main/java/org/apache/camel/component/olingo2/api/impl/UriType.java +++ b/components/camel-olingo2/camel-olingo2-api/src/main/java/org/apache/camel/component/olingo2/api/impl/UriType.java @@ -118,7 +118,7 @@ public enum UriType { private ArrayList<SystemQueryOption> whiteList = new ArrayList<SystemQueryOption>(); - private UriType(final SystemQueryOption... compatibleQueryOptions) { + UriType(final SystemQueryOption... compatibleQueryOptions) { for (SystemQueryOption queryOption : compatibleQueryOptions) { whiteList.add(queryOption); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerDaemonSolverTest.java ---------------------------------------------------------------------- diff --git a/components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerDaemonSolverTest.java b/components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerDaemonSolverTest.java index 3ef5e26..48e9e23 100644 --- a/components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerDaemonSolverTest.java +++ b/components/camel-optaplanner/src/test/java/org/apache/camel/component/optaplanner/OptaPlannerDaemonSolverTest.java @@ -76,7 +76,7 @@ public class OptaPlannerDaemonSolverTest extends CamelTestSupport { private final CloudComputer removingComputer; - public RemoveComputerChange(CloudComputer removingComputer) { + RemoveComputerChange(CloudComputer removingComputer) { this.removingComputer = removingComputer; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/text/DefaultLineBuilderStrategy.java ---------------------------------------------------------------------- diff --git a/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/text/DefaultLineBuilderStrategy.java b/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/text/DefaultLineBuilderStrategy.java index bb2d005..4ade22b 100644 --- a/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/text/DefaultLineBuilderStrategy.java +++ b/components/camel-pdf/src/main/java/org/apache/camel/component/pdf/text/DefaultLineBuilderStrategy.java @@ -127,14 +127,13 @@ public class DefaultLineBuilderStrategy implements LineBuilderStrategy { private StringBuilder line = new StringBuilder(); private int wordsCount; - public LineBuilder() { } + LineBuilder() { } - public LineBuilder(String line, int wordsCount) { + LineBuilder(String line, int wordsCount) { this.line = new StringBuilder(line); this.wordsCount = wordsCount; } - public LineBuilder appendWord(String word) { line.append(word).append(" "); wordsCount++; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrintDocument.java ---------------------------------------------------------------------- diff --git a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrintDocument.java b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrintDocument.java index 636df81a..ee1b269 100644 --- a/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrintDocument.java +++ b/components/camel-printer/src/main/java/org/apache/camel/component/printer/PrintDocument.java @@ -31,7 +31,7 @@ class PrintDocument implements Doc { private Reader reader; private byte[] buffer; - public PrintDocument(InputStream stream, DocFlavor docFlavor) { + PrintDocument(InputStream stream, DocFlavor docFlavor) { this.stream = stream; this.docFlavor = docFlavor; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java index cc292a4..1ec7579 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/MessageCorrelator.java @@ -74,7 +74,7 @@ public class MessageCorrelator implements QuickfixjEventListener { private Message replyMessage; - public MessageCorrelationRule(Exchange exchange, SessionID sessionID, MessagePredicate messageCriteria) { + MessageCorrelationRule(Exchange exchange, SessionID sessionID, MessagePredicate messageCriteria) { this.exchange = exchange; this.messageCriteria = messageCriteria; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java index 1016d42..141403e 100644 --- a/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java +++ b/components/camel-quickfix/src/main/java/org/apache/camel/component/quickfixj/QuickfixjEngine.java @@ -533,7 +533,7 @@ public class QuickfixjEngine extends ServiceSupport { private static final long serialVersionUID = 1L; - public DispatcherException(Throwable cause) { + DispatcherException(Throwable cause) { super(cause); } } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java index 7aeebba..6fa933b 100644 --- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java +++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/QuickfixjEngineTest.java @@ -518,7 +518,7 @@ public class QuickfixjEngineTest extends org.apache.camel.test.junit4.TestSuppor final SessionID sessionID; final Message message; - public EventRecord(QuickfixjEventCategory eventCategory, SessionID sessionID, Message message) { + EventRecord(QuickfixjEventCategory eventCategory, SessionID sessionID, Message message) { this.eventCategory = eventCategory; this.sessionID = sessionID; this.message = message; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java index f3a1a08..ef5dfd9 100644 --- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java +++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutor.java @@ -420,7 +420,7 @@ public class TradeExecutor { private static class DefaultMarketQuoteProvider implements MarketQuoteProvider { private double defaultMarketPrice; - public DefaultMarketQuoteProvider(double defaultMarketPrice) { + DefaultMarketQuoteProvider(double defaultMarketPrice) { this.defaultMarketPrice = defaultMarketPrice; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java index 80a8f38..7f04c0e 100644 --- a/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java +++ b/components/camel-quickfix/src/test/java/org/apache/camel/component/quickfixj/examples/trading/TradeExecutorComponent.java @@ -95,7 +95,7 @@ public class TradeExecutorComponent extends DefaultComponent { private final TradeExecutor tradeExecutor; private List<Processor> processors = new CopyOnWriteArrayList<Processor>(); - public TradeExecutorEndpoint(String uri, TradeExecutor tradeExecutor) { + TradeExecutorEndpoint(String uri, TradeExecutor tradeExecutor) { super(uri, TradeExecutorComponent.this); this.tradeExecutor = tradeExecutor; tradeExecutor.addListener(new QuickfixjMessageListener() { http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java index a03e7f8..eeeafd6 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitConsumer.java @@ -45,11 +45,8 @@ class RabbitConsumer implements com.rabbitmq.client.Consumer { /** * Constructs a new instance and records its association to the passed-in * channel. - * - * @param channel - * the channel to which this consumer is attached */ - public RabbitConsumer(RabbitMQConsumer consumer) { + RabbitConsumer(RabbitMQConsumer consumer) { // super(channel); this.consumer = consumer; try { http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java index 69d3a0b..9faffc2 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/RabbitMQConsumer.java @@ -184,7 +184,7 @@ public class RabbitMQConsumer extends DefaultConsumer implements Suspendable { private final long connectionRetryInterval; private final AtomicBoolean running = new AtomicBoolean(true); - public StartConsumerCallable(long connectionRetryInterval) { + StartConsumerCallable(long connectionRetryInterval) { this.connectionRetryInterval = connectionRetryInterval; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java index 05cea1a..6f03017 100644 --- a/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java +++ b/components/camel-rabbitmq/src/main/java/org/apache/camel/component/rabbitmq/reply/TemporaryQueueReplyManager.java @@ -120,7 +120,7 @@ public class TemporaryQueueReplyManager extends ReplyManagerSupport { * * @param channel the channel to which this consumer is attached */ - public RabbitConsumer(TemporaryQueueReplyManager consumer, Channel channel) { + RabbitConsumer(TemporaryQueueReplyManager consumer, Channel channel) { super(channel); this.consumer = consumer; this.channel = channel; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQProducerIntTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQProducerIntTest.java b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQProducerIntTest.java index 5f859ad..fded387 100644 --- a/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQProducerIntTest.java +++ b/components/camel-rabbitmq/src/test/java/org/apache/camel/component/rabbitmq/RabbitMQProducerIntTest.java @@ -134,7 +134,7 @@ public class RabbitMQProducerIntTest extends CamelTestSupport { private class ArrayPopulatingConsumer extends DefaultConsumer { private final List<String> received; - public ArrayPopulatingConsumer(final List<String> received) { + ArrayPopulatingConsumer(final List<String> received) { super(RabbitMQProducerIntTest.this.channel); this.received = received; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/CamelOperatorTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/CamelOperatorTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/CamelOperatorTest.java index ca37ca1..93d25f8 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/CamelOperatorTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/CamelOperatorTest.java @@ -59,14 +59,14 @@ public class CamelOperatorTest extends RxTestSupport { // Define an InOut route ConnectableObservable<Exchange> inOut = reactiveCamel.from("restlet:http://localhost:9080/test?restletMethod=POST";) .map(exchange -> { - exchange.getIn().setBody(exchange.getIn().getBody(String.class)); - return exchange; - }) + exchange.getIn().setBody(exchange.getIn().getBody(String.class)); + return exchange; + }) .lift(reactiveCamel.to("log:inOut")) .map(exchange -> { - exchange.getIn().setBody(exchange.getIn().getBody(String.class) + " back"); - return exchange; - }) + exchange.getIn().setBody(exchange.getIn().getBody(String.class) + " back"); + return exchange; + }) .lift(reactiveCamel.to(mockEndpoint4)) .publish(); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableBodyTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableBodyTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableBodyTest.java index 52995fc..75774ec 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableBodyTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableBodyTest.java @@ -54,8 +54,8 @@ public class ObservableBodyTest extends CamelTestSupport { protected void configure(Observable<String> observable) { // lets process the messages using the RX API observable.map(body -> "Hello " + body).subscribe(body -> { - template.sendBody(resultEndpoint, body); - }); + template.sendBody(resultEndpoint, body); + }); } } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableMessageTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableMessageTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableMessageTest.java index 93b45d4..735389c 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableMessageTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/ObservableMessageTest.java @@ -51,8 +51,8 @@ public class ObservableMessageTest extends CamelTestSupport { protected void configure(Observable<Message> observable) { // lets process the messages using the RX API observable.map(message -> "Hello " + message.getBody(String.class)).subscribe(body -> { - template.sendBody(resultEndpoint, body); - }); + template.sendBody(resultEndpoint, body); + }); } } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableAndMapTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableAndMapTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableAndMapTest.java index 0daddd8..8b5689f 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableAndMapTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableAndMapTest.java @@ -39,9 +39,9 @@ public class ToObservableAndMapTest extends RxTestSupport { Observable<String> observable = observableMessage.map(message -> "Transformed value: headers " + message.getHeaders()); observable.take(4).subscribe(body -> { - LOG.info(body); - producerTemplate.sendBody(mockEndpoint, body); - }); + LOG.info(body); + producerTemplate.sendBody(mockEndpoint, body); + }); mockEndpoint.assertIsSatisfied(); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableBodyTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableBodyTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableBodyTest.java index 3c4649e..3d84013 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableBodyTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableBodyTest.java @@ -37,9 +37,9 @@ public class ToObservableBodyTest extends RxTestSupport { // lets route the largeOrderIds to the mock endpoint for testing largeOrderIds.take(2).subscribe(body -> { - LOG.info("Processing " + body); - producerTemplate.sendBody(mockEndpoint, body); - }); + LOG.info("Processing " + body); + producerTemplate.sendBody(mockEndpoint, body); + }); // now lets send some orders in Order[] orders = {new Order("a", 49.95), new Order("b", 125.50), new Order("c", 22.95), http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableTest.java index c534e8f..860e3fb 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableTest.java @@ -34,10 +34,10 @@ public class ToObservableTest extends RxTestSupport { Observable<Message> observable = reactiveCamel.toObservable("timer://foo?fixedRate=true&period=100"); observable.take(4).subscribe(message -> { - String body = "Processing message headers " + message.getHeaders(); - LOG.info(body); - producerTemplate.sendBody(mockEndpoint, body); - }); + String body = "Processing message headers " + message.getHeaders(); + LOG.info(body); + producerTemplate.sendBody(mockEndpoint, body); + }); mockEndpoint.assertIsSatisfied(); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableUoWTest.java ---------------------------------------------------------------------- diff --git a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableUoWTest.java b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableUoWTest.java index 9a4e82b..f14768d 100644 --- a/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableUoWTest.java +++ b/components/camel-rx/src/test/java/org/apache/camel/rx/ToObservableUoWTest.java @@ -40,9 +40,9 @@ public class ToObservableUoWTest extends RxTestSupport { Observable<Message> observable = reactiveCamel.toObservable("file://target/foo?move=done"); observable.subscribe(message -> { - String body = message.getBody(String.class); - producerTemplate.sendBody("mock:results", body); - }); + String body = message.getBody(String.class); + producerTemplate.sendBody("mock:results", body); + }); producerTemplate.sendBodyAndHeader("file://target/foo", "Hello World", Exchange.FILE_NAME, "hello.txt"); producerTemplate.sendBodyAndHeader("file://target/foo", "Bye World", Exchange.FILE_NAME, "bye.txt"); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/dto/analytics/reports/FormatEnum.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/dto/analytics/reports/FormatEnum.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/dto/analytics/reports/FormatEnum.java index b9b825b..939acd9 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/dto/analytics/reports/FormatEnum.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/api/dto/analytics/reports/FormatEnum.java @@ -35,7 +35,7 @@ public enum FormatEnum { final String value; - private FormatEnum(String value) { + FormatEnum(String value) { this.value = value; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java index efe09ce..eba175d 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/OperationName.java @@ -61,7 +61,7 @@ public enum OperationName { private final String value; - private OperationName(String value) { + OperationName(String value) { this.value = value; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java index 562719c..ed5388c 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/DefaultRestClient.java @@ -426,7 +426,7 @@ public class DefaultRestClient extends AbstractClientBase implements RestClient private static class DelegatingClientCallback implements ClientResponseCallback { private final ResponseCallback callback; - public DelegatingClientCallback(ResponseCallback callback) { + DelegatingClientCallback(ResponseCallback callback) { this.callback = callback; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityHandler.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityHandler.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityHandler.java index 8df28de..679cb1c 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityHandler.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/client/SalesforceSecurityHandler.java @@ -87,7 +87,7 @@ public class SalesforceSecurityHandler implements ProtocolHandler { private class SecurityListener extends BufferingResponseListener { - public SecurityListener(int maxLength) { + SecurityListener(int maxLength) { super(maxLength); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForFieldsEnum.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForFieldsEnum.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForFieldsEnum.java index 0385be3..9096091 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForFieldsEnum.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForFieldsEnum.java @@ -35,7 +35,7 @@ public enum NotifyForFieldsEnum { final String value; - private NotifyForFieldsEnum(String value) { + NotifyForFieldsEnum(String value) { this.value = value; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForOperationsEnum.java ---------------------------------------------------------------------- diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForOperationsEnum.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForOperationsEnum.java index 6ac2b87..b5eda3b 100644 --- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForOperationsEnum.java +++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/internal/dto/NotifyForOperationsEnum.java @@ -35,7 +35,7 @@ public enum NotifyForOperationsEnum { final String value; - private NotifyForOperationsEnum(String value) { + NotifyForOperationsEnum(String value) { this.value = value; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-script/src/main/java/org/apache/camel/builder/script/ScriptBuilder.java ---------------------------------------------------------------------- diff --git a/components/camel-script/src/main/java/org/apache/camel/builder/script/ScriptBuilder.java b/components/camel-script/src/main/java/org/apache/camel/builder/script/ScriptBuilder.java index 3ee457c..af2ba63 100644 --- a/components/camel-script/src/main/java/org/apache/camel/builder/script/ScriptBuilder.java +++ b/components/camel-script/src/main/java/org/apache/camel/builder/script/ScriptBuilder.java @@ -496,7 +496,7 @@ public class ScriptBuilder implements Expression, Predicate, Processor { context.setAttribute("body", in.getBody(), scope); if (exchange.hasOut()) { Message out = exchange.getOut(); - context.setAttribute("out", out , scope); + context.setAttribute("out", out, scope); context.setAttribute("response", out, scope); } // to make using properties component easier http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-script/src/test/java/org/apache/camel/builder/script/Jsr223Test.java ---------------------------------------------------------------------- diff --git a/components/camel-script/src/test/java/org/apache/camel/builder/script/Jsr223Test.java b/components/camel-script/src/test/java/org/apache/camel/builder/script/Jsr223Test.java index 22db508..72d80b4 100644 --- a/components/camel-script/src/test/java/org/apache/camel/builder/script/Jsr223Test.java +++ b/components/camel-script/src/test/java/org/apache/camel/builder/script/Jsr223Test.java @@ -33,7 +33,7 @@ public class Jsr223Test extends TestCase { ScriptEngineManager manager = new ScriptEngineManager(); for (String scriptName : scriptNames) { ScriptEngine engine = manager.getEngineByName(scriptName); - assertNotNull("We should get the script engine for " + scriptName , engine); + assertNotNull("We should get the script engine for " + scriptName, engine); } } } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-servicenow/src/main/java/org/apache/camel/component/servicenow/ServiceNowProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-servicenow/src/main/java/org/apache/camel/component/servicenow/ServiceNowProducer.java b/components/camel-servicenow/src/main/java/org/apache/camel/component/servicenow/ServiceNowProducer.java index 0830bad..d0c91c5 100644 --- a/components/camel-servicenow/src/main/java/org/apache/camel/component/servicenow/ServiceNowProducer.java +++ b/components/camel-servicenow/src/main/java/org/apache/camel/component/servicenow/ServiceNowProducer.java @@ -80,7 +80,7 @@ public class ServiceNowProducer extends DefaultProducer { private final ThreadLocal<WeakReference<Processor>> cache; private final ServiceNowProducerProcessor.Supplier supplier; - public WeakThreadLocal(ServiceNowProducerProcessor.Supplier supplier) { + WeakThreadLocal(ServiceNowProducerProcessor.Supplier supplier) { this.cache = new ThreadLocal<>(); this.supplier = supplier; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationBase64Test.java ---------------------------------------------------------------------- diff --git a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationBase64Test.java b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationBase64Test.java index db0bbc1..a3a4b7b 100644 --- a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationBase64Test.java +++ b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationBase64Test.java @@ -93,7 +93,7 @@ public class ShiroAuthenticationBase64Test extends CamelTestSupport { private static class TestShiroSecurityTokenInjector extends ShiroSecurityTokenInjector { - public TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { + TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { super(shiroSecurityToken, bytes); setBase64(true); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationReauthenticateFalseAndNewUserTest.java ---------------------------------------------------------------------- diff --git a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationReauthenticateFalseAndNewUserTest.java b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationReauthenticateFalseAndNewUserTest.java index 3860034..18b872a 100644 --- a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationReauthenticateFalseAndNewUserTest.java +++ b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationReauthenticateFalseAndNewUserTest.java @@ -80,7 +80,7 @@ public class ShiroAuthenticationReauthenticateFalseAndNewUserTest extends CamelT private static class TestShiroSecurityTokenInjector extends ShiroSecurityTokenInjector { - public TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { + TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { super(shiroSecurityToken, bytes); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationTest.java b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationTest.java index 748c351..2d40600 100644 --- a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationTest.java +++ b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthenticationTest.java @@ -121,7 +121,7 @@ public class ShiroAuthenticationTest extends CamelTestSupport { private static class TestShiroSecurityTokenInjector extends ShiroSecurityTokenInjector { - public TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { + TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { super(shiroSecurityToken, bytes); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthorizationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthorizationTest.java b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthorizationTest.java index df69a38..9f0b24c 100644 --- a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthorizationTest.java +++ b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroAuthorizationTest.java @@ -208,7 +208,7 @@ public class ShiroAuthorizationTest extends CamelTestSupport { private static class TestShiroSecurityTokenInjector extends ShiroSecurityTokenInjector { - public TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { + TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { super(shiroSecurityToken, bytes); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroRolesAuthorizationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroRolesAuthorizationTest.java b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroRolesAuthorizationTest.java index ba57566..9351e0d 100644 --- a/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroRolesAuthorizationTest.java +++ b/components/camel-shiro/src/test/java/org/apache/camel/component/shiro/security/ShiroRolesAuthorizationTest.java @@ -165,7 +165,7 @@ public class ShiroRolesAuthorizationTest extends CamelTestSupport { private static class TestShiroSecurityTokenInjector extends ShiroSecurityTokenInjector { - public TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { + TestShiroSecurityTokenInjector(ShiroSecurityToken shiroSecurityToken, byte[] bytes) { super(shiroSecurityToken, bytes); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SessionCompletion.java ---------------------------------------------------------------------- diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SessionCompletion.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SessionCompletion.java index f2a7e69..6fe2657 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SessionCompletion.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SessionCompletion.java @@ -31,7 +31,7 @@ class SessionCompletion implements Synchronization { // TODO: add more details in the commit/rollback eg such as message id - public SessionCompletion(Session session) { + SessionCompletion(Session session) { this.session = session; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java index 215a72b..1fe5617 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumer.java @@ -194,7 +194,7 @@ public class SjmsBatchConsumer extends DefaultConsumer { private final List<AtomicBoolean> triggers; - public CompletionIntervalTask(List<AtomicBoolean> triggers) { + CompletionIntervalTask(List<AtomicBoolean> triggers) { this.triggers = triggers; } @@ -276,7 +276,7 @@ public class SjmsBatchConsumer extends DefaultConsumer { private long startTime; private Exchange aggregatedExchange; - public BatchConsumptionTask(AtomicBoolean timeoutInterval) { + BatchConsumptionTask(AtomicBoolean timeoutInterval) { this.timeoutInterval = timeoutInterval; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/SessionAcknowledgementType.java ---------------------------------------------------------------------- diff --git a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/SessionAcknowledgementType.java b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/SessionAcknowledgementType.java index 2ca0e79..658f83d 100644 --- a/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/SessionAcknowledgementType.java +++ b/components/camel-sjms/src/main/java/org/apache/camel/component/sjms/jms/SessionAcknowledgementType.java @@ -29,7 +29,7 @@ public enum SessionAcknowledgementType { private int intValue = -1; - private SessionAcknowledgementType(int intValue) { + SessionAcknowledgementType(int intValue) { this.intValue = intValue; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java ---------------------------------------------------------------------- diff --git a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java index 80c1970..e9e5cc8 100644 --- a/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java +++ b/components/camel-sjms/src/test/java/org/apache/camel/component/sjms/batch/SjmsBatchConsumerTest.java @@ -65,7 +65,7 @@ public class SjmsBatchConsumerTest extends CamelTestSupport { private static class TransactedSendHarness extends RouteBuilder { private final String queueName; - public TransactedSendHarness(String queueName) { + TransactedSendHarness(String queueName) { this.queueName = queueName; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppCommandType.java ---------------------------------------------------------------------- diff --git a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppCommandType.java b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppCommandType.java index 50f4e89..8582ad1 100644 --- a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppCommandType.java +++ b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppCommandType.java @@ -61,7 +61,7 @@ public enum SmppCommandType { private String commandName; - private SmppCommandType(String commandName) { + SmppCommandType(String commandName) { this.commandName = commandName; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-soap/src/main/java/org/apache/camel/dataformat/soap/name/TypeInfo.java ---------------------------------------------------------------------- diff --git a/components/camel-soap/src/main/java/org/apache/camel/dataformat/soap/name/TypeInfo.java b/components/camel-soap/src/main/java/org/apache/camel/dataformat/soap/name/TypeInfo.java index 3b28f14..94e157b 100644 --- a/components/camel-soap/src/main/java/org/apache/camel/dataformat/soap/name/TypeInfo.java +++ b/components/camel-soap/src/main/java/org/apache/camel/dataformat/soap/name/TypeInfo.java @@ -28,11 +28,8 @@ final class TypeInfo { /** * Initialize TypeInfo with given name and resolved element name for a type - * - * @param typeName - * @param elName */ - public TypeInfo(final String typeName, final QName elName) { + TypeInfo(final String typeName, final QName elName) { this.typeName = typeName; this.elName = elName; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-spark/src/main/java/org/apache/camel/component/spark/annotations/AnnotatedRddCallbackProxy.java ---------------------------------------------------------------------- diff --git a/components/camel-spark/src/main/java/org/apache/camel/component/spark/annotations/AnnotatedRddCallbackProxy.java b/components/camel-spark/src/main/java/org/apache/camel/component/spark/annotations/AnnotatedRddCallbackProxy.java index dffdbc1..dbf6442 100644 --- a/components/camel-spark/src/main/java/org/apache/camel/component/spark/annotations/AnnotatedRddCallbackProxy.java +++ b/components/camel-spark/src/main/java/org/apache/camel/component/spark/annotations/AnnotatedRddCallbackProxy.java @@ -37,7 +37,7 @@ class AnnotatedRddCallbackProxy implements RddCallback { private final CamelContext camelContext; - public AnnotatedRddCallbackProxy(Object objectWithCallback, CamelContext camelContext) { + AnnotatedRddCallbackProxy(Object objectWithCallback, CamelContext camelContext) { this.objectWithCallback = objectWithCallback; this.camelContext = camelContext; this.rddCallbacks = findMethodsWithAnnotation(objectWithCallback.getClass(), org.apache.camel.component.spark.annotations.RddCallback.class); @@ -46,7 +46,7 @@ class AnnotatedRddCallbackProxy implements RddCallback { } } - public AnnotatedRddCallbackProxy(Object objectWithCallback) { + AnnotatedRddCallbackProxy(Object objectWithCallback) { this(objectWithCallback, null); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-splunk/src/test/java/org/apache/camel/component/splunk/Helper.java ---------------------------------------------------------------------- diff --git a/components/camel-splunk/src/test/java/org/apache/camel/component/splunk/Helper.java b/components/camel-splunk/src/test/java/org/apache/camel/component/splunk/Helper.java index 55b5b81..ebd7901 100644 --- a/components/camel-splunk/src/test/java/org/apache/camel/component/splunk/Helper.java +++ b/components/camel-splunk/src/test/java/org/apache/camel/component/splunk/Helper.java @@ -54,7 +54,7 @@ final class MockConnectionSettings extends SplunkConfiguration { private Service service; private Socket socket; - public MockConnectionSettings(Service service, Socket socket) { + MockConnectionSettings(Service service, Socket socket) { this.service = service; this.socket = socket; mockSplunkWriterApi(); @@ -82,7 +82,7 @@ final class MockConnectionSettings extends SplunkConfiguration { class MockConnectionFactory extends SplunkConnectionFactory { private Service service; - public MockConnectionFactory(Service service) { + MockConnectionFactory(Service service) { super("foo", "bar"); this.service = service; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java index 7d74deb..e42de06 100644 --- a/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java +++ b/components/camel-spring-batch/src/main/java/org/apache/camel/component/spring/batch/support/CamelJobExecutionListener.java @@ -49,7 +49,7 @@ public class CamelJobExecutionListener implements JobExecutionListener { LOG.debug("sent after job execution event"); } - public static enum EventType { + public enum EventType { BEFORE, AFTER; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationConsumer.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationConsumer.java index fac7139..e4e8c5b 100644 --- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationConsumer.java +++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationConsumer.java @@ -101,7 +101,7 @@ public class SpringIntegrationConsumer extends DefaultConsumer implements Messa try { getProcessor().process(exchange); } catch (Exception e) { - getExceptionHandler().handleException("Error processing exchange" , exchange, e); + getExceptionHandler().handleException("Error processing exchange", exchange, e); return; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java index 3be4d0c..8b653be 100644 --- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java +++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/SpringIntegrationProducer.java @@ -90,7 +90,7 @@ public class SpringIntegrationProducer extends DefaultProducer implements Proces if (inputChannel == null) { throw new IllegalArgumentException("InputChannel has not been configured on " + getEndpoint()); } - exchange.getIn().getHeaders().put(MessageHeaders.REPLY_CHANNEL , inputChannel); + exchange.getIn().getHeaders().put(MessageHeaders.REPLY_CHANNEL, inputChannel); // subscribe so we can receive the reply from spring integration inputChannel.subscribe(new MessageHandler() { http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelSourceAdapter.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelSourceAdapter.java b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelSourceAdapter.java index d963578..58cb444 100644 --- a/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelSourceAdapter.java +++ b/components/camel-spring-integration/src/main/java/org/apache/camel/component/spring/integration/adapter/CamelSourceAdapter.java @@ -66,7 +66,7 @@ public class CamelSourceAdapter extends AbstractCamelAdapter implements Initiali org.springframework.messaging.Message<?> request = SpringIntegrationBinding.createSpringIntegrationMessage(exchange); if (exchange.getPattern().isOutCapable()) { - exchange.getIn().getHeaders().put(MessageHeaders.REPLY_CHANNEL , replyChannel); + exchange.getIn().getHeaders().put(MessageHeaders.REPLY_CHANNEL, replyChannel); // we want to do in-out so the inputChannel is mandatory (used to receive reply from spring integration) if (replyChannel == null) { http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingType.java ---------------------------------------------------------------------- diff --git a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingType.java b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingType.java index 85fceb1..ae9a33c 100644 --- a/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingType.java +++ b/components/camel-spring-ws/src/main/java/org/apache/camel/component/spring/ws/type/EndpointMappingType.java @@ -31,7 +31,7 @@ public enum EndpointMappingType { private String prefix; - private EndpointMappingType(String prefix) { + EndpointMappingType(String prefix) { this.prefix = prefix; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogConverter.java ---------------------------------------------------------------------- diff --git a/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogConverter.java b/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogConverter.java index e872498..7d787b2 100644 --- a/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogConverter.java +++ b/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogConverter.java @@ -34,7 +34,7 @@ public final class SyslogConverter { private static final Logger LOG = LoggerFactory.getLogger(SyslogConverter.class); - private static enum MONTHS { + private enum MONTHS { jan, feb, mar, apr, may, jun, jul, aug, sep, oct, nov, dec } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java ---------------------------------------------------------------------- diff --git a/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java b/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java index 595fe28..a2bb2ca 100644 --- a/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java +++ b/components/camel-syslog/src/test/java/org/apache/camel/component/syslog/NettyRfc5425Test.java @@ -64,7 +64,7 @@ public class NettyRfc5425Test extends CamelTestSupport { mock2.expectedMessageCount(2); mock2.expectedBodiesReceived(rfc3164Message, rfc5424Message); - template.sendBody(uriClient , rfc3164Message.getBytes("UTF8")); + template.sendBody(uriClient, rfc3164Message.getBytes("UTF8")); template.sendBody(uriClient, rfc5424Message.getBytes("UTF8")); assertMockEndpointsSatisfied(); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java ---------------------------------------------------------------------- diff --git a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java index 5394076..e70bec4 100644 --- a/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java +++ b/components/camel-tarfile/src/main/java/org/apache/camel/processor/aggregate/tarfile/TarAggregationStrategy.java @@ -259,7 +259,7 @@ public class TarAggregationStrategy implements AggregationStrategy { private final File fileToDelete; - public DeleteTarFileOnCompletion(File fileToDelete) { + DeleteTarFileOnCompletion(File fileToDelete) { this.fileToDelete = fileToDelete; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java index 1e87e14..18f0aee 100644 --- a/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java +++ b/components/camel-twitter/src/main/java/org/apache/camel/component/twitter/consumer/timeline/AbstractStatusConsumer.java @@ -30,7 +30,7 @@ import twitter4j.TwitterException; */ abstract class AbstractStatusConsumer extends TwitterConsumer { - public AbstractStatusConsumer(TwitterEndpoint endpoint) { + AbstractStatusConsumer(TwitterEndpoint endpoint) { super(endpoint); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterTestSupport.java ---------------------------------------------------------------------- diff --git a/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterTestSupport.java b/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterTestSupport.java index bd6fe48..de189c4 100644 --- a/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterTestSupport.java +++ b/components/camel-twitter/src/test/java/org/apache/camel/component/twitter/CamelTwitterTestSupport.java @@ -36,9 +36,9 @@ public class CamelTwitterTestSupport extends CamelTestSupport { // Load from env addProperty(properties, "consumer.key", "CAMEL_TWITTER_CONSUMER_KEY"); - addProperty(properties, "consumer.secret" , "CAMEL_TWITTER_CONSUMER_SECRET"); - addProperty(properties, "access.token" , "CAMEL_TWITTER_ACCESS_TOKEN"); - addProperty(properties, "access.token.secret" , "CAMEL_TWITTER_ACCESS_TOKE_SECRET"); + addProperty(properties, "consumer.secret", "CAMEL_TWITTER_CONSUMER_SECRET"); + addProperty(properties, "access.token", "CAMEL_TWITTER_ACCESS_TOKEN"); + addProperty(properties, "access.token.secret", "CAMEL_TWITTER_ACCESS_TOKE_SECRET"); // if any of the properties is not set, load test-options.properties if (!properties.containsKey("consumer.key") http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowProducer.java b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowProducer.java index c74b7c3..5b6a087 100644 --- a/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowProducer.java +++ b/components/camel-undertow/src/main/java/org/apache/camel/component/undertow/UndertowProducer.java @@ -152,7 +152,7 @@ public class UndertowProducer extends DefaultAsyncProducer { private final Exchange camelExchange; private final AsyncCallback callback; - public UndertowProducerCallback(ClientConnection connection, ByteBuffer body, Exchange camelExchange, AsyncCallback callback) { + UndertowProducerCallback(ClientConnection connection, ByteBuffer body, Exchange camelExchange, AsyncCallback callback) { this.connection = connection; this.body = body; this.camelExchange = camelExchange; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java index 7c9cbb7..271b75f 100644 --- a/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java +++ b/components/camel-websocket/src/main/java/org/apache/camel/component/websocket/WebsocketComponent.java @@ -91,7 +91,7 @@ public class WebsocketComponent extends UriEndpointComponent { MemoryWebsocketStore memoryStore; int refCount; - public ConnectorRef(Server server, ServerConnector connector, WebsocketComponentServlet servlet, MemoryWebsocketStore memoryStore) { + ConnectorRef(Server server, ServerConnector connector, WebsocketComponentServlet servlet, MemoryWebsocketStore memoryStore) { this.server = server; this.connector = connector; this.servlet = servlet; @@ -229,9 +229,7 @@ public class WebsocketComponent extends UriEndpointComponent { ConnectorRef connectorRef = CONNECTORS.get(connectorKey); if (connectorRef != null) { if (connectorRef.decrement() == 0) { - LOG.info("Stopping Jetty Server as the last connector is disconnecting: {}:{}" - , connectorRef.connector.getHost() - , connectorRef.connector.getPort()); + LOG.info("Stopping Jetty Server as the last connector is disconnecting: {}:{}", connectorRef.connector.getHost(), connectorRef.connector.getPort()); servlets.remove(createPathSpec(endpoint.getResourceUri())); connectorRef.server.removeConnector(connectorRef.connector); if (connectorRef.connector != null) { http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/api/XmlSignatureProperties.java ---------------------------------------------------------------------- diff --git a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/api/XmlSignatureProperties.java b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/api/XmlSignatureProperties.java index 3dea473..2953823 100644 --- a/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/api/XmlSignatureProperties.java +++ b/components/camel-xmlsecurity/src/main/java/org/apache/camel/component/xmlsecurity/api/XmlSignatureProperties.java @@ -117,7 +117,7 @@ public interface XmlSignatureProperties { } - public static class Output { + class Output { private String contentReferenceId; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XAdESSignaturePropertiesTest.java ---------------------------------------------------------------------- diff --git a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XAdESSignaturePropertiesTest.java b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XAdESSignaturePropertiesTest.java index 7c0a61a..f7cb5ce 100644 --- a/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XAdESSignaturePropertiesTest.java +++ b/components/camel-xmlsecurity/src/test/java/org/apache/camel/component/xmlsecurity/XAdESSignaturePropertiesTest.java @@ -899,7 +899,7 @@ public class XAdESSignaturePropertiesTest extends CamelTestSupport { private String alias = "bob"; - public CertChainXAdESSignatureProperties() { + CertChainXAdESSignatureProperties() { setAddSigningTime(false); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java index d56e108..2b59fe3 100644 --- a/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java +++ b/components/camel-xmpp/src/main/java/org/apache/camel/component/xmpp/XmppPrivateChatProducer.java @@ -108,8 +108,7 @@ public class XmppPrivateChatProducer extends DefaultProducer { public void processMessage(Chat chat, Message message) { // not here to do conversation if (LOG.isDebugEnabled()) { - LOG.debug("Received and discarding message from {} : {}" - , participant, message.getBody()); + LOG.debug("Received and discarding message from {} : {}", participant, message.getBody()); } } }); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-xstream/src/test/java/org/apache/camel/dataformat/xstream/XStreamDataFormatOmitFieldsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-xstream/src/test/java/org/apache/camel/dataformat/xstream/XStreamDataFormatOmitFieldsTest.java b/components/camel-xstream/src/test/java/org/apache/camel/dataformat/xstream/XStreamDataFormatOmitFieldsTest.java index f8e28dd..18f0466 100644 --- a/components/camel-xstream/src/test/java/org/apache/camel/dataformat/xstream/XStreamDataFormatOmitFieldsTest.java +++ b/components/camel-xstream/src/test/java/org/apache/camel/dataformat/xstream/XStreamDataFormatOmitFieldsTest.java @@ -57,10 +57,10 @@ public class XStreamDataFormatOmitFieldsTest extends CamelTestSupport { Map<String, String[]> omitFields = new HashMap<String, String[]>(); omitFields.put(PurchaseOrder.class.getName(), new String[]{"price"}); xStreamDataFormat.setOmitFields(omitFields); - + from("direct:start"). marshal(xStreamDataFormat). - convertBodyTo(String.class). + convertBodyTo(String.class). to("mock:result"); } }; http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipInputStreamWrapper.java ---------------------------------------------------------------------- diff --git a/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipInputStreamWrapper.java b/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipInputStreamWrapper.java index 0986c77..c5468b1 100644 --- a/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipInputStreamWrapper.java +++ b/components/camel-zipfile/src/main/java/org/apache/camel/dataformat/zipfile/ZipInputStreamWrapper.java @@ -22,11 +22,11 @@ import java.io.InputStream; class ZipInputStreamWrapper extends BufferedInputStream { - public ZipInputStreamWrapper(InputStream in, int size) { + ZipInputStreamWrapper(InputStream in, int size) { super(in, size); } - public ZipInputStreamWrapper(InputStream in) { + ZipInputStreamWrapper(InputStream in) { super(in); } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zipfile/src/main/java/org/apache/camel/processor/aggregate/zipfile/ZipAggregationStrategy.java ---------------------------------------------------------------------- diff --git a/components/camel-zipfile/src/main/java/org/apache/camel/processor/aggregate/zipfile/ZipAggregationStrategy.java b/components/camel-zipfile/src/main/java/org/apache/camel/processor/aggregate/zipfile/ZipAggregationStrategy.java index a6b7a0c..56a004a 100644 --- a/components/camel-zipfile/src/main/java/org/apache/camel/processor/aggregate/zipfile/ZipAggregationStrategy.java +++ b/components/camel-zipfile/src/main/java/org/apache/camel/processor/aggregate/zipfile/ZipAggregationStrategy.java @@ -223,7 +223,7 @@ public class ZipAggregationStrategy implements AggregationStrategy { private final File fileToDelete; - public DeleteZipFileOnCompletion(File fileToDelete) { + DeleteZipFileOnCompletion(File fileToDelete) { this.fileToDelete = fileToDelete; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java ---------------------------------------------------------------------- diff --git a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java index 0237d26..68d097b 100644 --- a/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java +++ b/components/camel-zipkin/src/main/java/org/apache/camel/zipkin/ZipkinTracer.java @@ -678,9 +678,10 @@ public class ZipkinTracer extends ServiceSupport implements RoutePolicyFactory, private final String routeId; - public ZipkinRoutePolicy(String routeId) { + ZipkinRoutePolicy(String routeId) { this.routeId = routeId; } + @Override public void onExchangeBegin(Route route, Exchange exchange) { // use route policy to track events when Camel a Camel route begins/end the lifecycle of an Exchange http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/NaturalSortComparator.java ---------------------------------------------------------------------- diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/NaturalSortComparator.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/NaturalSortComparator.java index 4c60d77..9646aa6 100644 --- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/NaturalSortComparator.java +++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/NaturalSortComparator.java @@ -37,7 +37,7 @@ public class NaturalSortComparator implements Comparator<CharSequence> { int direction; - private Order(int direction) { + Order(int direction) { this.direction = direction; } } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConnectionManager.java ---------------------------------------------------------------------- diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConnectionManager.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConnectionManager.java index 3b1ab7f..2ef5639 100644 --- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConnectionManager.java +++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperConnectionManager.java @@ -48,7 +48,7 @@ public class ZooKeeperConnectionManager { private ConnectionHolder holder; private ZooKeeperConfiguration configuration; - public DefaultZookeeperConnectionStrategy(ZooKeeperEndpoint endpoint) { + DefaultZookeeperConnectionStrategy(ZooKeeperEndpoint endpoint) { this.configuration = endpoint.getConfiguration(); LOG.debug("Creating connection to ZooKeeper: {}", configuration); holder = new ConnectionHolder(configuration); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperProducer.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperProducer.java index e5428af..449a138 100644 --- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperProducer.java +++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/ZooKeeperProducer.java @@ -157,7 +157,7 @@ public class ZooKeeperProducer extends DefaultProducer { int version; String node; - public ProductionContext(ZooKeeper connection, Exchange exchange) { + ProductionContext(ZooKeeper connection, Exchange exchange) { this.connection = connection; this.exchange = exchange; this.in = exchange.getIn(); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/policy/ZooKeeperElection.java ---------------------------------------------------------------------- diff --git a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/policy/ZooKeeperElection.java b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/policy/ZooKeeperElection.java index cdff74c..cee0e2b 100644 --- a/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/policy/ZooKeeperElection.java +++ b/components/camel-zookeeper/src/main/java/org/apache/camel/component/zookeeper/policy/ZooKeeperElection.java @@ -195,7 +195,7 @@ public class ZooKeeperElection { private SequenceComparator comparator = new SequenceComparator(); private ZooKeeperEndpoint zep; - public ElectoralMonitorRoute(ZooKeeperEndpoint zep) { + ElectoralMonitorRoute(ZooKeeperEndpoint zep) { this.zep = zep; zep.getConfiguration().setListChildren(true); zep.getConfiguration().setSendEmptyMessageOnDelete(true); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/policy/FailoverRoutePolicyTest.java ---------------------------------------------------------------------- diff --git a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/policy/FailoverRoutePolicyTest.java b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/policy/FailoverRoutePolicyTest.java index 8438c37..8ee22ac 100644 --- a/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/policy/FailoverRoutePolicyTest.java +++ b/components/camel-zookeeper/src/test/java/org/apache/camel/component/zookeeper/policy/FailoverRoutePolicyTest.java @@ -64,7 +64,7 @@ public class FailoverRoutePolicyTest extends ZooKeeperTestSupport { private MockEndpoint mock; private String routename; - public ZookeeperPolicyEnforcedContext(String name) throws Exception { + ZookeeperPolicyEnforcedContext(String name) throws Exception { controlledContext = new DefaultCamelContext(); routename = name; template = controlledContext.createProducerTemplate(); http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/httptojms/JmsBroker.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/httptojms/JmsBroker.java b/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/httptojms/JmsBroker.java index 06d641c..74942b0 100644 --- a/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/httptojms/JmsBroker.java +++ b/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/httptojms/JmsBroker.java @@ -54,7 +54,7 @@ public final class JmsBroker { final String brokerUrl; Exception exception; - public JMSEmbeddedBroker(String url) { + JMSEmbeddedBroker(String url) { brokerUrl = url; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/jaxrs/CamelRouterBuilder.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/jaxrs/CamelRouterBuilder.java b/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/jaxrs/CamelRouterBuilder.java index d2429ef..154cd7e 100644 --- a/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/jaxrs/CamelRouterBuilder.java +++ b/examples/camel-example-cxf/src/main/java/org/apache/camel/example/cxf/jaxrs/CamelRouterBuilder.java @@ -103,7 +103,7 @@ public class CamelRouterBuilder extends RouteBuilder { private Class<?> beanClass; private Object instance; - public MappingProcessor(Object obj) { + MappingProcessor(Object obj) { beanClass = obj.getClass(); instance = obj; } http://git-wip-us.apache.org/repos/asf/camel/blob/1608f76e/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java ---------------------------------------------------------------------- diff --git a/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java b/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java index fb96e45..c5f64a7 100644 --- a/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java +++ b/examples/camel-example-loan-broker/src/main/java/org/apache/camel/loanbroker/queue/version/JmsBroker.java @@ -53,7 +53,7 @@ public final class JmsBroker { final String brokerUrl; Exception exception; - public JMSEmbeddedBroker(String url) { + JMSEmbeddedBroker(String url) { brokerUrl = url; }
