You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by da...@apache.org on 2016/03/23 19:59:35 UTC
[15/23] camel git commit: Fixing Logging level.
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 <oa...@neivi.es>
Authored: Tue Mar 22 12:33:32 2016 +0100
Committer: Claus Ibsen <da...@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;
+ }
+}