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 <oal...@neivi.es> Authored: Tue Mar 22 12:33:32 2016 +0100 Committer: Claus Ibsen <davscl...@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; + } +}
