Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/5fee9dd8 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/5fee9dd8 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/5fee9dd8 Branch: refs/heads/master Commit: 5fee9dd8e122684580249b5b436030d360832c55 Parents: 1fc9983 Author: Claus Ibsen <[email protected]> Authored: Fri Apr 29 10:02:18 2016 +0200 Committer: Claus Ibsen <[email protected]> Committed: Fri Apr 29 10:02:18 2016 +0200 ---------------------------------------------------------------------- .../braintree/AbstractBraintreeTestSupport.java | 6 +- .../MerchantAccountGatewayIntegrationTest.java | 14 +- .../ResultSetConversionStrategies.java | 2 +- .../cassandra/CassandraCamelCodec.java | 2 +- .../camel/component/cometd/CometdComponent.java | 2 +- .../camel/converter/crypto/HMACAccumulator.java | 2 +- .../dataformat/csv/CsvUnmarshalStreamTest.java | 2 +- .../component/disruptor/DisruptorConsumer.java | 2 +- .../disruptor/DisruptorWaitStrategy.java | 2 +- .../disruptor/SedaDisruptorCompareTest.java | 6 +- .../camel/component/docker/DockerOperation.java | 2 +- .../dropbox/util/DropboxOperation.java | 2 +- .../dropbox/util/DropboxResultHeader.java | 2 +- .../dropbox/util/DropboxUploadMode.java | 2 +- .../component/etcd/policy/EtcdRoutePolicy.java | 2 +- .../camel/component/etcd/EtcdStatsTest.java | 9 +- .../etcd/policy/EtcdRoutePolicyMain.java | 6 +- .../component/facebook/FacebookConsumer.java | 3 +- .../facebook/data/FacebookMethodsType.java | 203 +++++++++---------- .../data/FacebookMethodsTypeHelper.java | 2 +- .../component/facebook/TestUserMethodsTest.java | 3 +- .../component/flatpack/FlatpackProducer.java | 2 +- .../file/remote/OsgiParserFactory.java | 7 +- .../file/remote/sftp/SftpSetCipherTest.java | 2 +- .../file/remote/sftp/SftpSetOperationsTest.java | 2 +- .../camel/component/gora/utils/GoraUtils.java | 2 +- .../guice/jsr250/AnnotatedMethodCache.java | 2 +- ...HL7MLLPConfigAwareChannelHandlerFactory.java | 4 +- .../component/hl7/HL7MLLPNettyDecoder.java | 4 +- .../component/hl7/HL7MLLPNettyEncoder.java | 4 +- .../camel/component/hl7/TerserExpression.java | 2 +- .../infinispan/InfinispanConsumer.java | 2 +- .../apache/camel/component/ironmq/GsonUtil.java | 2 +- .../component/javaspace/JavaSpaceConsumer.java | 2 +- .../javaspace/JavaSpaceRequestReplyTest.java | 2 +- .../jcache/JCacheEntryEventFilters.java | 4 +- .../camel/component/kafka/KafkaConsumer.java | 2 +- .../component/linkedin/api/OAuthScope.java | 2 +- .../camel/component/metrics/MetricsType.java | 2 +- .../MinaClientModeTcpTextlineDelimiterTest.java | 3 +- ...Mina2ClientModeTcpTextlineDelimiterTest.java | 3 +- .../junit/rule/mllp/MllpServerResource.java | 8 +- .../camel/component/nats/NatsConsumer.java | 2 +- .../ClassLoadingAwareObjectInputStreamTest.java | 2 +- 44 files changed, 172 insertions(+), 171 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/AbstractBraintreeTestSupport.java ---------------------------------------------------------------------- diff --git a/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/AbstractBraintreeTestSupport.java b/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/AbstractBraintreeTestSupport.java index c145b9b..4a0e801 100644 --- a/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/AbstractBraintreeTestSupport.java +++ b/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/AbstractBraintreeTestSupport.java @@ -66,9 +66,9 @@ public class AbstractBraintreeTestSupport extends CamelTestSupport { } addOptionIfMissing(options, "environment", "CAMEL_BRAINTREE_ENVIRONMENT"); - addOptionIfMissing(options, "merchantId" , "CAMEL_BRAINTREE_MERCHANT_ID"); - addOptionIfMissing(options, "publicKey" , "CAMEL_BRAINTREE_PUBLIC_KEY"); - addOptionIfMissing(options, "privateKey" , "CAMEL_BRAINTREE_PRIVATE_KEY"); + addOptionIfMissing(options, "merchantId", "CAMEL_BRAINTREE_MERCHANT_ID"); + addOptionIfMissing(options, "publicKey", "CAMEL_BRAINTREE_PUBLIC_KEY"); + addOptionIfMissing(options, "privateKey", "CAMEL_BRAINTREE_PRIVATE_KEY"); final BraintreeConfiguration configuration = new BraintreeConfiguration(); configuration.setHttpLogLevel(Level.WARNING); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/MerchantAccountGatewayIntegrationTest.java ---------------------------------------------------------------------- diff --git a/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/MerchantAccountGatewayIntegrationTest.java b/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/MerchantAccountGatewayIntegrationTest.java index 7d833cd..d89b0fc 100644 --- a/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/MerchantAccountGatewayIntegrationTest.java +++ b/components/camel-braintree/src/test/java/org/apache/camel/component/braintree/MerchantAccountGatewayIntegrationTest.java @@ -45,13 +45,13 @@ public class MerchantAccountGatewayIntegrationTest extends AbstractBraintreeTest new MerchantAccountRequest() .masterMerchantAccountId(System.getenv("CAMEL_BRAINTREE_MERCHANT_ACCOUNT_ID")) .individual() - .firstName("merchant") - .lastName(merchantId) - .address() - .streetAddress("my street") - .done() - .done() - , Result.class + .firstName("merchant") + .lastName(merchantId) + .address() + .streetAddress("my street") + .done() + .done(), + Result.class ); assertNotNull("create result", result); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/ResultSetConversionStrategies.java ---------------------------------------------------------------------- diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/ResultSetConversionStrategies.java b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/ResultSetConversionStrategies.java index 29aa7a2..bda0234 100644 --- a/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/ResultSetConversionStrategies.java +++ b/components/camel-cassandraql/src/main/java/org/apache/camel/component/cassandra/ResultSetConversionStrategies.java @@ -68,7 +68,7 @@ public final class ResultSetConversionStrategies { private static class LimitResultSetConversionStrategy implements ResultSetConversionStrategy { private final int rowMax; - public LimitResultSetConversionStrategy(int rowMax) { + LimitResultSetConversionStrategy(int rowMax) { this.rowMax = rowMax; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraCamelCodec.java ---------------------------------------------------------------------- diff --git a/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraCamelCodec.java b/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraCamelCodec.java index d4a403b..e49af9c 100644 --- a/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraCamelCodec.java +++ b/components/camel-cassandraql/src/main/java/org/apache/camel/processor/aggregate/cassandra/CassandraCamelCodec.java @@ -88,7 +88,7 @@ public class CassandraCamelCodec { private final ByteBuffer buffer; - public ByteBufferInputStream(ByteBuffer buffer) { + ByteBufferInputStream(ByteBuffer buffer) { this.buffer = buffer; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java ---------------------------------------------------------------------- diff --git a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java index f01b160..3ff8ee0 100644 --- a/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java +++ b/components/camel-cometd/src/main/java/org/apache/camel/component/cometd/CometdComponent.java @@ -69,7 +69,7 @@ public class CometdComponent extends UriEndpointComponent { Server server; int refCount; - public ConnectorRef(Connector connector, CometDServlet servlet, Server server) { + ConnectorRef(Connector connector, CometDServlet servlet, Server server) { this.connector = connector; this.servlet = servlet; this.server = server; http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/HMACAccumulator.java ---------------------------------------------------------------------- diff --git a/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/HMACAccumulator.java b/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/HMACAccumulator.java index 99f9fee..477670f 100644 --- a/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/HMACAccumulator.java +++ b/components/camel-crypto/src/main/java/org/apache/camel/converter/crypto/HMACAccumulator.java @@ -123,7 +123,7 @@ public class HMACAccumulator { private int read; private int available; - public CircularBuffer(int bufferSize) { + CircularBuffer(int bufferSize) { buffer = new byte[bufferSize]; available = bufferSize; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvUnmarshalStreamTest.java ---------------------------------------------------------------------- diff --git a/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvUnmarshalStreamTest.java b/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvUnmarshalStreamTest.java index 3c049b8..6ba0ea5 100644 --- a/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvUnmarshalStreamTest.java +++ b/components/camel-csv/src/test/java/org/apache/camel/dataformat/csv/CsvUnmarshalStreamTest.java @@ -84,7 +84,7 @@ public class CsvUnmarshalStreamTest extends CamelTestSupport { class MyFileInputStream extends FileInputStream { - public MyFileInputStream(File file) throws FileNotFoundException { + MyFileInputStream(File file) throws FileNotFoundException { super(file); } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java index d4f0415..c766f7e 100644 --- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java +++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorConsumer.java @@ -196,7 +196,7 @@ public class DisruptorConsumer extends ServiceSupport implements Consumer, Suspe private final int concurrentConsumers; - public ConsumerEventHandler(final int ordinal, final int concurrentConsumers) { + ConsumerEventHandler(final int ordinal, final int concurrentConsumers) { this.ordinal = ordinal; this.concurrentConsumers = concurrentConsumers; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorWaitStrategy.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorWaitStrategy.java b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorWaitStrategy.java index 198f95b..fa69f0e 100644 --- a/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorWaitStrategy.java +++ b/components/camel-disruptor/src/main/java/org/apache/camel/component/disruptor/DisruptorWaitStrategy.java @@ -78,7 +78,7 @@ public enum DisruptorWaitStrategy { private final Class<? extends WaitStrategy> waitStrategyClass; - private DisruptorWaitStrategy(final Class<? extends WaitStrategy> waitStrategyClass) { + DisruptorWaitStrategy(final Class<? extends WaitStrategy> waitStrategyClass) { this.waitStrategyClass = waitStrategyClass; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/SedaDisruptorCompareTest.java ---------------------------------------------------------------------- diff --git a/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/SedaDisruptorCompareTest.java b/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/SedaDisruptorCompareTest.java index cd94143..7593369 100644 --- a/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/SedaDisruptorCompareTest.java +++ b/components/camel-disruptor/src/test/java/org/apache/camel/component/disruptor/SedaDisruptorCompareTest.java @@ -161,7 +161,7 @@ public class SedaDisruptorCompareTest extends CamelTestSupport { parameters .add(new Object[] {"SEDA LONG {P=1, C=1, CCT=1, SIZE=" + SIZE_PARAMETER_VALUE + "}", "seda:speedtest?concurrentConsumers=1&waitForTaskToComplete=IfReplyExpected&timeout=30000&multipleConsumers=false&limitConcurrentConsumers=true&blockWhenFull=true&size=" - + SIZE_PARAMETER_VALUE , + + SIZE_PARAMETER_VALUE, singleProducer(), singleConsumer(), singleConcurrentConsumerThread(), SEDA_SIZE_HISTOGRAM_BOUNDS}); } @@ -352,7 +352,7 @@ public class SedaDisruptorCompareTest extends CamelTestSupport { private Queue<Long> latencyQueue = new ConcurrentLinkedQueue<Long>(); - public ExchangeAwaiter(final int count) { + ExchangeAwaiter(final int count) { this.count = count; } @@ -410,7 +410,7 @@ public class SedaDisruptorCompareTest extends CamelTestSupport { private final int totalMessageCount; private int producedMessageCount; - public ProducerThread(final int totalMessageCount) { + ProducerThread(final int totalMessageCount) { super("TestDataProducerThread"); this.totalMessageCount = totalMessageCount; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-docker/src/main/java/org/apache/camel/component/docker/DockerOperation.java ---------------------------------------------------------------------- diff --git a/components/camel-docker/src/main/java/org/apache/camel/component/docker/DockerOperation.java b/components/camel-docker/src/main/java/org/apache/camel/component/docker/DockerOperation.java index b83b0b7..36ae1e3 100644 --- a/components/camel-docker/src/main/java/org/apache/camel/component/docker/DockerOperation.java +++ b/components/camel-docker/src/main/java/org/apache/camel/component/docker/DockerOperation.java @@ -211,7 +211,7 @@ public enum DockerOperation { private Map<String, Class<?>> parameters; - private DockerOperation(String text, boolean canConsume, boolean canProduce, Object... params) { + DockerOperation(String text, boolean canConsume, boolean canProduce, Object... params) { this.text = text; this.canConsume = canConsume; http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxOperation.java ---------------------------------------------------------------------- diff --git a/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxOperation.java b/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxOperation.java index ab25b75..91d5744 100755 --- a/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxOperation.java +++ b/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxOperation.java @@ -25,7 +25,7 @@ public enum DropboxOperation { private final String text; - private DropboxOperation(final String text) { + DropboxOperation(final String text) { this.text = text; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxResultHeader.java ---------------------------------------------------------------------- diff --git a/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxResultHeader.java b/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxResultHeader.java index 531353f..0ab2fc1 100755 --- a/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxResultHeader.java +++ b/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxResultHeader.java @@ -17,6 +17,6 @@ package org.apache.camel.component.dropbox.util; public enum DropboxResultHeader { - DOWNLOADED_FILE, DOWNLOADED_FILES, UPLOADED_FILE, UPLOADED_FILES, FOUNDED_FILES , DELETED_PATH, MOVED_PATH; + DOWNLOADED_FILE, DOWNLOADED_FILES, UPLOADED_FILE, UPLOADED_FILES, FOUNDED_FILES, DELETED_PATH, MOVED_PATH; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxUploadMode.java ---------------------------------------------------------------------- diff --git a/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxUploadMode.java b/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxUploadMode.java index d20516d..1556c6a 100755 --- a/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxUploadMode.java +++ b/components/camel-dropbox/src/main/java/org/apache/camel/component/dropbox/util/DropboxUploadMode.java @@ -22,7 +22,7 @@ public enum DropboxUploadMode { private final String text; - private DropboxUploadMode(final String text) { + DropboxUploadMode(final String text) { this.text = text; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicy.java ---------------------------------------------------------------------- diff --git a/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicy.java b/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicy.java index 8c0cc12..32e95df 100644 --- a/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicy.java +++ b/components/camel-etcd/src/main/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicy.java @@ -133,7 +133,7 @@ public class EtcdRoutePolicy extends RoutePolicySupport implements ResponsePromi LOGGER.info("Leadership taken (path={}, name={})", servicePath, serviceName); startAllStoppedConsumers(); } else { - if(!leader.getAndSet(isLeader) && isLeader) { + if (!leader.getAndSet(isLeader) && isLeader) { LOGGER.info("Leadership lost (path={}, name={})", servicePath, serviceName); } } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/EtcdStatsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/EtcdStatsTest.java b/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/EtcdStatsTest.java index 762be01..aba6045 100644 --- a/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/EtcdStatsTest.java +++ b/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/EtcdStatsTest.java @@ -23,7 +23,6 @@ import org.apache.camel.Exchange; import org.apache.camel.Predicate; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; -import org.junit.Ignore; import org.junit.Test; //@Ignore("Etcd must be started manually") @@ -32,12 +31,12 @@ public class EtcdStatsTest extends EtcdTest { @Test public void testStats() throws Exception { testStatsConsumer("mock:stats-leader-consumer", EtcdConstants.ETCD_LEADER_STATS_PATH, EtcdLeaderStatsResponse.class); - testStatsConsumer("mock:stats-self-consumer" , EtcdConstants.ETCD_SELF_STATS_PATH , EtcdSelfStatsResponse.class); - testStatsConsumer("mock:stats-store-consumer" , EtcdConstants.ETCD_STORE_STATS_PATH , EtcdStoreStatsResponse.class); + testStatsConsumer("mock:stats-self-consumer", EtcdConstants.ETCD_SELF_STATS_PATH, EtcdSelfStatsResponse.class); + testStatsConsumer("mock:stats-store-consumer", EtcdConstants.ETCD_STORE_STATS_PATH, EtcdStoreStatsResponse.class); testStatsProducer("direct:stats-leader", "mock:stats-leader-producer", EtcdConstants.ETCD_LEADER_STATS_PATH, EtcdLeaderStatsResponse.class); - testStatsProducer("direct:stats-self" , "mock:stats-self-producer" , EtcdConstants.ETCD_SELF_STATS_PATH , EtcdSelfStatsResponse.class); - testStatsProducer("direct:stats-store" , "mock:stats-store-producer" , EtcdConstants.ETCD_STORE_STATS_PATH , EtcdStoreStatsResponse.class); + testStatsProducer("direct:stats-self", "mock:stats-self-producer", EtcdConstants.ETCD_SELF_STATS_PATH, EtcdSelfStatsResponse.class); + testStatsProducer("direct:stats-store", "mock:stats-store-producer", EtcdConstants.ETCD_STORE_STATS_PATH, EtcdStoreStatsResponse.class); } protected void testStatsConsumer(String mockEnpoint, String expectedPath, final Class<?> expectedType) throws Exception { http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicyMain.java ---------------------------------------------------------------------- diff --git a/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicyMain.java b/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicyMain.java index 149f485..ad46647 100644 --- a/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicyMain.java +++ b/components/camel-etcd/src/test/java/org/apache/camel/component/etcd/policy/EtcdRoutePolicyMain.java @@ -19,7 +19,11 @@ package org.apache.camel.component.etcd.policy; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.main.Main; -public class EtcdRoutePolicyMain { +public final class EtcdRoutePolicyMain { + + private EtcdRoutePolicyMain() { + } + public static void main(final String[] args) throws Exception { Main main = new Main(); main.addRouteBuilder(new RouteBuilder() { http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java index 6508ee3..e630754 100644 --- a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java +++ b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/FacebookConsumer.java @@ -94,8 +94,7 @@ public class FacebookConsumer extends ScheduledPollConsumer { try { this.sinceTime = URLDecoder.decode(strSince, "UTF-8"); } catch (UnsupportedEncodingException e) { - throw new RuntimeCamelException(String.format("Error decoding %s.since with value %s due to: %s" - , READING_PREFIX, strSince, e.getMessage()), e); + throw new RuntimeCamelException(String.format("Error decoding %s.since with value %s due to: %s", READING_PREFIX, strSince, e.getMessage()), e); } LOG.debug("Using supplied property {}since value {}", READING_PREFIX, this.sinceTime); } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsType.java ---------------------------------------------------------------------- diff --git a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsType.java b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsType.java index d03adf1..b5c0975 100644 --- a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsType.java +++ b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsType.java @@ -70,7 +70,6 @@ import facebook4j.User; import facebook4j.Video; import facebook4j.VideoUpdate; import facebook4j.internal.org.json.JSONArray; - import org.apache.camel.component.facebook.FacebookConstants; /** @@ -98,8 +97,8 @@ public enum FacebookMethodsType { COMMENTALBUM_UPDATE(String.class, "commentAlbum", String.class, "albumId", CommentUpdate.class, "commentUpdate"), CREATEALBUM(String.class, "createAlbum", AlbumUpdate.class, "albumUpdate"), CREATEALBUM_WITH_ID(String.class, "createAlbum", String.class, "userId", AlbumUpdate.class, "albumUpdate"), - GETALBUM(Album.class, "getAlbum", String.class, "albumId"), - GETALBUM_WITH_OPTIONS(Album.class, "getAlbum", String.class, "albumId", Reading.class, FacebookConstants.READING_PROPERTY), + GETALBUM(Album.class, "getAlbum", String.class, "albumId"), + GETALBUM_WITH_OPTIONS(Album.class, "getAlbum", String.class, "albumId", Reading.class, FacebookConstants.READING_PROPERTY), GETALBUMCOMMENTS(ResponseList.class, "getAlbumComments", String.class, "albumId"), GETALBUMCOMMENTS_WITH_OPTIONS(ResponseList.class, "getAlbumComments", String.class, "albumId", Reading.class, FacebookConstants.READING_PROPERTY), GETALBUMCOVERPHOTO(URL.class, "getAlbumCoverPhoto", String.class, "albumId"), @@ -150,15 +149,15 @@ public enum FacebookMethodsType { // EventMethods CREATEEVENT(String.class, "createEvent", EventUpdate.class, "eventUpdate"), CREATEEVENT_WITH_ID(String.class, "createEvent", String.class, "userId", EventUpdate.class, "eventUpdate"), - DELETEEVENT(Boolean.class, "deleteEvent", String.class, "eventId"), - DELETEEVENTPICTURE(Boolean.class, "deleteEventPicture", String.class, "eventId"), - EDITEVENT(Boolean.class, "editEvent", String.class, "eventId", EventUpdate.class, "eventUpdate"), - GETEVENT(Event.class, "getEvent", String.class, "eventId"), - GETEVENT_WITH_OPTIONS(Event.class, "getEvent", String.class, "eventId", Reading.class, FacebookConstants.READING_PROPERTY), + DELETEEVENT(Boolean.class, "deleteEvent", String.class, "eventId"), + DELETEEVENTPICTURE(Boolean.class, "deleteEventPicture", String.class, "eventId"), + EDITEVENT(Boolean.class, "editEvent", String.class, "eventId", EventUpdate.class, "eventUpdate"), + GETEVENT(Event.class, "getEvent", String.class, "eventId"), + GETEVENT_WITH_OPTIONS(Event.class, "getEvent", String.class, "eventId", Reading.class, FacebookConstants.READING_PROPERTY), GETEVENTPHOTOS(ResponseList.class, "getEventPhotos", String.class, "eventId"), GETEVENTPHOTOS_WITH_OPTIONS(ResponseList.class, "getEventPhotos", String.class, "eventId", Reading.class, FacebookConstants.READING_PROPERTY), - GETEVENTPICTUREURL(URL.class, "getEventPictureURL", String.class, "eventId"), - GETEVENTPICTUREURL_WITH_PICTURESIZE(URL.class, "getEventPictureURL", String.class, "eventId", PictureSize.class, "size"), + GETEVENTPICTUREURL(URL.class, "getEventPictureURL", String.class, "eventId"), + GETEVENTPICTUREURL_WITH_PICTURESIZE(URL.class, "getEventPictureURL", String.class, "eventId", PictureSize.class, "size"), GETEVENTS(ResponseList.class, "getEvents"), GETEVENTS_WITH_OPTIONS(ResponseList.class, "getEvents", Reading.class, FacebookConstants.READING_PROPERTY), GETEVENTS_WITH_ID(ResponseList.class, "getEvents", String.class, "userId"), @@ -175,20 +174,20 @@ public enum FacebookMethodsType { GETRSVPSTATUSINDECLINED_WITH_ID(ResponseList.class, "getRSVPStatusInDeclined", String.class, "eventId", String.class, "userId"), GETRSVPSTATUSINMAYBE(ResponseList.class, "getRSVPStatusInMaybe", String.class, "eventId"), GETRSVPSTATUSINMAYBE_WITH_ID(ResponseList.class, "getRSVPStatusInMaybe", String.class, "eventId", String.class, "userId"), - INVITETOEVENT(Boolean.class, "inviteToEvent", String.class, "eventId", String.class, "userId"), - INVITETOEVENT_WITH_IDS(Boolean.class, "inviteToEvent", String.class, "eventId", new String[0].getClass(), "userIds"), - POSTEVENTLINK_WITH_LINK(String.class, "postEventLink", String.class, "eventId", URL.class , "link"), - POSTEVENTLINK_WITH_LINK_MSG(String.class, "postEventLink", String.class, "eventId", URL.class , "link", String.class, "message"), + INVITETOEVENT(Boolean.class, "inviteToEvent", String.class, "eventId", String.class, "userId"), + INVITETOEVENT_WITH_IDS(Boolean.class, "inviteToEvent", String.class, "eventId", new String[0].getClass(), "userIds"), + POSTEVENTLINK_WITH_LINK(String.class, "postEventLink", String.class, "eventId", URL.class, "link"), + POSTEVENTLINK_WITH_LINK_MSG(String.class, "postEventLink", String.class, "eventId", URL.class, "link", String.class, "message"), POSTEVENTPHOTO_WITH_MEDIA(String.class, "postEventPhoto", String.class, "eventId", Media.class, "source"), POSTEVENTPHOTO_WITH_MEDIA_MSG(String.class, "postEventPhoto", String.class, "eventId", Media.class, "source", String.class, "message"), POSTEVENTSTATUSMESSAGE_WITH_MSG(String.class, "postEventStatusMessage", String.class, "eventId", String.class, "message"), POSTEVENTVIDEO_WITH_MEDIA(String.class, "postEventVideo", String.class, "eventId", Media.class, "source"), POSTEVENTVIDEO_WITH_MEDIA_TITLE_DESC(String.class, "postEventVideo", String.class, "eventId", Media.class, "source", String.class, "title", String.class, "description"), - RSVPEVENTASATTENDING(Boolean.class, "rsvpEventAsAttending", String.class, "eventId"), - RSVPEVENTASDECLINED(Boolean.class, "rsvpEventAsDeclined", String.class, "eventId"), - RSVPEVENTASMAYBE(Boolean.class, "rsvpEventAsMaybe", String.class, "eventId"), - UNINVITEFROMEVENT(Boolean.class, "uninviteFromEvent", String.class, "eventId", String.class, "userId"), - UPDATEEVENTPICTURE(Boolean.class, "updateEventPicture", String.class, "eventId", Media.class, "source"), + RSVPEVENTASATTENDING(Boolean.class, "rsvpEventAsAttending", String.class, "eventId"), + RSVPEVENTASDECLINED(Boolean.class, "rsvpEventAsDeclined", String.class, "eventId"), + RSVPEVENTASMAYBE(Boolean.class, "rsvpEventAsMaybe", String.class, "eventId"), + UNINVITEFROMEVENT(Boolean.class, "uninviteFromEvent", String.class, "eventId", String.class, "userId"), + UPDATEEVENTPICTURE(Boolean.class, "updateEventPicture", String.class, "eventId", Media.class, "source"), // FamilyMethods GETFAMILY(ResponseList.class, "getFamily"), @@ -208,7 +207,7 @@ public enum FacebookMethodsType { GETINTERESTS(ResponseList.class, "getInterests"), GETINTERESTS_WITH_ID(ResponseList.class, "getInterests", String.class, "userId"), GETINTERESTS_WITH_OPTIONS(ResponseList.class, "getInterests", Reading.class, FacebookConstants.READING_PROPERTY), - GETINTERESTS_WITH_ID_OPTIONS(ResponseList.class, "getInterests", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), + GETINTERESTS_WITH_ID_OPTIONS(ResponseList.class, "getInterests", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), GETMOVIES(ResponseList.class, "getMovies"), GETMOVIES_WITH_OPTIONS(ResponseList.class, "getMovies", Reading.class, FacebookConstants.READING_PROPERTY), GETMOVIES_WITH_ID(ResponseList.class, "getMovies", String.class, "userId"), @@ -265,7 +264,7 @@ public enum FacebookMethodsType { // GameMethods DELETEACHIEVEMENT(Boolean.class, "deleteAchievement", URL.class, "achievementURL"), - DELETEACHIEVEMENT_WITH_ID(Boolean.class, "deleteAchievement", String.class, "userId", URL.class , "achievementURL"), + DELETEACHIEVEMENT_WITH_ID(Boolean.class, "deleteAchievement", String.class, "userId", URL.class, "achievementURL"), DELETESCORE(Boolean.class, "deleteScore"), DELETESCORE_WITH_ID(Boolean.class, "deleteScore", String.class, "userId"), GETACHIEVEMENTS(ResponseList.class, "getAchievements"), @@ -279,18 +278,18 @@ public enum FacebookMethodsType { POSTACHIEVEMENT(String.class, "postAchievement", URL.class, "achievementURL"), POSTACHIEVEMENT_WITH_ID(String.class, "postAchievement", String.class, "userId", URL.class, "achievementURL"), POSTSCORE(Boolean.class, "postScore", int.class, "scoreValue"), - POSTSCORE_WITH_ID(Boolean.class, "postScore", String.class, "userId", int.class, "scoreValue"), + POSTSCORE_WITH_ID(Boolean.class, "postScore", String.class, "userId", int.class, "scoreValue"), // GroupMethods - GETGROUP(Group.class, "getGroup", String.class, "groupId"), - GETGROUP_WITH_OPTIONS(Group.class, "getGroup", String.class, "groupId", Reading.class, FacebookConstants.READING_PROPERTY), + GETGROUP(Group.class, "getGroup", String.class, "groupId"), + GETGROUP_WITH_OPTIONS(Group.class, "getGroup", String.class, "groupId", Reading.class, FacebookConstants.READING_PROPERTY), GETGROUPDOCS(ResponseList.class, "getGroupDocs", String.class, "groupId"), GETGROUPDOCS_WITH_OPTIONS(ResponseList.class, "getGroupDocs", String.class, "groupId", Reading.class, FacebookConstants.READING_PROPERTY), GETGROUPFEED(ResponseList.class, "getGroupFeed", String.class, "groupId"), GETGROUPFEED_WITH_OPTIONS(ResponseList.class, "getGroupFeed", String.class, "groupId", Reading.class, FacebookConstants.READING_PROPERTY), GETGROUPMEMBERS(ResponseList.class, "getGroupMembers", String.class, "groupId"), GETGROUPMEMBERS_WITH_OPTIONS(ResponseList.class, "getGroupMembers", String.class, "groupId", Reading.class, FacebookConstants.READING_PROPERTY), - GETGROUPPICTUREURL(URL.class, "getGroupPictureURL", String.class, "groupId"), + GETGROUPPICTUREURL(URL.class, "getGroupPictureURL", String.class, "groupId"), GETGROUPS(ResponseList.class, "getGroups"), GETGROUPS_WITH_OPTIONS(ResponseList.class, "getGroups", Reading.class, FacebookConstants.READING_PROPERTY), GETGROUPS_WITH_ID(ResponseList.class, "getGroups", String.class, "userId"), @@ -313,14 +312,14 @@ public enum FacebookMethodsType { // LinkMethods COMMENTLINK(String.class, "commentLink", String.class, "linkId", String.class, "message"), COMMENTLINK_UPDATE(String.class, "commentLink", String.class, "linkId", CommentUpdate.class, "commentUpdate"), - GETLINK(Link.class, "getLink", String.class, "linkId"), - GETLINK_WITH_OPTIONS(Link.class, "getLink", String.class, "linkId", Reading.class, FacebookConstants.READING_PROPERTY), + GETLINK(Link.class, "getLink", String.class, "linkId"), + GETLINK_WITH_OPTIONS(Link.class, "getLink", String.class, "linkId", Reading.class, FacebookConstants.READING_PROPERTY), GETLINKCOMMENTS(ResponseList.class, "getLinkComments", String.class, "linkId"), GETLINKCOMMENTS_WITH_OPTIONS(ResponseList.class, "getLinkComments", String.class, "linkId", Reading.class, FacebookConstants.READING_PROPERTY), GETLINKLIKES(ResponseList.class, "getLinkLikes", String.class, "linkId"), GETLINKLIKES_WITH_OPTIONS(ResponseList.class, "getLinkLikes", String.class, "linkId", Reading.class, FacebookConstants.READING_PROPERTY), - LIKELINK(Boolean.class, "likeLink", String.class, "linkId"), - UNLIKELINK(Boolean.class, "unlikeLink", String.class, "linkId"), + LIKELINK(Boolean.class, "likeLink", String.class, "linkId"), + UNLIKELINK(Boolean.class, "unlikeLink", String.class, "linkId"), // LocationMethods GETLOCATIONS(ResponseList.class, "getLocations"), @@ -337,8 +336,8 @@ public enum FacebookMethodsType { GETINBOX_WITH_OPTIONS(InboxResponseList.class, "getInbox", Reading.class, FacebookConstants.READING_PROPERTY), GETINBOX_WITH_ID(InboxResponseList.class, "getInbox", String.class, "userId"), GETINBOX_WITH_ID_OPTIONS(InboxResponseList.class, "getInbox", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), - GETMESSAGE(Message.class, "getMessage", String.class, "messageId"), - GETMESSAGE_WITH_OPTIONS(Message.class, "getMessage", String.class, "messageId", Reading.class, FacebookConstants.READING_PROPERTY), + GETMESSAGE(Message.class, "getMessage", String.class, "messageId"), + GETMESSAGE_WITH_OPTIONS(Message.class, "getMessage", String.class, "messageId", Reading.class, FacebookConstants.READING_PROPERTY), GETOUTBOX(ResponseList.class, "getOutbox"), GETOUTBOX_WITH_OPTIONS(ResponseList.class, "getOutbox", Reading.class, FacebookConstants.READING_PROPERTY), GETOUTBOX_WITH_ID(ResponseList.class, "getOutbox", String.class, "userId"), @@ -352,8 +351,8 @@ public enum FacebookMethodsType { COMMENTNOTE(String.class, "commentNote", String.class, "noteId", String.class, "message"), CREATENOTE(String.class, "createNote", String.class, "subject", String.class, "message"), CREATENOTE_WITH_ID_MSG(String.class, "createNote", String.class, "userId", String.class, "subject", String.class, "message"), - GETNOTE(Note.class, "getNote", String.class, "noteId"), - GETNOTE_WITH_OPTIONS(Note.class, "getNote", String.class, "noteId", Reading.class, FacebookConstants.READING_PROPERTY), + GETNOTE(Note.class, "getNote", String.class, "noteId"), + GETNOTE_WITH_OPTIONS(Note.class, "getNote", String.class, "noteId", Reading.class, FacebookConstants.READING_PROPERTY), GETNOTECOMMENTS(ResponseList.class, "getNoteComments", String.class, "noteId"), GETNOTECOMMENTS_WITH_OPTIONS(ResponseList.class, "getNoteComments", String.class, "noteId", Reading.class, FacebookConstants.READING_PROPERTY), GETNOTELIKES(ResponseList.class, "getNoteLikes", String.class, "noteId"), @@ -362,8 +361,8 @@ public enum FacebookMethodsType { GETNOTES_WITH_OPTIONS(ResponseList.class, "getNotes", Reading.class, FacebookConstants.READING_PROPERTY), GETNOTES_WITH_ID(ResponseList.class, "getNotes", String.class, "userId"), GETNOTES_WITH_ID_OPTIONS(ResponseList.class, "getNotes", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), - LIKENOTE(Boolean.class, "likeNote", String.class, "noteId"), - UNLIKENOTE(Boolean.class, "unlikeNote", String.class, "noteId"), + LIKENOTE(Boolean.class, "likeNote", String.class, "noteId"), + UNLIKENOTE(Boolean.class, "unlikeNote", String.class, "noteId"), // NotificationMethods GETNOTIFICATIONS(ResponseList.class, "getNotifications"), @@ -374,27 +373,27 @@ public enum FacebookMethodsType { GETNOTIFICATIONS_WITH_ID_INCLUDEREAD(ResponseList.class, "getNotifications", String.class, "userId", boolean.class, "includeRead"), GETNOTIFICATIONS_WITH_ID_OPTIONS(ResponseList.class, "getNotifications", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), GETNOTIFICATIONS_WITH_ID_OPTIONS_INCLUDEREAD(ResponseList.class, "getNotifications", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY, boolean.class, "includeRead"), - MARKNOTIFICATIONASREAD(Boolean.class, "markNotificationAsRead", String.class, "notificationId"), + MARKNOTIFICATIONASREAD(Boolean.class, "markNotificationAsRead", String.class, "notificationId"), // PermissionMethods - DELETEALLPERMISSIONS(Boolean.class, "deleteAllPermissions"), - DELETEALLPERMISSIONS_WITH_ID(Boolean.class, "deleteAllPermissions", String.class, "userId"), + DELETEALLPERMISSIONS(Boolean.class, "deleteAllPermissions"), + DELETEALLPERMISSIONS_WITH_ID(Boolean.class, "deleteAllPermissions", String.class, "userId"), GETPERMISSIONS(List.class, "getPermissions"), GETPERMISSIONS_WITH_ID(List.class, "getPermissions", String.class, "userId"), - REVOKEPERMISSION(Boolean.class, "revokePermission", String.class, "permissionName"), - REVOKEPERMISSION_WITH_ID(Boolean.class, "revokePermission", String.class, "userId", String.class, "permissionName"), - REVOKEALLPERMISSIONS(Boolean.class, "revokeAllPermissions"), - REVOKEALLPERMISSIONS_WITH_ID(Boolean.class, "revokeAllPermissions", String.class, "userId"), + REVOKEPERMISSION(Boolean.class, "revokePermission", String.class, "permissionName"), + REVOKEPERMISSION_WITH_ID(Boolean.class, "revokePermission", String.class, "userId", String.class, "permissionName"), + REVOKEALLPERMISSIONS(Boolean.class, "revokeAllPermissions"), + REVOKEALLPERMISSIONS_WITH_ID(Boolean.class, "revokeAllPermissions", String.class, "userId"), // PhotoMethods - ADDTAGTOPHOTO(Boolean.class, "addTagToPhoto", String.class, "photoId", String.class, "toUserId"), - ADDTAGTOPHOTO_WITH_IDS(Boolean.class, "addTagToPhoto", String.class, "photoId", List.class, "toUserIds"), - ADDTAGTOPHOTO_WITH_TAGUPDATE(Boolean.class, "addTagToPhoto", String.class, "photoId", TagUpdate.class, "tagUpdate"), + ADDTAGTOPHOTO(Boolean.class, "addTagToPhoto", String.class, "photoId", String.class, "toUserId"), + ADDTAGTOPHOTO_WITH_IDS(Boolean.class, "addTagToPhoto", String.class, "photoId", List.class, "toUserIds"), + ADDTAGTOPHOTO_WITH_TAGUPDATE(Boolean.class, "addTagToPhoto", String.class, "photoId", TagUpdate.class, "tagUpdate"), COMMENTPHOTO(String.class, "commentPhoto", String.class, "photoId", String.class, "message"), COMMENTPHOTO_UPDATE(String.class, "commentPhoto", String.class, "photoId", CommentUpdate.class, "commentUpdate"), - DELETEPHOTO(Boolean.class, "deletePhoto", String.class, "photoId"), - GETPHOTO(Photo.class, "getPhoto", String.class, "photoId"), - GETPHOTO_WITH_OPTIONS(Photo.class, "getPhoto", String.class, "photoId", Reading.class, FacebookConstants.READING_PROPERTY), + DELETEPHOTO(Boolean.class, "deletePhoto", String.class, "photoId"), + GETPHOTO(Photo.class, "getPhoto", String.class, "photoId"), + GETPHOTO_WITH_OPTIONS(Photo.class, "getPhoto", String.class, "photoId", Reading.class, FacebookConstants.READING_PROPERTY), GETPHOTOCOMMENTS(ResponseList.class, "getPhotoComments", String.class, "photoId"), GETPHOTOCOMMENTS_WITH_OPTIONS(ResponseList.class, "getPhotoComments", String.class, "photoId", Reading.class, FacebookConstants.READING_PROPERTY), GETPHOTOLIKES(ResponseList.class, "getPhotoLikes", String.class, "photoId"), @@ -403,14 +402,14 @@ public enum FacebookMethodsType { GETPHOTOS_WITH_OPTIONS(ResponseList.class, "getPhotos", Reading.class, FacebookConstants.READING_PROPERTY), GETPHOTOS_WITH_ID(ResponseList.class, "getPhotos", String.class, "userId"), GETPHOTOS_WITH_ID_OPTIONS(ResponseList.class, "getPhotos", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), - GETPHOTOURL(URL.class, "getPhotoURL", String.class, "photoId"), + GETPHOTOURL(URL.class, "getPhotoURL", String.class, "photoId"), GETTAGSONPHOTO(ResponseList.class, "getTagsOnPhoto", String.class, "photoId"), GETTAGSONPHOTO_WITH_OPTIONS(ResponseList.class, "getTagsOnPhoto", String.class, "photoId", Reading.class, FacebookConstants.READING_PROPERTY), - LIKEPHOTO(Boolean.class, "likePhoto", String.class, "photoId"), + LIKEPHOTO(Boolean.class, "likePhoto", String.class, "photoId"), POSTPHOTO(String.class, "postPhoto", Media.class, "source"), POSTPHOTO_WITH_MEDIA(String.class, "postPhoto", String.class, "userId", Media.class, "source"), - UNLIKEPHOTO(Boolean.class, "unlikePhoto", String.class, "photoId"), - UPDATETAGONPHOTO_WITH_TAGUPDATE(Boolean.class, "updateTagOnPhoto", String.class, "photoId", TagUpdate.class, "tagUpdate"), + UNLIKEPHOTO(Boolean.class, "unlikePhoto", String.class, "photoId"), + UPDATETAGONPHOTO_WITH_TAGUPDATE(Boolean.class, "updateTagOnPhoto", String.class, "photoId", TagUpdate.class, "tagUpdate"), // PokeMethods GETPOKES(ResponseList.class, "getPokes"), @@ -421,7 +420,7 @@ public enum FacebookMethodsType { // PostMethods COMMENTPOST(String.class, "commentPost", String.class, "postId", String.class, "message"), COMMENTPOST_UPDATE(String.class, "commentPost", String.class, "postId", CommentUpdate.class, "commentUpdate"), - DELETEPOST(Boolean.class, "deletePost", String.class, "postId"), + DELETEPOST(Boolean.class, "deletePost", String.class, "postId"), GETFEED(ResponseList.class, "getFeed"), GETFEED_WITH_OPTIONS(ResponseList.class, "getFeed", Reading.class, FacebookConstants.READING_PROPERTY), GETFEED_WITH_ID(ResponseList.class, "getFeed", String.class, "userId"), @@ -432,8 +431,8 @@ public enum FacebookMethodsType { GETLINKS_WITH_OPTIONS(ResponseList.class, "getLinks", Reading.class, FacebookConstants.READING_PROPERTY), GETLINKS_WITH_ID(ResponseList.class, "getLinks", String.class, "userId"), GETLINKS_WITH_ID_OPTIONS(ResponseList.class, "getLinks", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), - GETPOST(Post.class, "getPost", String.class, "postId"), - GETPOST_WITH_OPTIONS(Post.class, "getPost", String.class, "postId", Reading.class, FacebookConstants.READING_PROPERTY), + GETPOST(Post.class, "getPost", String.class, "postId"), + GETPOST_WITH_OPTIONS(Post.class, "getPost", String.class, "postId", Reading.class, FacebookConstants.READING_PROPERTY), GETPOSTCOMMENTS(ResponseList.class, "getPostComments", String.class, "postId"), GETPOSTCOMMENTS_WITH_OPTIONS(ResponseList.class, "getPostComments", String.class, "postId", Reading.class, FacebookConstants.READING_PROPERTY), GETPOSTLIKES(ResponseList.class, "getPostLikes", String.class, "postId"), @@ -450,7 +449,7 @@ public enum FacebookMethodsType { GETTAGGED_WITH_OPTIONS(ResponseList.class, "getTagged", Reading.class, FacebookConstants.READING_PROPERTY), GETTAGGED_WITH_ID(ResponseList.class, "getTagged", String.class, "userId"), GETTAGGED_WITH_ID_OPTIONS(ResponseList.class, "getTagged", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), - LIKEPOST(Boolean.class, "likePost", String.class, "postId"), + LIKEPOST(Boolean.class, "likePost", String.class, "postId"), POSTFEED(String.class, "postFeed", PostUpdate.class, "postUpdate"), POSTFEED_WITH_POSTUPDATE(String.class, "postFeed", String.class, "userId", PostUpdate.class, "postUpdate"), POSTLINK(String.class, "postLink", URL.class, "link"), @@ -459,13 +458,13 @@ public enum FacebookMethodsType { POSTLINK_WITH_ID_MSG(String.class, "postLink", String.class, "userId", URL.class, "link", String.class, "message"), POSTSTATUSMESSAGE(String.class, "postStatusMessage", String.class, "message"), POSTSTATUSMESSAGE_WITH_ID(String.class, "postStatusMessage", String.class, "userId", String.class, "message"), - UNLIKEPOST(Boolean.class, "unlikePost", String.class, "postId"), + UNLIKEPOST(Boolean.class, "unlikePost", String.class, "postId"), // QuestionMethods ADDQUESTIONOPTION(String.class, "addQuestionOption", String.class, "questionId", String.class, "optionDescription"), - DELETEQUESTION(Boolean.class, "deleteQuestion", String.class, "questionId"), - GETQUESTION(Question.class, "getQuestion", String.class, "questionId"), - GETQUESTION_WITH_OPTIONS(Question.class, "getQuestion", String.class, "questionId", Reading.class, FacebookConstants.READING_PROPERTY), + DELETEQUESTION(Boolean.class, "deleteQuestion", String.class, "questionId"), + GETQUESTION(Question.class, "getQuestion", String.class, "questionId"), + GETQUESTION_WITH_OPTIONS(Question.class, "getQuestion", String.class, "questionId", Reading.class, FacebookConstants.READING_PROPERTY), GETQUESTIONOPTIONS(ResponseList.class, "getQuestionOptions", String.class, "questionId"), GETQUESTIONOPTIONS_WITH_OPTIONS(ResponseList.class, "getQuestionOptions", String.class, "questionId", Reading.class, FacebookConstants.READING_PROPERTY), GETQUESTIONOPTIONVOTES(ResponseList.class, "getQuestionOptionVotes", String.class, "questionId"), @@ -485,45 +484,45 @@ public enum FacebookMethodsType { GETSUBSCRIBERS_WITH_ID_OPTIONS(ResponseList.class, "getSubscribers", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), // TestUserMethods - CREATETESTUSER(TestUser.class, "createTestUser", String.class, "appId"), - CREATETESTUSER_WITH_NAME(TestUser.class, "createTestUser", String.class, "appId", String.class, "name", String.class, "userLocale", String.class, "permissions"), - DELETETESTUSER(Boolean.class, "deleteTestUser", String.class, "testUserId"), + CREATETESTUSER(TestUser.class, "createTestUser", String.class, "appId"), + CREATETESTUSER_WITH_NAME(TestUser.class, "createTestUser", String.class, "appId", String.class, "name", String.class, "userLocale", String.class, "permissions"), + DELETETESTUSER(Boolean.class, "deleteTestUser", String.class, "testUserId"), GETTESTUSERS(List.class, "getTestUsers", String.class, "appId"), - MAKEFRIENDTESTUSER(Boolean.class, "makeFriendTestUser", TestUser.class, "testUser1", TestUser.class, "testUser2"), + MAKEFRIENDTESTUSER(Boolean.class, "makeFriendTestUser", TestUser.class, "testUser1", TestUser.class, "testUser2"), // UserMethods - GETME(User.class, "getMe"), - GETME_WITH_OPTIONS(User.class, "getMe", Reading.class, FacebookConstants.READING_PROPERTY), - GETPICTUREURL(URL.class, "getPictureURL"), - GETPICTUREURL_WITH_DIM(URL.class, "getPictureURL", int.class, "pictureId", int.class, "pictureId2"), - GETPICTUREURL_WITH_PICTURESIZE(URL.class, "getPictureURL", PictureSize.class, "size"), - GETPICTUREURL_WITH_ID(URL.class, "getPictureURL", String.class, "userId"), - GETPICTUREURL_WITH_ID_PICTURESIZE(URL.class, "getPictureURL", String.class, "userId", PictureSize.class, "size"), - GETPICTUREURL_WITH_ID_AND_DIM(URL.class, "getPictureURL", String.class, "userId", int.class, "pictureId", int.class, "pictureId2"), - GETSSLPICTUREURL(URL.class, "getSSLPictureURL"), - GETSSLPICTUREURL_WITH_PICTURESIZE(URL.class, "getSSLPictureURL", PictureSize.class, "size"), - GETSSLPICTUREURL_WITH_ID(URL.class, "getSSLPictureURL", String.class, "userId"), - GETSSLPICTUREURL_WITH_ID_SIZE(URL.class, "getSSLPictureURL", String.class, "userId", PictureSize.class, "size"), - GETUSER(User.class, "getUser", String.class, "userId"), - GETUSER_WITH_OPTIONS(User.class, "getUser", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), + GETME(User.class, "getMe"), + GETME_WITH_OPTIONS(User.class, "getMe", Reading.class, FacebookConstants.READING_PROPERTY), + GETPICTUREURL(URL.class, "getPictureURL"), + GETPICTUREURL_WITH_DIM(URL.class, "getPictureURL", int.class, "pictureId", int.class, "pictureId2"), + GETPICTUREURL_WITH_PICTURESIZE(URL.class, "getPictureURL", PictureSize.class, "size"), + GETPICTUREURL_WITH_ID(URL.class, "getPictureURL", String.class, "userId"), + GETPICTUREURL_WITH_ID_PICTURESIZE(URL.class, "getPictureURL", String.class, "userId", PictureSize.class, "size"), + GETPICTUREURL_WITH_ID_AND_DIM(URL.class, "getPictureURL", String.class, "userId", int.class, "pictureId", int.class, "pictureId2"), + GETSSLPICTUREURL(URL.class, "getSSLPictureURL"), + GETSSLPICTUREURL_WITH_PICTURESIZE(URL.class, "getSSLPictureURL", PictureSize.class, "size"), + GETSSLPICTUREURL_WITH_ID(URL.class, "getSSLPictureURL", String.class, "userId"), + GETSSLPICTUREURL_WITH_ID_SIZE(URL.class, "getSSLPictureURL", String.class, "userId", PictureSize.class, "size"), + GETUSER(User.class, "getUser", String.class, "userId"), + GETUSER_WITH_OPTIONS(User.class, "getUser", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), GETUSERS(List.class, "getUsers", new String[0].getClass(), "ids"), // VideoMethods COMMENTVIDEO(String.class, "commentVideo", String.class, "videoId", String.class, "message"), COMMENTVIDEO_UPDATE(String.class, "commentVideo", String.class, "videoId", CommentUpdate.class, "commentUpdate"), - GETVIDEO(Video.class, "getVideo", String.class, "videoId"), - GETVIDEO_WITH_OPTIONS(Video.class, "getVideo", String.class, "videoId", Reading.class, FacebookConstants.READING_PROPERTY), + GETVIDEO(Video.class, "getVideo", String.class, "videoId"), + GETVIDEO_WITH_OPTIONS(Video.class, "getVideo", String.class, "videoId", Reading.class, FacebookConstants.READING_PROPERTY), GETVIDEOCOMMENTS(ResponseList.class, "getVideoComments", String.class, "videoId"), GETVIDEOCOMMENTS_WITH_OPTIONS(ResponseList.class, "getVideoComments", String.class, "videoId", Reading.class, FacebookConstants.READING_PROPERTY), - GETVIDEOCOVER(URL.class, "getVideoCover", String.class, "videoId"), + GETVIDEOCOVER(URL.class, "getVideoCover", String.class, "videoId"), GETVIDEOLIKES(ResponseList.class, "getVideoLikes", String.class, "videoId"), GETVIDEOLIKES_WITH_OPTIONS(ResponseList.class, "getVideoLikes", String.class, "videoId", Reading.class, FacebookConstants.READING_PROPERTY), GETVIDEOS(ResponseList.class, "getVideos"), GETVIDEOS_WITH_OPTIONS(ResponseList.class, "getVideos", Reading.class, FacebookConstants.READING_PROPERTY), GETVIDEOS_WITH_ID(ResponseList.class, "getVideos", String.class, "userId"), GETVIDEOS_WITH_ID_OPTIONS(ResponseList.class, "getVideos", String.class, "userId", Reading.class, FacebookConstants.READING_PROPERTY), - LIKEVIDEO(Boolean.class, "likeVideo", String.class, "videoId"), - UNLIKEVIDEO(Boolean.class, "unlikeVideo", String.class, "videoId"), + LIKEVIDEO(Boolean.class, "likeVideo", String.class, "videoId"), + UNLIKEVIDEO(Boolean.class, "unlikeVideo", String.class, "videoId"), // SearchMethods get the highest priority with higher ordinal values SEARCH(ResponseList.class, "search", String.class, "query"), @@ -552,12 +551,12 @@ public enum FacebookMethodsType { BLOCK_USERLIST_WITH_PAGEID(Map.class, "block", String.class, "pageId", List.class, "list"), GET_PROMOTABLE_POSTS(ResponseList.class, "getPromotablePosts"), GET_PROMOTABLE_POSTS_WITH_PAGEID(ResponseList.class, "getPromotablePosts", String.class, "pageId"), - GET_PROMOTABLE_POSTS_WITH_READING(ResponseList.class, "getPromotablePosts", Reading.class , FacebookConstants.READING_PROPERTY), - GET_PROMOTABLE_POSTS_WITH_PAGEID_AND_READING(ResponseList.class, "getPromotablePosts", String.class, "pageId", Reading.class , FacebookConstants.READING_PROPERTY), - POST_PAGE_PHOTO(String.class, "postPagePhoto", PagePhotoUpdate.class , "pagePhotoUpdate"), - POST_PAGE_PHOTO_WITH_PAGEID(String.class, "postPagePhoto", String.class, "pageId", PagePhotoUpdate.class , "pagePhotoUpdate"), + GET_PROMOTABLE_POSTS_WITH_READING(ResponseList.class, "getPromotablePosts", Reading.class, FacebookConstants.READING_PROPERTY), + GET_PROMOTABLE_POSTS_WITH_PAGEID_AND_READING(ResponseList.class, "getPromotablePosts", String.class, "pageId", Reading.class, FacebookConstants.READING_PROPERTY), + POST_PAGE_PHOTO(String.class, "postPagePhoto", PagePhotoUpdate.class, "pagePhotoUpdate"), + POST_PAGE_PHOTO_WITH_PAGEID(String.class, "postPagePhoto", String.class, "pageId", PagePhotoUpdate.class, "pagePhotoUpdate"), GET_PAGE_TAGGED(ResponseList.class, "getPageTagged", String.class, "pageId"), - GET_PAGE_TAGGED_WITH_READING(ResponseList.class, "getPageTagged", String.class, "pageId", Reading.class , FacebookConstants.READING_PROPERTY), + GET_PAGE_TAGGED_WITH_READING(ResponseList.class, "getPageTagged", String.class, "pageId", Reading.class, FacebookConstants.READING_PROPERTY), GET_PAGE(Page.class, "getPage"), GET_PAGE_WITH_ID(Page.class, "getPage", String.class, "pageId"), GET_PAGE_WITH_READING(Page.class, "getPage", Reading.class, FacebookConstants.READING_PROPERTY), @@ -601,8 +600,8 @@ public enum FacebookMethodsType { GET_TABS_WITH_READING(ResponseList.class, "getTabs", Reading.class, FacebookConstants.READING_PROPERTY), GET_TABS_WITH_PAGEID_AND_READING(ResponseList.class, "getTabs", String.class, "pageId", Reading.class, FacebookConstants.READING_PROPERTY), GET_INSTALLED_TABS(ResponseList.class, "getInstalledTabs", List.class, "appIds"), - GET_INSTALLED_TABS_WITH_PAGEID(ResponseList.class, "getInstalledTabs", String.class, "pageId", List.class, "appIds"), - GET_INSTALLED_TABS_WITH_READING(ResponseList.class, "getInstalledTabs", List.class, "appIds", Reading.class, FacebookConstants.READING_PROPERTY), + GET_INSTALLED_TABS_WITH_PAGEID(ResponseList.class, "getInstalledTabs", String.class, "pageId", List.class, "appIds"), + GET_INSTALLED_TABS_WITH_READING(ResponseList.class, "getInstalledTabs", List.class, "appIds", Reading.class, FacebookConstants.READING_PROPERTY), GET_INSTALLED_TABS_WITH_PAGEID_AND_READING(ResponseList.class, "getInstalledTabs", String.class, "pageId", List.class, "appIds", Reading.class, FacebookConstants.READING_PROPERTY), INSTALL_TAB(boolean.class, "installTab", String.class, "appId"), INSTALL_TAB_WITH_PAGEID(boolean.class, "installTab", String.class, "pageId", String.class, "appId"), @@ -643,7 +642,7 @@ public enum FacebookMethodsType { POST_VIDEO_WITH_ID(String.class, "postVideo", String.class, "id", VideoUpdate.class, "videoUpdate"), SEARCH_PAGES(ResponseList.class, "searchPages", String.class, "query"), SEARCH_PAGES_WITH_READING(ResponseList.class, "searchPages", String.class, "query", Reading.class, FacebookConstants.READING_PROPERTY), - CREATETESTUSER_WITH_INSTALLED(TestUser.class, "createTestUser", String.class, "appId", String.class, "name", String.class, "userLocale", String.class, "permissions", boolean.class, "installed"), + CREATETESTUSER_WITH_INSTALLED(TestUser.class, "createTestUser", String.class, "appId", String.class, "name", String.class, "userLocale", String.class, "permissions", boolean.class, "installed"), GETTESTUSERS_WITH_LIMIT(ResponseList.class, "getTestUsers", String.class, "appId", Integer.class, "limit"), EXECUTE_BATCH(List.class, "executeBatch", BatchRequests.class, "requests"), CALL_POST_API(RawAPIResponse.class, "callPostAPI", String.class, "relativeUrl"), @@ -654,7 +653,7 @@ public enum FacebookMethodsType { CALL_GET_API_WITH_MAP(RawAPIResponse.class, "callGetAPI", String.class, "relativeUrl", Map.class, "parameters"), CALL_DELETE_API(RawAPIResponse.class, "callDeleteAPI", String.class, "relativeUrl"), CALL_DELETE_API_WITH_MAP(RawAPIResponse.class, "callDeleteAPI", String.class, "relativeUrl", Map.class, "parameters"); - + // name, result class, ordered argument names and classes, and Method to invoke private final String name; private final Class<?> resultType; @@ -662,13 +661,13 @@ public enum FacebookMethodsType { private final List<Class<?>> argTypes; private final Method method; - private FacebookMethodsType(Class<?> resultType, String name, Object... args) throws IllegalArgumentException { + FacebookMethodsType(Class<?> resultType, String name, Object... args) throws IllegalArgumentException { this.name = name; this.resultType = resultType; if (args.length % 2 != 0) { throw new IllegalArgumentException("Invalid parameter list, " - + "must be of the form 'Class arg1, String arg1Name, Class arg2, String arg2Name..."); + + "must be of the form 'Class arg1, String arg1Name, Class arg2, String arg2Name..."); } int nArgs = args.length / 2; this.argNames = new ArrayList<String>(nArgs); @@ -683,8 +682,8 @@ public enum FacebookMethodsType { this.method = Facebook.class.getMethod(name, argTypes.toArray(new Class[nArgs])); } catch (NoSuchMethodException e) { throw new IllegalArgumentException( - String.format("Missing method %s %s", name, argTypes.toString().replace('[', '(').replace(']', ')')), - e); + String.format("Missing method %s %s", name, argTypes.toString().replace('[', '(').replace(']', ')')), + e); } } @@ -698,7 +697,7 @@ public enum FacebookMethodsType { for (FacebookMethodsType method : values()) { if (method.name.equals(name)) { if ((method.argTypes.isEmpty() && (args == null || args.length == 0)) - || Arrays.equals(method.argTypes.toArray(), args)) { + || Arrays.equals(method.argTypes.toArray(), args)) { return method; } } @@ -731,11 +730,11 @@ public enum FacebookMethodsType { public String toString() { StringBuilder builder = new StringBuilder(); builder.append("{") - .append("name=").append(name) - .append(", resultType=").append(resultType) - .append(", argNames=").append(argNames) - .append(", argTypes=").append(argTypes) - .append("}"); + .append("name=").append(name) + .append(", resultType=").append(resultType) + .append(", argNames=").append(argNames) + .append(", argTypes=").append(argTypes) + .append("}"); return builder.toString(); } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java ---------------------------------------------------------------------- diff --git a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java index 4cdf4c2..4e7f7bf 100644 --- a/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java +++ b/components/camel-facebook/src/main/java/org/apache/camel/component/facebook/data/FacebookMethodsTypeHelper.java @@ -363,7 +363,7 @@ public final class FacebookMethodsTypeHelper { } } - public static enum MatchType { + public enum MatchType { EXACT, SUBSET, SUPER_SET } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/TestUserMethodsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/TestUserMethodsTest.java b/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/TestUserMethodsTest.java index 37732f4..2525ade 100644 --- a/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/TestUserMethodsTest.java +++ b/components/camel-facebook/src/test/java/org/apache/camel/component/facebook/TestUserMethodsTest.java @@ -53,8 +53,7 @@ public class TestUserMethodsTest extends CamelFacebookTestSupport { // make friends, not enemies final Map<String, Object> headers = new HashMap<String, Object>(); headers.put("CamelFacebook.testUser2", testUser2); - Boolean worked = template().requestBodyAndHeaders("direct:makeFriendTestUser" - , testUser1, headers, Boolean.class); + Boolean worked = template().requestBodyAndHeaders("direct:makeFriendTestUser", testUser1, headers, Boolean.class); assertTrue("Friends not made", worked); // get app test users http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java ---------------------------------------------------------------------- diff --git a/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java b/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java index 7964a75..c7eb1aa 100644 --- a/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java +++ b/components/camel-flatpack/src/main/java/org/apache/camel/component/flatpack/FlatpackProducer.java @@ -27,7 +27,7 @@ import org.apache.camel.impl.DefaultProducer; class FlatpackProducer extends DefaultProducer { private FlatpackEndpoint endpoint; - public FlatpackProducer(FlatpackEndpoint endpoint) { + FlatpackProducer(FlatpackEndpoint endpoint) { super(endpoint); this.endpoint = endpoint; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/OsgiParserFactory.java ---------------------------------------------------------------------- diff --git a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/OsgiParserFactory.java b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/OsgiParserFactory.java index 7d78ac1..9c4875e 100644 --- a/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/OsgiParserFactory.java +++ b/components/camel-ftp/src/main/java/org/apache/camel/component/file/remote/OsgiParserFactory.java @@ -133,7 +133,7 @@ public class OsgiParserFactory extends DefaultFTPFileEntryParserFactory { /** * Creates an NT FTP parser: if the config exists, and the system key equals - * {@link FTPClientConfig.SYST_NT} then a plain {@link NTFTPEntryParser} is used, + * {@link FTPClientConfig#SYST_NT} then a plain {@link NTFTPEntryParser} is used, * otherwise a composite of {@link NTFTPEntryParser} and {@link UnixFTPEntryParser} is used. * @param config the config to use, may be {@code null} * @return the parser @@ -152,13 +152,12 @@ public class OsgiParserFactory extends DefaultFTPFileEntryParserFactory { /** * Creates an OS400 FTP parser: if the config exists, and the system key equals - * {@link FTPClientConfig.SYST_OS400} then a plain {@link OS400FTPEntryParser} is used, + * {@link FTPClientConfig#SYST_OS400} then a plain {@link OS400FTPEntryParser} is used, * otherwise a composite of {@link OS400FTPEntryParser} and {@link UnixFTPEntryParser} is used. * @param config the config to use, may be {@code null} * @return the parser */ - private FTPFileEntryParser createOS400FTPEntryParser(FTPClientConfig config) - { + private FTPFileEntryParser createOS400FTPEntryParser(FTPClientConfig config) { if (config != null && FTPClientConfig.SYST_OS400.equals(config.getServerSystemKey())) { return new OS400FTPEntryParser(config); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetCipherTest.java ---------------------------------------------------------------------- diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetCipherTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetCipherTest.java index ffa5404..fe4c83f 100644 --- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetCipherTest.java +++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetCipherTest.java @@ -40,7 +40,7 @@ public class SftpSetCipherTest extends SftpServerTestSupport { String cipher = "blowfish-cbc"; String uri = "sftp://localhost:"; + getPort() + "/" + FTP_ROOT_DIR + "?username=admin&password=admin&ciphers=" + cipher; - template.sendBodyAndHeader(uri , "Hello World", Exchange.FILE_NAME, "hello.txt"); + template.sendBodyAndHeader(uri, "Hello World", Exchange.FILE_NAME, "hello.txt"); // test setting the cipher doesn't interfere with message payload File file = new File(FTP_ROOT_DIR + "/hello.txt"); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetOperationsTest.java ---------------------------------------------------------------------- diff --git a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetOperationsTest.java b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetOperationsTest.java index ca40540..62d6834 100644 --- a/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetOperationsTest.java +++ b/components/camel-ftp/src/test/java/org/apache/camel/component/file/remote/sftp/SftpSetOperationsTest.java @@ -39,7 +39,7 @@ public class SftpSetOperationsTest extends SftpServerTestSupport { String uri = "sftp://localhost:"; + getPort() + "/" + FTP_ROOT_DIR + "?username=admin&password=admin&ciphers=blowfish-cbc" + "&preferredAuthentications=password,publickey"; - template.sendBodyAndHeader(uri , "Hello World", Exchange.FILE_NAME, "hello.txt"); + template.sendBodyAndHeader(uri, "Hello World", Exchange.FILE_NAME, "hello.txt"); // test setting the cipher doesn't interfere with message payload File file = new File(FTP_ROOT_DIR + "/hello.txt"); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java ---------------------------------------------------------------------- diff --git a/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java b/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java index 58c4cf6..4660507 100644 --- a/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java +++ b/components/camel-gora/src/main/java/org/apache/camel/component/gora/utils/GoraUtils.java @@ -63,7 +63,7 @@ public final class GoraUtils { public static Query<Object, Persistent> constractQueryFromConfiguration(final DataStore<Object, Persistent> dataStore, final GoraConfiguration conf) throws ClassNotFoundException, IllegalAccessException, NoSuchMethodException, InvocationTargetException { - final Query<Object , Persistent> query = dataStore.newQuery(); + final Query<Object, Persistent> query = dataStore.newQuery(); if (configurationExist(GoraAttribute.GORA_QUERY_START_TIME, conf)) { query.setStartTime(getAttributeAsLong(GoraAttribute.GORA_QUERY_START_TIME, conf)); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-guice/src/main/java/org/apache/camel/guice/jsr250/AnnotatedMethodCache.java ---------------------------------------------------------------------- diff --git a/components/camel-guice/src/main/java/org/apache/camel/guice/jsr250/AnnotatedMethodCache.java b/components/camel-guice/src/main/java/org/apache/camel/guice/jsr250/AnnotatedMethodCache.java index ad0f4ca..6f8ea66 100644 --- a/components/camel-guice/src/main/java/org/apache/camel/guice/jsr250/AnnotatedMethodCache.java +++ b/components/camel-guice/src/main/java/org/apache/camel/guice/jsr250/AnnotatedMethodCache.java @@ -33,7 +33,7 @@ class AnnotatedMethodCache { private Map<Class<?>, Method> methodCache = Collections .synchronizedMap(new WeakHashMap<Class<?>, Method>()); - public AnnotatedMethodCache(Class<? extends Annotation> annotationType) { + AnnotatedMethodCache(Class<? extends Annotation> annotationType) { this.annotationType = annotationType; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPConfigAwareChannelHandlerFactory.java ---------------------------------------------------------------------- diff --git a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPConfigAwareChannelHandlerFactory.java b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPConfigAwareChannelHandlerFactory.java index 82be6d0..a686ed7 100644 --- a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPConfigAwareChannelHandlerFactory.java +++ b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPConfigAwareChannelHandlerFactory.java @@ -27,11 +27,11 @@ abstract class HL7MLLPConfigAwareChannelHandlerFactory extends DefaultChannelHan protected final HL7MLLPConfig config; - public HL7MLLPConfigAwareChannelHandlerFactory() { + HL7MLLPConfigAwareChannelHandlerFactory() { this(new HL7MLLPConfig()); } - public HL7MLLPConfigAwareChannelHandlerFactory(HL7MLLPConfig config) { + HL7MLLPConfigAwareChannelHandlerFactory(HL7MLLPConfig config) { this.config = config; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyDecoder.java ---------------------------------------------------------------------- diff --git a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyDecoder.java b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyDecoder.java index 2ced9b4..54557b7 100644 --- a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyDecoder.java +++ b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyDecoder.java @@ -38,7 +38,7 @@ class HL7MLLPNettyDecoder extends DelimiterBasedFrameDecoder { /** * Creates a decoder instance using a default HL7MLLPConfig */ - public HL7MLLPNettyDecoder() { + HL7MLLPNettyDecoder() { this(new HL7MLLPConfig()); } @@ -48,7 +48,7 @@ class HL7MLLPNettyDecoder extends DelimiterBasedFrameDecoder { * @param config HL7MLLPConfig to be used for decoding * @throws java.lang.NullPointerException is config is null */ - public HL7MLLPNettyDecoder(HL7MLLPConfig config) { + HL7MLLPNettyDecoder(HL7MLLPConfig config) { super(MAX_FRAME_LENGTH, true, Unpooled.copiedBuffer( new char[]{config.getEndByte1(), config.getEndByte2()}, Charset.defaultCharset())); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyEncoder.java ---------------------------------------------------------------------- diff --git a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyEncoder.java b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyEncoder.java index a661ccd..33f27fb 100644 --- a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyEncoder.java +++ b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/HL7MLLPNettyEncoder.java @@ -28,11 +28,11 @@ class HL7MLLPNettyEncoder extends MessageToByteEncoder<Object> { private final HL7MLLPConfig config; - public HL7MLLPNettyEncoder() { + HL7MLLPNettyEncoder() { this(new HL7MLLPConfig()); } - public HL7MLLPNettyEncoder(HL7MLLPConfig config) { + HL7MLLPNettyEncoder(HL7MLLPConfig config) { this.config = config; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/TerserExpression.java ---------------------------------------------------------------------- diff --git a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/TerserExpression.java b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/TerserExpression.java index 4476227..7efebc8 100644 --- a/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/TerserExpression.java +++ b/components/camel-hl7/src/main/java/org/apache/camel/component/hl7/TerserExpression.java @@ -26,7 +26,7 @@ import org.apache.camel.model.language.ExpressionDefinition; @XmlAccessorType(XmlAccessType.FIELD) class TerserExpression extends ExpressionDefinition { - public TerserExpression(String expression) { + TerserExpression(String expression) { super(expression); } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java index e60156a..34463fb 100644 --- a/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java +++ b/components/camel-infinispan/src/main/java/org/apache/camel/component/infinispan/InfinispanConsumer.java @@ -127,7 +127,7 @@ public class InfinispanConsumer extends DefaultConsumer { private class ContinuousQueryEventListener implements ContinuousQueryListener<Object, Object> { private final String cacheName; - public ContinuousQueryEventListener(String cacheName) { + ContinuousQueryEventListener(String cacheName) { this.cacheName = cacheName; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/GsonUtil.java ---------------------------------------------------------------------- diff --git a/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/GsonUtil.java b/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/GsonUtil.java index 47dab61..17a8804 100644 --- a/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/GsonUtil.java +++ b/components/camel-ironmq/src/main/java/org/apache/camel/component/ironmq/GsonUtil.java @@ -33,7 +33,7 @@ public final class GsonUtil { private Map<String, Object> headers = new HashMap<String, Object>(); private String body; - public IronMqMessage(String body, Map<String, Object> headers) { + IronMqMessage(String body, Map<String, Object> headers) { super(); this.headers = headers; this.body = body; http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceConsumer.java b/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceConsumer.java index 4001a6e..bb9fe14 100644 --- a/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceConsumer.java +++ b/components/camel-javaspace/src/main/java/org/apache/camel/component/javaspace/JavaSpaceConsumer.java @@ -113,7 +113,7 @@ class Task implements Runnable { private final int verb; private final Entry template; - public Task(JavaSpaceEndpoint endpoint, Processor processor, JavaSpace javaSpace, + Task(JavaSpaceEndpoint endpoint, Processor processor, JavaSpace javaSpace, TransactionHelper transactionHelper, long transactionTimeout, int verb, String templateId) throws Exception { this.endpoint = endpoint; this.processor = processor; http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-javaspace/src/test/java/org/apache/camel/component/javaspace/JavaSpaceRequestReplyTest.java ---------------------------------------------------------------------- diff --git a/components/camel-javaspace/src/test/java/org/apache/camel/component/javaspace/JavaSpaceRequestReplyTest.java b/components/camel-javaspace/src/test/java/org/apache/camel/component/javaspace/JavaSpaceRequestReplyTest.java index 23e5593..e7f9b27 100644 --- a/components/camel-javaspace/src/test/java/org/apache/camel/component/javaspace/JavaSpaceRequestReplyTest.java +++ b/components/camel-javaspace/src/test/java/org/apache/camel/component/javaspace/JavaSpaceRequestReplyTest.java @@ -105,7 +105,7 @@ class PojoCallable implements Callable<Reply> { final ITestPojo proxy; final Request request; - public PojoCallable(Request request, ITestPojo proxy) { + PojoCallable(Request request, ITestPojo proxy) { this.request = request; this.proxy = proxy; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEntryEventFilters.java ---------------------------------------------------------------------- diff --git a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEntryEventFilters.java b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEntryEventFilters.java index 08dbfd5..fc54909 100644 --- a/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEntryEventFilters.java +++ b/components/camel-jcache/src/main/java/org/apache/camel/component/jcache/JCacheEntryEventFilters.java @@ -28,7 +28,7 @@ class JCacheEntryEventFilters { public static class Named implements CacheEntryEventFilter<Object, Object> { private List<EventType> filteredEvents; - public Named(Collection<EventType> filteredEventNames) { + Named(Collection<EventType> filteredEventNames) { if (filteredEventNames != null && !filteredEventNames.isEmpty()) { this.filteredEvents = new ArrayList<>(filteredEventNames); } @@ -48,7 +48,7 @@ class JCacheEntryEventFilters { private final List<CacheEntryEventFilter> filteredEvents; private final int filteredEventsSize; - public Chained(List<CacheEntryEventFilter> filteredEvents) { + Chained(List<CacheEntryEventFilter> filteredEvents) { if (filteredEvents != null && !filteredEvents.isEmpty()) { this.filteredEvents = new ArrayList<>(filteredEvents); this.filteredEventsSize = this.filteredEvents.size(); http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java ---------------------------------------------------------------------- diff --git a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java index 536ab66..7733231 100644 --- a/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java +++ b/components/camel-kafka/src/main/java/org/apache/camel/component/kafka/KafkaConsumer.java @@ -90,7 +90,7 @@ public class KafkaConsumer extends DefaultConsumer { private final String threadId; private final Properties kafkaProps; - public KafkaFetchRecords(String topicName, String id, Properties kafkaProps) { + KafkaFetchRecords(String topicName, String id, Properties kafkaProps) { this.topicName = topicName; this.threadId = topicName + "-" + "Thread " + id; this.kafkaProps = kafkaProps; http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-linkedin/camel-linkedin-api/src/main/java/org/apache/camel/component/linkedin/api/OAuthScope.java ---------------------------------------------------------------------- diff --git a/components/camel-linkedin/camel-linkedin-api/src/main/java/org/apache/camel/component/linkedin/api/OAuthScope.java b/components/camel-linkedin/camel-linkedin-api/src/main/java/org/apache/camel/component/linkedin/api/OAuthScope.java index 3549061..f372ad7 100644 --- a/components/camel-linkedin/camel-linkedin-api/src/main/java/org/apache/camel/component/linkedin/api/OAuthScope.java +++ b/components/camel-linkedin/camel-linkedin-api/src/main/java/org/apache/camel/component/linkedin/api/OAuthScope.java @@ -35,7 +35,7 @@ public enum OAuthScope { private final String value; - private OAuthScope(String value) { + OAuthScope(String value) { this.value = value; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsType.java ---------------------------------------------------------------------- diff --git a/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsType.java b/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsType.java index 3348578..970da79 100644 --- a/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsType.java +++ b/components/camel-metrics/src/main/java/org/apache/camel/component/metrics/MetricsType.java @@ -38,7 +38,7 @@ public enum MetricsType { } } - private MetricsType(String name) { + MetricsType(String name) { this.name = name; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java ---------------------------------------------------------------------- diff --git a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java index 5f1ad2d..2967c94 100644 --- a/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java +++ b/components/camel-mina/src/test/java/org/apache/camel/component/mina/MinaClientModeTcpTextlineDelimiterTest.java @@ -62,7 +62,8 @@ public class MinaClientModeTcpTextlineDelimiterTest extends BaseMinaTest { private class Server { private final int port; private IoAcceptor acceptor; - public Server(int port) { + + Server(int port) { this.port = port; } http://git-wip-us.apache.org/repos/asf/camel/blob/5fee9dd8/components/camel-mina2/src/test/java/org/apache/camel/component/mina2/Mina2ClientModeTcpTextlineDelimiterTest.java ---------------------------------------------------------------------- diff --git a/components/camel-mina2/src/test/java/org/apache/camel/component/mina2/Mina2ClientModeTcpTextlineDelimiterTest.java b/components/camel-mina2/src/test/java/org/apache/camel/component/mina2/Mina2ClientModeTcpTextlineDelimiterTest.java index b160add..ba11d11 100644 --- a/components/camel-mina2/src/test/java/org/apache/camel/component/mina2/Mina2ClientModeTcpTextlineDelimiterTest.java +++ b/components/camel-mina2/src/test/java/org/apache/camel/component/mina2/Mina2ClientModeTcpTextlineDelimiterTest.java @@ -64,7 +64,8 @@ public class Mina2ClientModeTcpTextlineDelimiterTest extends BaseMina2Test { private class Server { private final int port; private IoAcceptor acceptor; - public Server(int port) { + + Server(int port) { this.port = port; }
