camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From davscl...@apache.org
Subject [15/23] camel git commit: Fixing Logging level.
Date Wed, 23 Mar 2016 18:59:35 GMT
Fixing Logging level. 

Project: http://git-wip-us.apache.org/repos/asf/camel/repo
Commit: http://git-wip-us.apache.org/repos/asf/camel/commit/32308ca7
Tree: http://git-wip-us.apache.org/repos/asf/camel/tree/32308ca7
Diff: http://git-wip-us.apache.org/repos/asf/camel/diff/32308ca7

Branch: refs/heads/master
Commit: 32308ca75a405a44d30735925d583210246cee58
Parents: d0e134c
Author: oalles <oalles@neivi.es>
Authored: Tue Mar 22 12:33:32 2016 +0100
Committer: Claus Ibsen <davsclaus@apache.org>
Committed: Wed Mar 23 18:46:10 2016 +0100

----------------------------------------------------------------------
 .../apache/camel/component/cm/CMEndpoint.java   | 282 +++++++++----------
 1 file changed, 141 insertions(+), 141 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/camel/blob/32308ca7/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java
----------------------------------------------------------------------
diff --git a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java
b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java
index 0aa34d2..860967d 100644
--- a/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java
+++ b/components/camel-cm/src/main/java/org/apache/camel/component/cm/CMEndpoint.java
@@ -1,141 +1,141 @@
-/**
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements.  See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License.  You may obtain a copy of the License at
- *
- *      http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.camel.component.cm;
-
-import org.apache.camel.Consumer;
-import org.apache.camel.ExchangePattern;
-import org.apache.camel.Processor;
-import org.apache.camel.Producer;
-import org.apache.camel.RuntimeCamelException;
-import org.apache.camel.api.management.ManagedAttribute;
-import org.apache.camel.api.management.ManagedOperation;
-import org.apache.camel.api.management.ManagedResource;
-import org.apache.camel.impl.DefaultEndpoint;
-import org.apache.camel.spi.Metadata;
-import org.apache.camel.spi.UriPath;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-@ManagedResource(description = "CM SMS Endpoint")
-// @UriEndpoint(scheme = "cm", title = "CM DIRECT SMS", syntax = "cm:host",
-// label = "sms provider", producerOnly = true)
-public class CMEndpoint extends DefaultEndpoint {
-
-    private static final Logger LOG = LoggerFactory.getLogger(CMEndpoint.class);
-
-    @UriPath
-    @Metadata(description = "SMS Provider HOST with scheme", required = "true")
-    private String host;
-
-    /**
-     * data needed for exchange interaction
-     */
-    private CMConfiguration configuration;
-
-    private CMProducer producer;
-
-    /**
-     * Constructs a partially-initialized CMEndpoint instance. Useful when creating endpoints
manually (e.g., as beans in Spring).
-     */
-    // We are just going to allow fully initialized endpoint instances
-    // public CMEndpoint() {
-    // }
-
-    /**
-     * Constructs a fully-initialized CMEndpoint instance. This is the preferred method of
constructing an object from Java code (as opposed to Spring beans, etc.).
-     *
-     * @param endpointUri the full URI used to create this endpoint
-     * @param component the component that created this endpoint
-     */
-    public CMEndpoint(final String uri, final CMComponent component) {
-        super(uri, component);
-        setExchangePattern(ExchangePattern.InOut);
-        LOG.info("CM Endpoint created - (IN/OUT)");
-    }
-
-    /**
-     * Provides a channel on which clients can send Messages to a CM Endpoint
-     */
-    @Override
-    public Producer createProducer() throws Exception {
-        final CMConfiguration config = getConfiguration();
-
-        // This is the camel exchange processor. Allows to send messages to CM
-        // API.
-        // TODO: Should i provide a CMSender factory? Dynamically choose
-        // CMSender implementation? Sending strategy?
-        // Consider:
-        // 1. single - Single Message strategy.
-        // 2. Multi - CM Api supports to 1000 messages per call.
-        // 3. sliding - sliding window? 1000 messages or time thresold?
-        // 4. mocked - in order to fake cm responses
-
-        // CMConstants.DEFAULT_SCHEME + host is a valid URL. It was previously
-        // checked
-        LOG.debug("Creating CM Producer");
-        producer = new CMProducer(this, new CMSenderOneMessageImpl(getCMUrl(), config.getProductToken()));
-        LOG.debug("CM Producer: OK!");
-        return producer;
-    }
-
-    @Override
-    public Consumer createConsumer(final Processor processor) throws Exception {
-
-        throw new RuntimeCamelException("So far, cannot consume from CM Endpoint: " + getEndpointUri());
-    }
-
-    public CMConfiguration getConfiguration() {
-        return configuration;
-    }
-
-    public void setConfiguration(final CMConfiguration configuration) {
-        this.configuration = configuration;
-    }
-
-    @Override
-    public boolean isSingleton() {
-        return true;
-    }
-
-    // @Override
-    // public Exchange createExchange() {
-    // return super.createExchange();
-    // }
-
-    @ManagedAttribute
-    public String getHost() {
-        return host;
-    }
-
-    public String getCMUrl() {
-        return CMConstants.DEFAULT_SCHEME + host;
-    }
-
-    @ManagedOperation(description = "Dynamically modify Service HOST")
-    public void setHost(final String host) {
-        this.host = host;
-    }
-
-    @Override
-    public CMComponent getComponent() {
-        return (CMComponent) super.getComponent();
-    }
-
-    public CMProducer getProducer() {
-        return producer;
-    }
-}
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements.  See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License.  You may obtain a copy of the License at
+ *
+ *      http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.camel.component.cm;
+
+import org.apache.camel.Consumer;
+import org.apache.camel.ExchangePattern;
+import org.apache.camel.Processor;
+import org.apache.camel.Producer;
+import org.apache.camel.RuntimeCamelException;
+import org.apache.camel.api.management.ManagedAttribute;
+import org.apache.camel.api.management.ManagedOperation;
+import org.apache.camel.api.management.ManagedResource;
+import org.apache.camel.impl.DefaultEndpoint;
+import org.apache.camel.spi.Metadata;
+import org.apache.camel.spi.UriPath;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+@ManagedResource(description = "CM SMS Endpoint")
+// @UriEndpoint(scheme = "cm", title = "CM DIRECT SMS", syntax = "cm:host",
+// label = "sms provider", producerOnly = true)
+public class CMEndpoint extends DefaultEndpoint {
+
+    private static final Logger LOG = LoggerFactory.getLogger(CMEndpoint.class);
+
+    @UriPath
+    @Metadata(description = "SMS Provider HOST with scheme", required = "true")
+    private String host;
+
+    /**
+     * data needed for exchange interaction
+     */
+    private CMConfiguration configuration;
+
+    private CMProducer producer;
+
+    /**
+     * Constructs a partially-initialized CMEndpoint instance. Useful when creating endpoints
manually (e.g., as beans in Spring).
+     */
+    // We are just going to allow fully initialized endpoint instances
+    // public CMEndpoint() {
+    // }
+
+    /**
+     * Constructs a fully-initialized CMEndpoint instance. This is the preferred method of
constructing an object from Java code (as opposed to Spring beans, etc.).
+     *
+     * @param endpointUri the full URI used to create this endpoint
+     * @param component the component that created this endpoint
+     */
+    public CMEndpoint(final String uri, final CMComponent component) {
+        super(uri, component);
+        setExchangePattern(ExchangePattern.InOut);
+        LOG.debug("CM Endpoint created");
+    }
+
+    /**
+     * Provides a channel on which clients can send Messages to a CM Endpoint
+     */
+    @Override
+    public Producer createProducer() throws Exception {
+        final CMConfiguration config = getConfiguration();
+
+        // This is the camel exchange processor. Allows to send messages to CM
+        // API.
+        // TODO: Should i provide a CMSender factory? Dynamically choose
+        // CMSender implementation? Sending strategy?
+        // Consider:
+        // 1. single - Single Message strategy.
+        // 2. Multi - CM Api supports to 1000 messages per call.
+        // 3. sliding - sliding window? 1000 messages or time thresold?
+        // 4. mocked - in order to fake cm responses
+
+        // CMConstants.DEFAULT_SCHEME + host is a valid URL. It was previously
+        // checked
+        LOG.debug("Creating CM Producer");
+        producer = new CMProducer(this, new CMSenderOneMessageImpl(getCMUrl(), config.getProductToken()));
+        LOG.debug("CM Producer: OK!");
+        return producer;
+    }
+
+    @Override
+    public Consumer createConsumer(final Processor processor) throws Exception {
+
+        throw new RuntimeCamelException("So far, cannot consume from CM Endpoint: " + getEndpointUri());
+    }
+
+    public CMConfiguration getConfiguration() {
+        return configuration;
+    }
+
+    public void setConfiguration(final CMConfiguration configuration) {
+        this.configuration = configuration;
+    }
+
+    @Override
+    public boolean isSingleton() {
+        return true;
+    }
+
+    // @Override
+    // public Exchange createExchange() {
+    // return super.createExchange();
+    // }
+
+    @ManagedAttribute
+    public String getHost() {
+        return host;
+    }
+
+    public String getCMUrl() {
+        return CMConstants.DEFAULT_SCHEME + host;
+    }
+
+    @ManagedOperation(description = "Dynamically modify Service HOST")
+    public void setHost(final String host) {
+        this.host = host;
+    }
+
+    @Override
+    public CMComponent getComponent() {
+        return (CMComponent) super.getComponent();
+    }
+
+    public CMProducer getProducer() {
+        return producer;
+    }
+}


Mime
View raw message