Fixed CS
Project: http://git-wip-us.apache.org/repos/asf/camel/repo Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/3500b833 Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/3500b833 Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/3500b833 Branch: refs/heads/master Commit: 3500b833f9b12d95eb70dea38ee6c8275a3e3773 Parents: 8592aaa Author: Claus Ibsen <davscl...@apache.org> Authored: Fri Mar 4 14:33:15 2016 +0100 Committer: Claus Ibsen <davscl...@apache.org> Committed: Fri Mar 4 14:33:15 2016 +0100 ---------------------------------------------------------------------- .../java/org/apache/camel/component/solr/SolrEndpoint.java | 9 +++++---- 1 file changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/camel/blob/3500b833/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java ---------------------------------------------------------------------- diff --git a/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java b/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java index 56f9b3e..dd29913 100644 --- a/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java +++ b/components/camel-solr/src/main/java/org/apache/camel/component/solr/SolrEndpoint.java @@ -40,7 +40,8 @@ public class SolrEndpoint extends DefaultEndpoint { private String scheme = "http://";; - @UriPath(description = "Hostname and port for the solr server") @Metadata(required = "true") + @UriPath(description = "Hostname and port for the solr server") + @Metadata(required = "true") private String url; @UriParam(defaultValue = "" + SolrConstants.DEFUALT_STREAMING_QUEUE_SIZE) private int streamingQueueSize = SolrConstants.DEFUALT_STREAMING_QUEUE_SIZE; @@ -103,16 +104,16 @@ public class SolrEndpoint extends DefaultEndpoint { public SolrComponent getComponent() { return (SolrComponent) super.getComponent(); } - + private CloudSolrClient getCloudServer() { - CloudSolrClient rVal = null; + CloudSolrClient rVal = null; if (this.getZkHost() != null && this.getCollection() != null) { rVal = new CloudSolrClient(zkHost); rVal.setDefaultCollection(this.getCollection()); } return rVal; } - + @Override public Producer createProducer() throws Exception { // do we have servers?
