camel-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhira...@apache.org
Subject [05/26] camel git commit: Revert "CAMEL-10197: Added plain get/set to components for spring-boot configuration"
Date Tue, 20 Sep 2016 19:57:17 GMT
http://git-wip-us.apache.org/repos/asf/camel/blob/a04fb15b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java
index 33b814e..f515c94 100644
--- a/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java
+++ b/components/camel-netty4/src/main/java/org/apache/camel/component/netty4/NettyComponent.java
@@ -18,24 +18,17 @@ package org.apache.camel.component.netty4;
 
 import java.net.URI;
 import java.util.HashMap;
-import java.util.List;
 import java.util.Map;
 import java.util.concurrent.ThreadFactory;
 
-import io.netty.channel.ChannelHandler;
-import io.netty.channel.EventLoopGroup;
-import io.netty.channel.group.ChannelGroup;
-import io.netty.handler.ssl.SslHandler;
 import io.netty.util.concurrent.DefaultEventExecutorGroup;
 import io.netty.util.concurrent.EventExecutorGroup;
 
 import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
-import org.apache.camel.LoggingLevel;
 import org.apache.camel.impl.UriEndpointComponent;
 import org.apache.camel.util.IntrospectionSupport;
 import org.apache.camel.util.concurrent.CamelThreadFactory;
-import org.apache.camel.util.jsse.SSLContextParameters;
 
 public class NettyComponent extends UriEndpointComponent {
     private NettyConfiguration configuration;
@@ -109,7 +102,7 @@ public class NettyComponent extends UriEndpointComponent {
     }
 
     /**
-     * To use the NettyConfiguration as configuration when creating endpoints. Properties of the shared configuration can also be set individually.
+     * To use the NettyConfiguration as configuration when creating endpoints.
      */
     public void setConfiguration(NettyConfiguration configuration) {
         this.configuration = configuration;
@@ -165,846 +158,4 @@ public class NettyComponent extends UriEndpointComponent {
         super.doStop();
     }
 
-    private NettyConfiguration getConfigurationOrCreate() {
-        if (this.getConfiguration() == null) {
-            this.setConfiguration(new NettyConfiguration());
-        }
-        return this.getConfiguration();
-    }
-
-    public String getAddress() {
-        return getConfigurationOrCreate().getAddress();
-    }
-
-    public boolean isTcp() {
-        return getConfigurationOrCreate().isTcp();
-    }
-
-    public String getProtocol() {
-        return getConfigurationOrCreate().getProtocol();
-    }
-
-    /**
-     * The protocol to use which can be tcp or udp.
-     * @param protocol
-     */
-    public void setProtocol(String protocol) {
-        getConfigurationOrCreate().setProtocol(protocol);
-    }
-
-    public String getHost() {
-        return getConfigurationOrCreate().getHost();
-    }
-
-    /**
-     * The hostname.
-     * <p/>
-     * For the consumer the hostname is localhost or 0.0.0.0
-     * For the producer the hostname is the remote host to connect to
-     * @param host
-     */
-    public void setHost(String host) {
-        getConfigurationOrCreate().setHost(host);
-    }
-
-    public int getPort() {
-        return getConfigurationOrCreate().getPort();
-    }
-
-    /**
-     * The host port number
-     * @param port
-     */
-    public void setPort(int port) {
-        getConfigurationOrCreate().setPort(port);
-    }
-
-    public boolean isBroadcast() {
-        return getConfigurationOrCreate().isBroadcast();
-    }
-
-    /**
-     * Setting to choose Multicast over UDP
-     * @param broadcast
-     */
-    public void setBroadcast(boolean broadcast) {
-        getConfigurationOrCreate().setBroadcast(broadcast);
-    }
-
-    public int getSendBufferSize() {
-        return getConfigurationOrCreate().getSendBufferSize();
-    }
-
-    /**
-     * The TCP/UDP buffer sizes to be used during outbound communication. Size is bytes.
-     * @param sendBufferSize
-     */
-    public void setSendBufferSize(int sendBufferSize) {
-        getConfigurationOrCreate().setSendBufferSize(sendBufferSize);
-    }
-
-    public int getReceiveBufferSize() {
-        return getConfigurationOrCreate().getReceiveBufferSize();
-    }
-
-    /**
-     * The TCP/UDP buffer sizes to be used during inbound communication. Size is bytes.
-     * @param receiveBufferSize
-     */
-    public void setReceiveBufferSize(int receiveBufferSize) {
-        getConfigurationOrCreate().setReceiveBufferSize(receiveBufferSize);
-    }
-
-    public int getReceiveBufferSizePredictor() {
-        return getConfigurationOrCreate().getReceiveBufferSizePredictor();
-    }
-
-    /**
-     * Configures the buffer size predictor. See details at Jetty documentation and this mail thread.
-     * @param receiveBufferSizePredictor
-     */
-    public void setReceiveBufferSizePredictor(int receiveBufferSizePredictor) {
-        getConfigurationOrCreate().setReceiveBufferSizePredictor(receiveBufferSizePredictor);
-    }
-
-    public int getWorkerCount() {
-        return getConfigurationOrCreate().getWorkerCount();
-    }
-
-    /**
-     * When netty works on nio mode, it uses default workerCount parameter from Netty, which is cpu_core_threads*2.
-     * User can use this operation to override the default workerCount from Netty
-     * @param workerCount
-     */
-    public void setWorkerCount(int workerCount) {
-        getConfigurationOrCreate().setWorkerCount(workerCount);
-    }
-
-    public int getBossCount() {
-        return getConfigurationOrCreate().getBossCount();
-    }
-
-    /**
-     * When netty works on nio mode, it uses default bossCount parameter from Netty, which is 1.
-     * User can use this operation to override the default bossCount from Netty
-     * @param bossCount
-     */
-    public void setBossCount(int bossCount) {
-        getConfigurationOrCreate().setBossCount(bossCount);
-    }
-
-    public boolean isKeepAlive() {
-        return getConfigurationOrCreate().isKeepAlive();
-    }
-
-    /**
-     * Setting to ensure socket is not closed due to inactivity
-     * @param keepAlive
-     */
-    public void setKeepAlive(boolean keepAlive) {
-        getConfigurationOrCreate().setKeepAlive(keepAlive);
-    }
-
-    public boolean isTcpNoDelay() {
-        return getConfigurationOrCreate().isTcpNoDelay();
-    }
-
-    /**
-     * Setting to improve TCP protocol performance
-     * @param tcpNoDelay
-     */
-    public void setTcpNoDelay(boolean tcpNoDelay) {
-        getConfigurationOrCreate().setTcpNoDelay(tcpNoDelay);
-    }
-
-    public boolean isReuseAddress() {
-        return getConfigurationOrCreate().isReuseAddress();
-    }
-
-    /**
-     * Setting to facilitate socket multiplexing
-     * @param reuseAddress
-     */
-    public void setReuseAddress(boolean reuseAddress) {
-        getConfigurationOrCreate().setReuseAddress(reuseAddress);
-    }
-
-    public int getConnectTimeout() {
-        return getConfigurationOrCreate().getConnectTimeout();
-    }
-
-    /**
-     * Time to wait for a socket connection to be available. Value is in millis.
-     * @param connectTimeout
-     */
-    public void setConnectTimeout(int connectTimeout) {
-        getConfigurationOrCreate().setConnectTimeout(connectTimeout);
-    }
-
-    public int getBacklog() {
-        return getConfigurationOrCreate().getBacklog();
-    }
-
-    /**
-     * Allows to configure a backlog for netty consumer (server).
-     * Note the backlog is just a best effort depending on the OS.
-     * Setting this option to a value such as 200, 500 or 1000, tells the TCP stack how long the "accept" queue can be
-     * If this option is not configured, then the backlog depends on OS setting.
-     * @param backlog
-     */
-    public void setBacklog(int backlog) {
-        getConfigurationOrCreate().setBacklog(backlog);
-    }
-
-    public boolean isSsl() {
-        return getConfigurationOrCreate().isSsl();
-    }
-
-    /**
-     * Setting to specify whether SSL encryption is applied to this endpoint
-     * @param ssl
-     */
-    public void setSsl(boolean ssl) {
-        getConfigurationOrCreate().setSsl(ssl);
-    }
-
-    public boolean isSslClientCertHeaders() {
-        return getConfigurationOrCreate().isSslClientCertHeaders();
-    }
-
-    /**
-     * When enabled and in SSL mode, then the Netty consumer will enrich the Camel Message with headers having
-     * information about the client certificate such as subject name, issuer name, serial number, and the valid date range.
-     * @param sslClientCertHeaders
-     */
-    public void setSslClientCertHeaders(boolean sslClientCertHeaders) {
-        getConfigurationOrCreate().setSslClientCertHeaders(sslClientCertHeaders);
-    }
-
-    public SslHandler getSslHandler() {
-        return getConfigurationOrCreate().getSslHandler();
-    }
-
-    /**
-     * Reference to a class that could be used to return an SSL Handler
-     * @param sslHandler
-     */
-    public void setSslHandler(SslHandler sslHandler) {
-        getConfigurationOrCreate().setSslHandler(sslHandler);
-    }
-
-    public SSLContextParameters getSslContextParameters() {
-        return getConfigurationOrCreate().getSslContextParameters();
-    }
-
-    /**
-     * To configure security using SSLContextParameters
-     * @param sslContextParameters
-     */
-    public void setSslContextParameters(SSLContextParameters sslContextParameters) {
-        getConfigurationOrCreate().setSslContextParameters(sslContextParameters);
-    }
-
-    public boolean isNeedClientAuth() {
-        return getConfigurationOrCreate().isNeedClientAuth();
-    }
-
-    /**
-     * Configures whether the server needs client authentication when using SSL.
-     * @param needClientAuth
-     */
-    public void setNeedClientAuth(boolean needClientAuth) {
-        getConfigurationOrCreate().setNeedClientAuth(needClientAuth);
-    }
-
-    public String getKeyStoreResource() {
-        return getConfigurationOrCreate().getKeyStoreResource();
-    }
-
-    /**
-     * Client side certificate keystore to be used for encryption. Is loaded by default from classpath,
-     * but you can prefix with "classpath:", "file:", or "http:" to load the resource from different systems.
-     * @param keyStoreResource
-     */
-    public void setKeyStoreResource(String keyStoreResource) {
-        getConfigurationOrCreate().setKeyStoreResource(keyStoreResource);
-    }
-
-    public String getTrustStoreResource() {
-        return getConfigurationOrCreate().getTrustStoreResource();
-    }
-
-    /**
-     * Server side certificate keystore to be used for encryption.
-     * Is loaded by default from classpath, but you can prefix with "classpath:", "file:", or "http:" to load the resource from different systems.
-     * @param trustStoreResource
-     */
-    public void setTrustStoreResource(String trustStoreResource) {
-        getConfigurationOrCreate().setTrustStoreResource(trustStoreResource);
-    }
-
-    public String getKeyStoreFormat() {
-        return getConfigurationOrCreate().getKeyStoreFormat();
-    }
-
-    /**
-     * Keystore format to be used for payload encryption. Defaults to "JKS" if not set
-     * @param keyStoreFormat
-     */
-    public void setKeyStoreFormat(String keyStoreFormat) {
-        getConfigurationOrCreate().setKeyStoreFormat(keyStoreFormat);
-    }
-
-    public String getSecurityProvider() {
-        return getConfigurationOrCreate().getSecurityProvider();
-    }
-
-    /**
-     * Security provider to be used for payload encryption. Defaults to "SunX509" if not set.
-     * @param securityProvider
-     */
-    public void setSecurityProvider(String securityProvider) {
-        getConfigurationOrCreate().setSecurityProvider(securityProvider);
-    }
-
-    public String getPassphrase() {
-        return getConfigurationOrCreate().getPassphrase();
-    }
-
-    /**
-     * Password setting to use in order to encrypt/decrypt payloads sent using SSH
-     * @param passphrase
-     */
-    public void setPassphrase(String passphrase) {
-        getConfigurationOrCreate().setPassphrase(passphrase);
-    }
-
-    public ServerInitializerFactory getServerInitializerFactory() {
-        return getConfigurationOrCreate().getServerInitializerFactory();
-    }
-
-    public String getCharsetName() {
-        return getConfigurationOrCreate().getCharsetName();
-    }
-
-    /**
-     * To use a custom ServerInitializerFactory
-     * @param serverInitializerFactory
-     */
-    public void setServerInitializerFactory(ServerInitializerFactory serverInitializerFactory) {
-        getConfigurationOrCreate().setServerInitializerFactory(serverInitializerFactory);
-    }
-
-    public NettyServerBootstrapFactory getNettyServerBootstrapFactory() {
-        return getConfigurationOrCreate().getNettyServerBootstrapFactory();
-    }
-
-    public long getRequestTimeout() {
-        return getConfigurationOrCreate().getRequestTimeout();
-    }
-
-    /**
-     * To use a custom NettyServerBootstrapFactory
-     * @param nettyServerBootstrapFactory
-     */
-    public void setNettyServerBootstrapFactory(NettyServerBootstrapFactory nettyServerBootstrapFactory) {
-        getConfigurationOrCreate().setNettyServerBootstrapFactory(nettyServerBootstrapFactory);
-    }
-
-    public Map<String, Object> getOptions() {
-        return getConfigurationOrCreate().getOptions();
-    }
-
-    /**
-     * Allows to use a timeout for the Netty producer when calling a remote server.
-     * By default no timeout is in use. The value is in milli seconds, so eg 30000 is 30 seconds.
-     * The requestTimeout is using Netty's ReadTimeoutHandler to trigger the timeout.
-     * @param requestTimeout
-     */
-    public void setRequestTimeout(long requestTimeout) {
-        getConfigurationOrCreate().setRequestTimeout(requestTimeout);
-    }
-
-    public boolean isSync() {
-        return getConfigurationOrCreate().isSync();
-    }
-
-    /**
-     * Setting to set endpoint as one-way or request-response
-     * @param sync
-     */
-    public void setSync(boolean sync) {
-        getConfigurationOrCreate().setSync(sync);
-    }
-
-    /**
-     * Allows to configure additional netty options using "option." as prefix.
-     * For example "option.child.keepAlive=false" to set the netty option "child.keepAlive=false". See the Netty documentation for possible options that can be used.
-     * @param options
-     */
-    public void setOptions(Map<String, Object> options) {
-        getConfigurationOrCreate().setOptions(options);
-    }
-
-    public boolean isTextline() {
-        return getConfigurationOrCreate().isTextline();
-    }
-
-    public boolean isNativeTransport() {
-        return getConfigurationOrCreate().isNativeTransport();
-    }
-
-    /**
-     * Only used for TCP. If no codec is specified, you can use this flag to indicate a text line based codec;
-     * if not specified or the value is false, then Object Serialization is assumed over TCP.
-     * @param textline
-     */
-    public void setTextline(boolean textline) {
-        getConfigurationOrCreate().setTextline(textline);
-    }
-
-    public int getDecoderMaxLineLength() {
-        return getConfigurationOrCreate().getDecoderMaxLineLength();
-    }
-
-    /**
-     * Whether to use native transport instead of NIO. Native transport takes advantage of the host operating system and is only supported on some platforms.
-     * You need to add the netty JAR for the host operating system you are using. See more details at: http://netty.io/wiki/native-transports.html
-     * @param nativeTransport
-     */
-    public void setNativeTransport(boolean nativeTransport) {
-        getConfigurationOrCreate().setNativeTransport(nativeTransport);
-    }
-
-    /**
-     * The max line length to use for the textline codec.
-     * @param decoderMaxLineLength
-     */
-    public void setDecoderMaxLineLength(int decoderMaxLineLength) {
-        getConfigurationOrCreate().setDecoderMaxLineLength(decoderMaxLineLength);
-    }
-
-    public EventLoopGroup getBossGroup() {
-        return getConfigurationOrCreate().getBossGroup();
-    }
-
-    public TextLineDelimiter getDelimiter() {
-        return getConfigurationOrCreate().getDelimiter();
-    }
-
-    /**
-     * Set the BossGroup which could be used for handling the new connection of the server side across the NettyEndpoint
-     * @param bossGroup
-     */
-    public void setBossGroup(EventLoopGroup bossGroup) {
-        getConfigurationOrCreate().setBossGroup(bossGroup);
-    }
-
-    /**
-     * The delimiter to use for the textline codec. Possible values are LINE and NULL.
-     * @param delimiter
-     */
-    public void setDelimiter(TextLineDelimiter delimiter) {
-        getConfigurationOrCreate().setDelimiter(delimiter);
-    }
-
-    public EventLoopGroup getWorkerGroup() {
-        return getConfigurationOrCreate().getWorkerGroup();
-    }
-
-    public boolean isAutoAppendDelimiter() {
-        return getConfigurationOrCreate().isAutoAppendDelimiter();
-    }
-
-    /**
-     * Whether or not to auto append missing end delimiter when sending using the textline codec.
-     * @param autoAppendDelimiter
-     */
-    public void setAutoAppendDelimiter(boolean autoAppendDelimiter) {
-        getConfigurationOrCreate().setAutoAppendDelimiter(autoAppendDelimiter);
-    }
-
-    /**
-     * To use a explicit EventLoopGroup as the boss thread pool.
-     * For example to share a thread pool with multiple consumers. By default each consumer has their own boss pool with 1 core thread.
-     * @param workerGroup
-     */
-    public void setWorkerGroup(EventLoopGroup workerGroup) {
-        getConfigurationOrCreate().setWorkerGroup(workerGroup);
-    }
-
-    public String getEncoding() {
-        return getConfigurationOrCreate().getEncoding();
-    }
-
-    public ChannelGroup getChannelGroup() {
-        return getConfigurationOrCreate().getChannelGroup();
-    }
-
-    /**
-     * To use a explicit ChannelGroup.
-     * @param channelGroup
-     */
-    public void setChannelGroup(ChannelGroup channelGroup) {
-        getConfigurationOrCreate().setChannelGroup(channelGroup);
-    }
-
-    /**
-     * The encoding (a charset name) to use for the textline codec. If not provided, Camel will use the JVM default Charset.
-     * @param encoding
-     */
-    public void setEncoding(String encoding) {
-        getConfigurationOrCreate().setEncoding(encoding);
-    }
-
-    public String getNetworkInterface() {
-        return getConfigurationOrCreate().getNetworkInterface();
-    }
-
-    public List<ChannelHandler> getDecoders() {
-        return getConfigurationOrCreate().getDecoders();
-    }
-
-    /**
-     * When using UDP then this option can be used to specify a network interface by its name, such as eth0 to join a multicast group.
-     * @param networkInterface
-     */
-    public void setNetworkInterface(String networkInterface) {
-        getConfigurationOrCreate().setNetworkInterface(networkInterface);
-    }
-
-    /**
-     * A list of decoders to be used.
-     * You can use a String which have values separated by comma, and have the values be looked up in the Registry.
-     * Just remember to prefix the value with # so Camel knows it should lookup.
-     * @param decoders
-     */
-    public void setDecoders(List<ChannelHandler> decoders) {
-        getConfigurationOrCreate().setDecoders(decoders);
-    }
-
-    public String getEnabledProtocols() {
-        return getConfigurationOrCreate().getEnabledProtocols();
-    }
-
-    public List<ChannelHandler> getEncoders() {
-        return getConfigurationOrCreate().getEncoders();
-    }
-
-    /**
-     * Which protocols to enable when using SSL
-     * @param enabledProtocols
-     */
-    public void setEnabledProtocols(String enabledProtocols) {
-        getConfigurationOrCreate().setEnabledProtocols(enabledProtocols);
-    }
-
-    /**
-     * Used only in clientMode in consumer, the consumer will attempt to reconnect on disconnection if this is enabled
-     */
-    public boolean isReconnect() {
-        return getConfigurationOrCreate().isReconnect();
-    }
-
-    /**
-     * A list of encoders to be used. You can use a String which have values separated by comma, and have the values be looked up in the Registry.
-     * Just remember to prefix the value with # so Camel knows it should lookup.
-     * @param encoders
-     */
-    public void setEncoders(List<ChannelHandler> encoders) {
-        getConfigurationOrCreate().setEncoders(encoders);
-    }
-
-    public void setReconnect(boolean reconnect) {
-        getConfigurationOrCreate().setReconnect(reconnect);
-    }
-
-    public ChannelHandler getEncoder() {
-        return getConfigurationOrCreate().getEncoder();
-    }
-
-    /**
-     * Used if reconnect and clientMode is enabled. The interval in milli seconds to attempt reconnection
-     */
-    public int getReconnectInterval() {
-        return getConfigurationOrCreate().getReconnectInterval();
-    }
-
-    /**
-     * A custom ChannelHandler class that can be used to perform special marshalling of outbound payloads.
-     * @param encoder
-     */
-    public void setEncoder(ChannelHandler encoder) {
-        getConfigurationOrCreate().setEncoder(encoder);
-    }
-
-    public void setReconnectInterval(int reconnectInterval) {
-        getConfigurationOrCreate().setReconnectInterval(reconnectInterval);
-    }
-
-    public ChannelHandler getDecoder() {
-        return getConfigurationOrCreate().getDecoder();
-    }
-
-    /**
-     * A custom ChannelHandler class that can be used to perform special marshalling of inbound payloads.
-     * @param decoder
-     */
-    public void setDecoder(ChannelHandler decoder) {
-        getConfigurationOrCreate().setDecoder(decoder);
-    }
-
-    public boolean isDisconnect() {
-        return getConfigurationOrCreate().isDisconnect();
-    }
-
-    /**
-     * Whether or not to disconnect(close) from Netty Channel right after use. Can be used for both consumer and producer.
-     * @param disconnect
-     */
-    public void setDisconnect(boolean disconnect) {
-        getConfigurationOrCreate().setDisconnect(disconnect);
-    }
-
-    public boolean isLazyChannelCreation() {
-        return getConfigurationOrCreate().isLazyChannelCreation();
-    }
-
-    /**
-     * Channels can be lazily created to avoid exceptions, if the remote server is not up and running when the Camel producer is started.
-     * @param lazyChannelCreation
-     */
-    public void setLazyChannelCreation(boolean lazyChannelCreation) {
-        getConfigurationOrCreate().setLazyChannelCreation(lazyChannelCreation);
-    }
-
-    public boolean isTransferExchange() {
-        return getConfigurationOrCreate().isTransferExchange();
-    }
-
-    /**
-     * Only used for TCP. You can transfer the exchange over the wire instead of just the body.
-     * The following fields are transferred: In body, Out body, fault body, In headers, Out headers, fault headers,
-     * exchange properties, exchange exception.
-     * This requires that the objects are serializable. Camel will exclude any non-serializable objects and log it at WARN level.
-     * @param transferExchange
-     */
-    public void setTransferExchange(boolean transferExchange) {
-        getConfigurationOrCreate().setTransferExchange(transferExchange);
-    }
-
-    public boolean isDisconnectOnNoReply() {
-        return getConfigurationOrCreate().isDisconnectOnNoReply();
-    }
-
-    /**
-     * If sync is enabled then this option dictates NettyConsumer if it should disconnect where there is no reply to send back.
-     * @param disconnectOnNoReply
-     */
-    public void setDisconnectOnNoReply(boolean disconnectOnNoReply) {
-        getConfigurationOrCreate().setDisconnectOnNoReply(disconnectOnNoReply);
-    }
-
-    public LoggingLevel getNoReplyLogLevel() {
-        return getConfigurationOrCreate().getNoReplyLogLevel();
-    }
-
-    /**
-     * If sync is enabled this option dictates NettyConsumer which logging level to use when logging a there is no reply to send back.
-     * @param noReplyLogLevel
-     */
-    public void setNoReplyLogLevel(LoggingLevel noReplyLogLevel) {
-        getConfigurationOrCreate().setNoReplyLogLevel(noReplyLogLevel);
-    }
-
-    public LoggingLevel getServerExceptionCaughtLogLevel() {
-        return getConfigurationOrCreate().getServerExceptionCaughtLogLevel();
-    }
-
-    /**
-     * If the server (NettyConsumer) catches an exception then its logged using this logging level.
-     * @param serverExceptionCaughtLogLevel
-     */
-    public void setServerExceptionCaughtLogLevel(LoggingLevel serverExceptionCaughtLogLevel) {
-        getConfigurationOrCreate().setServerExceptionCaughtLogLevel(serverExceptionCaughtLogLevel);
-    }
-
-    public LoggingLevel getServerClosedChannelExceptionCaughtLogLevel() {
-        return getConfigurationOrCreate().getServerClosedChannelExceptionCaughtLogLevel();
-    }
-
-    /**
-     * If the server (NettyConsumer) catches an java.nio.channels.ClosedChannelException then its logged using this logging level.
-     * This is used to avoid logging the closed channel exceptions, as clients can disconnect abruptly and then cause a flood of closed exceptions in the Netty server.
-     * @param serverClosedChannelExceptionCaughtLogLevel
-     */
-    public void setServerClosedChannelExceptionCaughtLogLevel(LoggingLevel serverClosedChannelExceptionCaughtLogLevel) {
-        getConfigurationOrCreate().setServerClosedChannelExceptionCaughtLogLevel(serverClosedChannelExceptionCaughtLogLevel);
-    }
-
-    public boolean isAllowDefaultCodec() {
-        return getConfigurationOrCreate().isAllowDefaultCodec();
-    }
-
-    /**
-     * The netty component installs a default codec if both, encoder/deocder is null and textline is false.
-     * Setting allowDefaultCodec to false prevents the netty component from installing a default codec as the first element in the filter chain.
-     * @param allowDefaultCodec
-     */
-    public void setAllowDefaultCodec(boolean allowDefaultCodec) {
-        getConfigurationOrCreate().setAllowDefaultCodec(allowDefaultCodec);
-    }
-
-    public ClientInitializerFactory getClientInitializerFactory() {
-        return getConfigurationOrCreate().getClientInitializerFactory();
-    }
-
-    /**
-     * To use a custom ClientInitializerFactory
-     * @param clientInitializerFactory
-     */
-    public void setClientInitializerFactory(ClientInitializerFactory clientInitializerFactory) {
-        getConfigurationOrCreate().setClientInitializerFactory(clientInitializerFactory);
-    }
-
-    public boolean isUsingExecutorService() {
-        return getConfigurationOrCreate().isUsingExecutorService();
-    }
-
-    /**
-     * Whether to use ordered thread pool, to ensure events are processed orderly on the same channel.
-     * @param usingExecutorService
-     */
-    public void setUsingExecutorService(boolean usingExecutorService) {
-        getConfigurationOrCreate().setUsingExecutorService(usingExecutorService);
-    }
-
-    public int getProducerPoolMaxActive() {
-        return getConfigurationOrCreate().getProducerPoolMaxActive();
-    }
-
-    /**
-     * Sets the cap on the number of objects that can be allocated by the pool
-     * (checked out to clients, or idle awaiting checkout) at a given time. Use a negative value for no limit.
-     * @param producerPoolMaxActive
-     */
-    public void setProducerPoolMaxActive(int producerPoolMaxActive) {
-        getConfigurationOrCreate().setProducerPoolMaxActive(producerPoolMaxActive);
-    }
-
-    public int getProducerPoolMinIdle() {
-        return getConfigurationOrCreate().getProducerPoolMinIdle();
-    }
-
-    /**
-     * Sets the minimum number of instances allowed in the producer pool before the evictor thread (if active) spawns new objects.
-     * @param producerPoolMinIdle
-     */
-    public void setProducerPoolMinIdle(int producerPoolMinIdle) {
-        getConfigurationOrCreate().setProducerPoolMinIdle(producerPoolMinIdle);
-    }
-
-    public int getProducerPoolMaxIdle() {
-        return getConfigurationOrCreate().getProducerPoolMaxIdle();
-    }
-
-    /**
-     * Sets the cap on the number of "idle" instances in the pool.
-     * @param producerPoolMaxIdle
-     */
-    public void setProducerPoolMaxIdle(int producerPoolMaxIdle) {
-        getConfigurationOrCreate().setProducerPoolMaxIdle(producerPoolMaxIdle);
-    }
-
-    public long getProducerPoolMinEvictableIdle() {
-        return getConfigurationOrCreate().getProducerPoolMinEvictableIdle();
-    }
-
-    /**
-     * Sets the minimum amount of time (value in millis) an object may sit idle in the pool before it is eligible for eviction by the idle object evictor.
-     * @param producerPoolMinEvictableIdle
-     */
-    public void setProducerPoolMinEvictableIdle(long producerPoolMinEvictableIdle) {
-        getConfigurationOrCreate().setProducerPoolMinEvictableIdle(producerPoolMinEvictableIdle);
-    }
-
-    public boolean isProducerPoolEnabled() {
-        return getConfigurationOrCreate().isProducerPoolEnabled();
-    }
-
-    /**
-     * Whether producer pool is enabled or not.
-     * Important: Do not turn this off, as the pooling is needed for handling concurrency and reliable request/reply.
-     * @param producerPoolEnabled
-     */
-    public void setProducerPoolEnabled(boolean producerPoolEnabled) {
-        getConfigurationOrCreate().setProducerPoolEnabled(producerPoolEnabled);
-    }
-
-    public boolean isUdpConnectionlessSending() {
-        return getConfigurationOrCreate().isUdpConnectionlessSending();
-    }
-
-    /**
-     * This option supports connection less udp sending which is a real fire and forget.
-     * A connected udp send receive the PortUnreachableException if no one is listen on the receiving port.
-     * @param udpConnectionlessSending
-     */
-    public void setUdpConnectionlessSending(boolean udpConnectionlessSending) {
-        getConfigurationOrCreate().setUdpConnectionlessSending(udpConnectionlessSending);
-    }
-
-    public boolean isClientMode() {
-        return getConfigurationOrCreate().isClientMode();
-    }
-
-    /**
-     * If the clientMode is true, netty consumer will connect the address as a TCP client.
-     * @param clientMode
-     */
-    public void setClientMode(boolean clientMode) {
-        getConfigurationOrCreate().setClientMode(clientMode);
-    }
-
-    public boolean isUseByteBuf() {
-        return getConfigurationOrCreate().isUseByteBuf();
-    }
-
-    /**
-     * If the useByteBuf is true, netty producer will turn the message body into {@link ByteBuf} before sending it out.
-     * @param useByteBuf
-     */
-    public void setUseByteBuf(boolean useByteBuf) {
-        getConfigurationOrCreate().setUseByteBuf(useByteBuf);
-    }
-
-    public boolean isUdpByteArrayCodec() {
-        return getConfigurationOrCreate().isUdpByteArrayCodec();
-    }
-
-    /**
-     * For UDP only. If enabled the using byte array codec instead of Java serialization protocol.
-     * @param udpByteArrayCodec
-     */
-    public void setUdpByteArrayCodec(boolean udpByteArrayCodec) {
-        getConfigurationOrCreate().setUdpByteArrayCodec(udpByteArrayCodec);
-    }
-
-    public boolean isReuseChannel() {
-        return getConfigurationOrCreate().isReuseChannel();
-    }
-
-    /**
-     * This option allows producers to reuse the same Netty {@link Channel} for the lifecycle of processing the {@link Exchange}.
-     * This is useable if you need to call a server multiple times in a Camel route and want to use the same network connection.
-     * When using this the channel is not returned to the connection pool until the {@link Exchange} is done; or disconnected
-     * if the disconnect option is set to true.
-     * <p/>
-     * The reused {@link Channel} is stored on the {@link Exchange} as an exchange property with the key {@link NettyConstants#NETTY_CHANNEL}
-     * which allows you to obtain the channel during routing and use it as well.
-     * @param reuseChannel
-     */
-    public void setReuseChannel(boolean reuseChannel) {
-        getConfigurationOrCreate().setReuseChannel(reuseChannel);
-    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/a04fb15b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java
----------------------------------------------------------------------
diff --git a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java
index ce950fd..35394df 100644
--- a/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java
+++ b/components/camel-olingo2/camel-olingo2-component/src/main/java/org/apache/camel/component/olingo2/Olingo2Component.java
@@ -93,7 +93,7 @@ public class Olingo2Component extends AbstractApiComponent<Olingo2ApiName, Oling
     }
 
     /**
-     * To use the shared configuration. Properties of the shared configuration can also be set individually.
+     * To use the shared configuration
      */
     @Override
     public void setConfiguration(Olingo2Configuration configuration) {
@@ -182,132 +182,4 @@ public class Olingo2Component extends AbstractApiComponent<Olingo2ApiName, Oling
             apiProxy.close();
         }
     }
-
-    private Olingo2Configuration getConfigurationOrCreate() {
-        if (this.getConfiguration() == null) {
-            this.setConfiguration(new Olingo2Configuration());
-        }
-        return this.getConfiguration();
-    }
-
-    public Olingo2ApiName getApiName() {
-        return getConfigurationOrCreate().getApiName();
-    }
-
-    /**
-     * What kind of operation to perform
-     * @param apiName
-     */
-    public void setApiName(Olingo2ApiName apiName) {
-        getConfigurationOrCreate().setApiName(apiName);
-    }
-
-    public String getMethodName() {
-        return getConfigurationOrCreate().getMethodName();
-    }
-
-    /**
-     * What sub operation to use for the selected operation
-     * @param methodName
-     */
-    public void setMethodName(String methodName) {
-        getConfigurationOrCreate().setMethodName(methodName);
-    }
-
-    public String getServiceUri() {
-        return getConfigurationOrCreate().getServiceUri();
-    }
-
-    /**
-     * Target OData service base URI, e.g. http://services.odata.org/OData/OData.svc
-     * @param serviceUri
-     */
-    public void setServiceUri(String serviceUri) {
-        getConfigurationOrCreate().setServiceUri(serviceUri);
-    }
-
-    public String getContentType() {
-        return getConfigurationOrCreate().getContentType();
-    }
-
-    /**
-     * Content-Type header value can be used to specify JSON or XML message format, defaults to application/json;charset=utf-8
-     * @param contentType
-     */
-    public void setContentType(String contentType) {
-        getConfigurationOrCreate().setContentType(contentType);
-    }
-
-    public Map<String, String> getHttpHeaders() {
-        return getConfigurationOrCreate().getHttpHeaders();
-    }
-
-    /**
-     * Custom HTTP headers to inject into every request, this could include OAuth tokens, etc.
-     * @param httpHeaders
-     */
-    public void setHttpHeaders(Map<String, String> httpHeaders) {
-        getConfigurationOrCreate().setHttpHeaders(httpHeaders);
-    }
-
-    public int getConnectTimeout() {
-        return getConfigurationOrCreate().getConnectTimeout();
-    }
-
-    /**
-     * HTTP connection creation timeout in milliseconds, defaults to 30,000 (30 seconds)
-     * @param connectTimeout
-     */
-    public void setConnectTimeout(int connectTimeout) {
-        getConfigurationOrCreate().setConnectTimeout(connectTimeout);
-    }
-
-    public int getSocketTimeout() {
-        return getConfigurationOrCreate().getSocketTimeout();
-    }
-
-    /**
-     * HTTP request timeout in milliseconds, defaults to 30,000 (30 seconds)
-     * @param socketTimeout
-     */
-    public void setSocketTimeout(int socketTimeout) {
-        getConfigurationOrCreate().setSocketTimeout(socketTimeout);
-    }
-
-    public HttpHost getProxy() {
-        return getConfigurationOrCreate().getProxy();
-    }
-
-    /**
-     * HTTP proxy server configuration
-     * @param proxy
-     */
-    public void setProxy(HttpHost proxy) {
-        getConfigurationOrCreate().setProxy(proxy);
-    }
-
-    public SSLContextParameters getSslContextParameters() {
-        return getConfigurationOrCreate().getSslContextParameters();
-    }
-
-    /**
-     * To configure security using SSLContextParameters
-     * @param sslContextParameters
-     */
-    public void setSslContextParameters(SSLContextParameters sslContextParameters) {
-        getConfigurationOrCreate().setSslContextParameters(sslContextParameters);
-    }
-
-    public HttpAsyncClientBuilder getHttpAsyncClientBuilder() {
-        return getConfigurationOrCreate().getHttpAsyncClientBuilder();
-    }
-
-    /**
-     * Custom HTTP async client builder for more complex HTTP client configuration, overrides connectionTimeout, socketTimeout, proxy and sslContext.
-     * Note that a socketTimeout MUST be specified in the builder, otherwise OData requests could block indefinitely
-     * @param httpAsyncClientBuilder
-     */
-    public void setHttpAsyncClientBuilder(HttpAsyncClientBuilder httpAsyncClientBuilder) {
-        getConfigurationOrCreate().setHttpAsyncClientBuilder(httpAsyncClientBuilder);
-    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/a04fb15b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceComponent.java b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceComponent.java
index 7b7b81a..61357ea 100644
--- a/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceComponent.java
+++ b/components/camel-salesforce/camel-salesforce-component/src/main/java/org/apache/camel/component/salesforce/SalesforceComponent.java
@@ -28,21 +28,14 @@ import java.util.Set;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
 
-import com.fasterxml.jackson.databind.ObjectMapper;
-
 import org.apache.camel.CamelContext;
 import org.apache.camel.ComponentConfiguration;
 import org.apache.camel.Endpoint;
 import org.apache.camel.component.salesforce.api.SalesforceException;
 import org.apache.camel.component.salesforce.api.dto.AbstractQueryRecordsBase;
 import org.apache.camel.component.salesforce.api.dto.AbstractSObjectBase;
-import org.apache.camel.component.salesforce.api.dto.analytics.reports.ReportMetadata;
-import org.apache.camel.component.salesforce.api.dto.bulk.ContentType;
 import org.apache.camel.component.salesforce.internal.OperationName;
-import org.apache.camel.component.salesforce.internal.PayloadFormat;
 import org.apache.camel.component.salesforce.internal.SalesforceSession;
-import org.apache.camel.component.salesforce.internal.dto.NotifyForFieldsEnum;
-import org.apache.camel.component.salesforce.internal.dto.NotifyForOperationsEnum;
 import org.apache.camel.component.salesforce.internal.streaming.SubscriptionHelper;
 import org.apache.camel.impl.UriEndpointComponent;
 import org.apache.camel.spi.EndpointCompleter;
@@ -390,7 +383,7 @@ public class SalesforceComponent extends UriEndpointComponent implements Endpoin
     }
 
     /**
-     * To use the shared SalesforceLoginConfig as login configuration. Properties of the shared configuration can also be set individually.
+     * To use the shared SalesforceLoginConfig as login configuration
      */
     public void setLoginConfig(SalesforceLoginConfig loginConfig) {
         this.loginConfig = loginConfig;
@@ -401,7 +394,7 @@ public class SalesforceComponent extends UriEndpointComponent implements Endpoin
     }
 
     /**
-     * To use the shared SalesforceEndpointConfig as configuration. Properties of the shared configuration can also be set individually.
+     * To use the shared SalesforceLoginConfig as configuration
      */
     public void setConfig(SalesforceEndpointConfig config) {
         this.config = config;
@@ -578,510 +571,4 @@ public class SalesforceComponent extends UriEndpointComponent implements Endpoin
     public Map<String, Class<?>> getClassMap() {
         return classMap;
     }
-
-    private SalesforceLoginConfig getLoginConfigOrCreate() {
-        if (this.getLoginConfig() == null) {
-            this.setLoginConfig(new SalesforceLoginConfig());
-        }
-        return this.getLoginConfig();
-    }
-
-    private SalesforceEndpointConfig getConfigOrCreate() {
-        if (this.getConfig() == null) {
-            this.setConfig(new SalesforceEndpointConfig());
-        }
-        return this.getConfig();
-    }
-
-    public String getLoginUrl() {
-        return getLoginConfigOrCreate().getLoginUrl();
-    }
-
-    /**
-     * Salesforce login URL, defaults to https://login.salesforce.com
-     * @param loginUrl
-     */
-    public void setLoginUrl(String loginUrl) {
-        getLoginConfigOrCreate().setLoginUrl(loginUrl);
-    }
-
-    public String getClientId() {
-        return getLoginConfigOrCreate().getClientId();
-    }
-
-    /**
-     * Salesforce connected application Consumer Key
-     * @param clientId
-     */
-    public void setClientId(String clientId) {
-        getLoginConfigOrCreate().setClientId(clientId);
-    }
-
-    public String getClientSecret() {
-        return getLoginConfigOrCreate().getClientSecret();
-    }
-
-    /**
-     * Salesforce connected application Consumer Secret
-     * @param clientSecret
-     */
-    public void setClientSecret(String clientSecret) {
-        getLoginConfigOrCreate().setClientSecret(clientSecret);
-    }
-
-    public String getUserName() {
-        return getLoginConfigOrCreate().getUserName();
-    }
-
-    /**
-     * Salesforce account user name
-     * @param userName
-     */
-    public void setUserName(String userName) {
-        getLoginConfigOrCreate().setUserName(userName);
-    }
-
-    public String getPassword() {
-        return getLoginConfigOrCreate().getPassword();
-    }
-
-    /**
-     * Salesforce account password
-     * @param password
-     */
-    public void setPassword(String password) {
-        getLoginConfigOrCreate().setPassword(password);
-    }
-
-    public boolean isLazyLogin() {
-        return getLoginConfigOrCreate().isLazyLogin();
-    }
-
-    /**
-     * Flag to enable/disable lazy OAuth, default is false. When enabled, OAuth token retrieval or generation is not done until the first API call
-     * @param lazyLogin
-     */
-    public void setLazyLogin(boolean lazyLogin) {
-        getLoginConfigOrCreate().setLazyLogin(lazyLogin);
-    }
-
-    public PayloadFormat getFormat() {
-        return getConfigOrCreate().getFormat();
-    }
-
-    /**
-     * Payload format to use for Salesforce API calls, either JSON or XML, defaults to JSON
-     * @param format
-     */
-    public void setFormat(PayloadFormat format) {
-        getConfigOrCreate().setFormat(format);
-    }
-
-    public String getApiVersion() {
-        return getConfigOrCreate().getApiVersion();
-    }
-
-    /**
-     * Salesforce API version, defaults to SalesforceEndpointConfig.DEFAULT_VERSION
-     * @param apiVersion
-     */
-    public void setApiVersion(String apiVersion) {
-        getConfigOrCreate().setApiVersion(apiVersion);
-    }
-
-    public String getSObjectName() {
-        return getConfigOrCreate().getSObjectName();
-    }
-
-    /**
-     * SObject name if required or supported by API
-     * @param sObjectName
-     */
-    public void setSObjectName(String sObjectName) {
-        getConfigOrCreate().setSObjectName(sObjectName);
-    }
-
-    public String getSObjectId() {
-        return getConfigOrCreate().getSObjectId();
-    }
-
-    /**
-     * SObject ID if required by API
-     * @param sObjectId
-     */
-    public void setSObjectId(String sObjectId) {
-        getConfigOrCreate().setSObjectId(sObjectId);
-    }
-
-    public String getSObjectFields() {
-        return getConfigOrCreate().getSObjectFields();
-    }
-
-    /**
-     * SObject fields to retrieve
-     * @param sObjectFields
-     */
-    public void setSObjectFields(String sObjectFields) {
-        getConfigOrCreate().setSObjectFields(sObjectFields);
-    }
-
-    public String getSObjectIdName() {
-        return getConfigOrCreate().getSObjectIdName();
-    }
-
-    /**
-     * SObject external ID field name
-     * @param sObjectIdName
-     */
-    public void setSObjectIdName(String sObjectIdName) {
-        getConfigOrCreate().setSObjectIdName(sObjectIdName);
-    }
-
-    public String getSObjectIdValue() {
-        return getConfigOrCreate().getSObjectIdValue();
-    }
-
-    /**
-     * SObject external ID field value
-     * @param sObjectIdValue
-     */
-    public void setSObjectIdValue(String sObjectIdValue) {
-        getConfigOrCreate().setSObjectIdValue(sObjectIdValue);
-    }
-
-    public String getSObjectBlobFieldName() {
-        return getConfigOrCreate().getSObjectBlobFieldName();
-    }
-
-    /**
-     * SObject blob field name
-     * @param sObjectBlobFieldName
-     */
-    public void setSObjectBlobFieldName(String sObjectBlobFieldName) {
-        getConfigOrCreate().setSObjectBlobFieldName(sObjectBlobFieldName);
-    }
-
-    public String getSObjectClass() {
-        return getConfigOrCreate().getSObjectClass();
-    }
-
-    /**
-     * Fully qualified SObject class name, usually generated using camel-salesforce-maven-plugin
-     * @param sObjectClass
-     */
-    public void setSObjectClass(String sObjectClass) {
-        getConfigOrCreate().setSObjectClass(sObjectClass);
-    }
-
-    public String getSObjectQuery() {
-        return getConfigOrCreate().getSObjectQuery();
-    }
-
-    /**
-     * Salesforce SOQL query string
-     * @param sObjectQuery
-     */
-    public void setSObjectQuery(String sObjectQuery) {
-        getConfigOrCreate().setSObjectQuery(sObjectQuery);
-    }
-
-    public String getSObjectSearch() {
-        return getConfigOrCreate().getSObjectSearch();
-    }
-
-    /**
-     * Salesforce SOSL search string
-     * @param sObjectSearch
-     */
-    public void setSObjectSearch(String sObjectSearch) {
-        getConfigOrCreate().setSObjectSearch(sObjectSearch);
-    }
-
-    public String getApexMethod() {
-        return getConfigOrCreate().getApexMethod();
-    }
-
-    /**
-     * APEX method name
-     * @param apexMethod
-     */
-    public void setApexMethod(String apexMethod) {
-        getConfigOrCreate().setApexMethod(apexMethod);
-    }
-
-    public String getApexUrl() {
-        return getConfigOrCreate().getApexUrl();
-    }
-
-    /**
-     * APEX method URL
-     * @param apexUrl
-     */
-    public void setApexUrl(String apexUrl) {
-        getConfigOrCreate().setApexUrl(apexUrl);
-    }
-
-    public Map<String, Object> getApexQueryParams() {
-        return getConfigOrCreate().getApexQueryParams();
-    }
-
-    /**
-     * Query params for APEX method
-     * @param apexQueryParams
-     */
-    public void setApexQueryParams(Map<String, Object> apexQueryParams) {
-        getConfigOrCreate().setApexQueryParams(apexQueryParams);
-    }
-
-    public ContentType getContentType() {
-        return getConfigOrCreate().getContentType();
-    }
-
-    /**
-     * Bulk API content type, one of XML, CSV, ZIP_XML, ZIP_CSV
-     * @param contentType
-     */
-    public void setContentType(ContentType contentType) {
-        getConfigOrCreate().setContentType(contentType);
-    }
-
-    public String getJobId() {
-        return getConfigOrCreate().getJobId();
-    }
-
-    /**
-     * Bulk API Job ID
-     * @param jobId
-     */
-    public void setJobId(String jobId) {
-        getConfigOrCreate().setJobId(jobId);
-    }
-
-    public String getBatchId() {
-        return getConfigOrCreate().getBatchId();
-    }
-
-    /**
-     * Bulk API Batch ID
-     * @param batchId
-     */
-    public void setBatchId(String batchId) {
-        getConfigOrCreate().setBatchId(batchId);
-    }
-
-    public String getResultId() {
-        return getConfigOrCreate().getResultId();
-    }
-
-    /**
-     * Bulk API Result ID
-     * @param resultId
-     */
-    public void setResultId(String resultId) {
-        getConfigOrCreate().setResultId(resultId);
-    }
-
-    public boolean isUpdateTopic() {
-        return getConfigOrCreate().isUpdateTopic();
-    }
-
-    /**
-     * Whether to update an existing Push Topic when using the Streaming API, defaults to false
-     * @param updateTopic
-     */
-    public void setUpdateTopic(boolean updateTopic) {
-        getConfigOrCreate().setUpdateTopic(updateTopic);
-    }
-
-    public NotifyForFieldsEnum getNotifyForFields() {
-        return getConfigOrCreate().getNotifyForFields();
-    }
-
-    /**
-     * Notify for fields, options are ALL, REFERENCED, SELECT, WHERE
-     * @param notifyForFields
-     */
-    public void setNotifyForFields(NotifyForFieldsEnum notifyForFields) {
-        getConfigOrCreate().setNotifyForFields(notifyForFields);
-    }
-
-    public NotifyForOperationsEnum getNotifyForOperations() {
-        return getConfigOrCreate().getNotifyForOperations();
-    }
-
-    /**
-     * Notify for operations, options are ALL, CREATE, EXTENDED, UPDATE (API version < 29.0)
-     * @param notifyForOperations
-     */
-    public void setNotifyForOperations(NotifyForOperationsEnum notifyForOperations) {
-        getConfigOrCreate().setNotifyForOperations(notifyForOperations);
-    }
-
-    public Boolean getNotifyForOperationCreate() {
-        return getConfigOrCreate().getNotifyForOperationCreate();
-    }
-
-    /**
-     * Notify for create operation, defaults to false (API version >= 29.0)
-     * @param notifyForOperationCreate
-     */
-    public void setNotifyForOperationCreate(Boolean notifyForOperationCreate) {
-        getConfigOrCreate().setNotifyForOperationCreate(notifyForOperationCreate);
-    }
-
-    public Boolean getNotifyForOperationUpdate() {
-        return getConfigOrCreate().getNotifyForOperationUpdate();
-    }
-
-    /**
-     * Notify for update operation, defaults to false (API version >= 29.0)
-     * @param notifyForOperationUpdate
-     */
-    public void setNotifyForOperationUpdate(Boolean notifyForOperationUpdate) {
-        getConfigOrCreate().setNotifyForOperationUpdate(notifyForOperationUpdate);
-    }
-
-    public Boolean getNotifyForOperationDelete() {
-        return getConfigOrCreate().getNotifyForOperationDelete();
-    }
-
-    /**
-     * Notify for delete operation, defaults to false (API version >= 29.0)
-     * @param notifyForOperationDelete
-     */
-    public void setNotifyForOperationDelete(Boolean notifyForOperationDelete) {
-        getConfigOrCreate().setNotifyForOperationDelete(notifyForOperationDelete);
-    }
-
-    public Boolean getNotifyForOperationUndelete() {
-        return getConfigOrCreate().getNotifyForOperationUndelete();
-    }
-
-    /**
-     * Notify for un-delete operation, defaults to false (API version >= 29.0)
-     * @param notifyForOperationUndelete
-     */
-    public void setNotifyForOperationUndelete(Boolean notifyForOperationUndelete) {
-        getConfigOrCreate().setNotifyForOperationUndelete(notifyForOperationUndelete);
-    }
-
-    public String getReportId() {
-        return getConfigOrCreate().getReportId();
-    }
-
-    /**
-     * Salesforce1 Analytics report Id
-     * @param reportId
-     */
-    public void setReportId(String reportId) {
-        getConfigOrCreate().setReportId(reportId);
-    }
-
-    public Boolean getIncludeDetails() {
-        return getConfigOrCreate().getIncludeDetails();
-    }
-
-    /**
-     * Include details in Salesforce1 Analytics report, defaults to false.
-     * @param includeDetails
-     */
-    public void setIncludeDetails(Boolean includeDetails) {
-        getConfigOrCreate().setIncludeDetails(includeDetails);
-    }
-
-    public ReportMetadata getReportMetadata() {
-        return getConfigOrCreate().getReportMetadata();
-    }
-
-    /**
-     * Salesforce1 Analytics report metadata for filtering
-     * @param reportMetadata
-     */
-    public void setReportMetadata(ReportMetadata reportMetadata) {
-        getConfigOrCreate().setReportMetadata(reportMetadata);
-    }
-
-    public String getInstanceId() {
-        return getConfigOrCreate().getInstanceId();
-    }
-
-    /**
-     * Salesforce1 Analytics report execution instance ID
-     * @param instanceId
-     */
-    public void setInstanceId(String instanceId) {
-        getConfigOrCreate().setInstanceId(instanceId);
-    }
-
-    /**
-     * Custom Jetty Http Client to use to connect to Salesforce.
-     * @param httpClient
-     */
-    public void setHttpClient(SalesforceHttpClient httpClient) {
-        getConfigOrCreate().setHttpClient(httpClient);
-    }
-
-    public SalesforceHttpClient getHttpClient() {
-        return getConfigOrCreate().getHttpClient();
-    }
-
-    public ObjectMapper getObjectMapper() {
-        return getConfigOrCreate().getObjectMapper();
-    }
-
-    /**
-     * Custom Jackson ObjectMapper to use when serializing/deserializing Salesforce objects.
-     * @param objectMapper
-     */
-    public void setObjectMapper(ObjectMapper objectMapper) {
-        getConfigOrCreate().setObjectMapper(objectMapper);
-    }
-
-    public Integer getDefaultReplayId() {
-        return getConfigOrCreate().getDefaultReplayId();
-    }
-
-    /**
-     * Default replayId setting if no value is found in {@link #initialReplayIdMap}
-     * @param defaultReplayId
-     */
-    public void setDefaultReplayId(Integer defaultReplayId) {
-        getConfigOrCreate().setDefaultReplayId(defaultReplayId);
-    }
-
-    public Map<String, Integer> getInitialReplayIdMap() {
-        return getConfigOrCreate().getInitialReplayIdMap();
-    }
-
-    /**
-     * Replay IDs to start from per channel name.
-     * @param initialReplayIdMap
-     */
-    public void setInitialReplayIdMap(Map<String, Integer> initialReplayIdMap) {
-        getConfigOrCreate().setInitialReplayIdMap(initialReplayIdMap);
-    }
-
-    public long getBackoffIncrement() {
-        return getConfigOrCreate().getBackoffIncrement();
-    }
-
-    /**
-     * Backoff interval increment for Streaming connection restart attempts for failures beyond CometD auto-reconnect.
-     * @param backoffIncrement
-     */
-    public void setBackoffIncrement(long backoffIncrement) {
-        getConfigOrCreate().setBackoffIncrement(backoffIncrement);
-    }
-
-    public long getMaxBackoff() {
-        return getConfigOrCreate().getMaxBackoff();
-    }
-
-    /**
-     * Maximum backoff interval for Streaming connection restart attempts for failures beyond CometD auto-reconnect.
-     * @param maxBackoff
-     */
-    public void setMaxBackoff(long maxBackoff) {
-        getConfigOrCreate().setMaxBackoff(maxBackoff);
-    }
 }

http://git-wip-us.apache.org/repos/asf/camel/blob/a04fb15b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java
----------------------------------------------------------------------
diff --git a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java
index 996da53..6a8eb43 100644
--- a/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java
+++ b/components/camel-smpp/src/main/java/org/apache/camel/component/smpp/SmppComponent.java
@@ -22,7 +22,6 @@ import java.util.Map;
 import org.apache.camel.CamelContext;
 import org.apache.camel.Endpoint;
 import org.apache.camel.impl.UriEndpointComponent;
-import org.jsmpp.session.SessionStateListener;
 
 /**
  * @version 
@@ -90,563 +89,9 @@ public class SmppComponent extends UriEndpointComponent {
     }
 
     /**
-     * To use the shared SmppConfiguration as configuration. Properties of the shared configuration can also be set individually.
+     * To use the shared SmppConfiguration as configuration.
      */
     public void setConfiguration(SmppConfiguration configuration) {
         this.configuration = configuration;
     }
-
-
-    private SmppConfiguration getConfigurationOrCreate() {
-        if (this.getConfiguration() == null) {
-            this.setConfiguration(new SmppConfiguration());
-        }
-        return this.getConfiguration();
-    }
-
-    public String getHost() {
-        return getConfigurationOrCreate().getHost();
-    }
-
-    /**
-     * Hostname for the SMSC server to use.
-     * @param host
-     */
-    public void setHost(String host) {
-        getConfigurationOrCreate().setHost(host);
-    }
-
-    public Integer getPort() {
-        return getConfigurationOrCreate().getPort();
-    }
-
-    /**
-     * Port number for the SMSC server to use.
-     * @param port
-     */
-    public void setPort(Integer port) {
-        getConfigurationOrCreate().setPort(port);
-    }
-
-    public String getSystemId() {
-        return getConfigurationOrCreate().getSystemId();
-    }
-
-    /**
-     * The system id (username) for connecting to SMSC server.
-     * @param systemId
-     */
-    public void setSystemId(String systemId) {
-        getConfigurationOrCreate().setSystemId(systemId);
-    }
-
-    /**
-     * The password for connecting to SMSC server.
-     */
-    public String getPassword() {
-        return getConfigurationOrCreate().getPassword();
-    }
-
-    public byte getDataCoding() {
-        return getConfigurationOrCreate().getDataCoding();
-    }
-
-    /**
-     * Defines the data coding according the SMPP 3.4 specification, section 5.2.19.
-     * Example data encodings are:
-     * <ul>
-     *     <li>0: SMSC Default Alphabet</li>
-     *     <li>3: Latin 1 (ISO-8859-1)</li>
-     *     <li>4: Octet unspecified (8-bit binary)</li>
-     *     <li>8: UCS2 (ISO/IEC-10646)</li>
-     *     <li>13: Extended Kanji JIS(X 0212-1990)</li>
-     * </ul>
-     * @param dataCoding
-     */
-    public void setDataCoding(byte dataCoding) {
-        getConfigurationOrCreate().setDataCoding(dataCoding);
-    }
-
-    public byte getAlphabet() {
-        return getConfigurationOrCreate().getAlphabet();
-    }
-
-    /**
-     * Defines encoding of data according the SMPP 3.4 specification, section 5.2.19.
-     * <ul>
-     *     <li>0: SMSC Default Alphabet
-     *     <li>4: 8 bit Alphabet</li>
-     *     <li>8: UCS2 Alphabet</li></li>
-     * </ul>
-     * @param alphabet
-     */
-    public void setAlphabet(byte alphabet) {
-        getConfigurationOrCreate().setAlphabet(alphabet);
-    }
-
-    public String getEncoding() {
-        return getConfigurationOrCreate().getEncoding();
-    }
-
-    /**
-     * Defines the encoding scheme of the short message user data.
-     * Only for SubmitSm, ReplaceSm and SubmitMulti.
-     * @param encoding
-     */
-    public void setEncoding(String encoding) {
-        getConfigurationOrCreate().setEncoding(encoding);
-    }
-
-    public void setPassword(String password) {
-        getConfigurationOrCreate().setPassword(password);
-    }
-
-    public Integer getEnquireLinkTimer() {
-        return getConfigurationOrCreate().getEnquireLinkTimer();
-    }
-
-    /**
-     * Defines the interval in milliseconds between the confidence checks.
-     * The confidence check is used to test the communication path between an ESME and an SMSC.
-     * @param enquireLinkTimer
-     */
-    public void setEnquireLinkTimer(Integer enquireLinkTimer) {
-        getConfigurationOrCreate().setEnquireLinkTimer(enquireLinkTimer);
-    }
-
-    public Integer getTransactionTimer() {
-        return getConfigurationOrCreate().getTransactionTimer();
-    }
-
-    /**
-     * Defines the maximum period of inactivity allowed after a transaction, after which
-     * an SMPP entity may assume that the session is no longer active.
-     * This timer may be active on either communicating SMPP entity (i.e. SMSC or ESME).
-     * @param transactionTimer
-     */
-    public void setTransactionTimer(Integer transactionTimer) {
-        getConfigurationOrCreate().setTransactionTimer(transactionTimer);
-    }
-
-    public String getSystemType() {
-        return getConfigurationOrCreate().getSystemType();
-    }
-
-    /**
-     * This parameter is used to categorize the type of ESME (External Short Message Entity) that is binding to the SMSC (max. 13 characters).
-     * @param systemType
-     */
-    public void setSystemType(String systemType) {
-        getConfigurationOrCreate().setSystemType(systemType);
-    }
-
-    public byte getRegisteredDelivery() {
-        return getConfigurationOrCreate().getRegisteredDelivery();
-    }
-
-    /**
-     * Is used to request an SMSC delivery receipt and/or SME originated acknowledgements. The following values are defined:
-     * <ul>
-     *     <li>0: No SMSC delivery receipt requested.</li>
-     *     <li>1: SMSC delivery receipt requested where final delivery outcome is success or failure.</li>
-     *     <li>2: SMSC delivery receipt requested where the final delivery outcome is delivery failure.</li>
-     * </ul>
-     * @param registeredDelivery
-     */
-    public void setRegisteredDelivery(byte registeredDelivery) {
-        getConfigurationOrCreate().setRegisteredDelivery(registeredDelivery);
-    }
-
-    public String getServiceType() {
-        return getConfigurationOrCreate().getServiceType();
-    }
-
-    /**
-     * The service type parameter can be used to indicate the SMS Application service associated with the message.
-     * The following generic service_types are defined:
-     * <ul>
-     *     <li>CMT: Cellular Messaging</li>
-     *     <li>CPT: Cellular Paging</li>
-     *     <li>VMN: Voice Mail Notification</li>
-     *     <li>VMA: Voice Mail Alerting</li>
-     *     <li>WAP: Wireless Application Protocol</li>
-     *     <li>USSD: Unstructured Supplementary Services Data</li>
-     * </ul>
-     * @param serviceType
-     */
-    public void setServiceType(String serviceType) {
-        getConfigurationOrCreate().setServiceType(serviceType);
-    }
-
-    public byte getSourceAddrTon() {
-        return getConfigurationOrCreate().getSourceAddrTon();
-    }
-
-    /**
-     * Defines the type of number (TON) to be used in the SME originator address parameters.
-     * The following TON values are defined:
-     * <ul>
-     *     <li>0: Unknown</li>
-     *     <li>1: International</li>
-     *     <li>2: National</li>
-     *     <li>3: Network Specific</li>
-     *     <li>4: Subscriber Number</li>
-     *     <li>5: Alphanumeric</li>
-     *     <li>6: Abbreviated</li>
-     * </ul>
-     * @param sourceAddrTon
-     */
-    public void setSourceAddrTon(byte sourceAddrTon) {
-        getConfigurationOrCreate().setSourceAddrTon(sourceAddrTon);
-    }
-
-    public byte getDestAddrTon() {
-        return getConfigurationOrCreate().getDestAddrTon();
-    }
-
-    /**
-     * Defines the type of number (TON) to be used in the SME destination address parameters.
-     * Only for SubmitSm, SubmitMulti, CancelSm and DataSm.
-     * The following TON values are defined:
-     * <ul>
-     *     <li>0: Unknown</li>
-     *     <li>1: International</li>
-     *     <li>2: National</li>
-     *     <li>3: Network Specific</li>
-     *     <li>4: Subscriber Number</li>
-     *     <li>5: Alphanumeric</li>
-     *     <li>6: Abbreviated</li>
-     * </ul>
-     * @param destAddrTon
-     */
-    public void setDestAddrTon(byte destAddrTon) {
-        getConfigurationOrCreate().setDestAddrTon(destAddrTon);
-    }
-
-    public byte getSourceAddrNpi() {
-        return getConfigurationOrCreate().getSourceAddrNpi();
-    }
-
-    /**
-     * Defines the numeric plan indicator (NPI) to be used in the SME originator address parameters.
-     * The following NPI values are defined:
-     * <ul>
-     *     <li>0: Unknown</li>
-     *     <li>1: ISDN (E163/E164)</li>
-     *     <li>2: Data (X.121)</li>
-     *     <li>3: Telex (F.69)</li>
-     *     <li>6: Land Mobile (E.212)</li>
-     *     <li>8: National</li>
-     *     <li>9: Private</li>
-     *     <li>10: ERMES</li>
-     *     <li>13: Internet (IP)</li>
-     *     <li>18: WAP Client Id (to be defined by WAP Forum)</li>
-     * </ul>
-     * @param sourceAddrNpi
-     */
-    public void setSourceAddrNpi(byte sourceAddrNpi) {
-        getConfigurationOrCreate().setSourceAddrNpi(sourceAddrNpi);
-    }
-
-    public byte getDestAddrNpi() {
-        return getConfigurationOrCreate().getDestAddrNpi();
-    }
-
-    /**
-     * Defines the type of number (TON) to be used in the SME destination address parameters.
-     * Only for SubmitSm, SubmitMulti, CancelSm and DataSm.
-     * The following NPI values are defined:
-     * <ul>
-     *     <li>0: Unknown</li>
-     *     <li>1: ISDN (E163/E164)</li>
-     *     <li>2: Data (X.121)</li>
-     *     <li>3: Telex (F.69)</li>
-     *     <li>6: Land Mobile (E.212)</li>
-     *     <li>8: National</li>
-     *     <li>9: Private</li>
-     *     <li>10: ERMES</li>
-     *     <li>13: Internet (IP)</li>
-     *     <li>18: WAP Client Id (to be defined by WAP Forum)</li>
-     * </ul>
-     * @param destAddrNpi
-     */
-    public void setDestAddrNpi(byte destAddrNpi) {
-        getConfigurationOrCreate().setDestAddrNpi(destAddrNpi);
-    }
-
-    public byte getProtocolId() {
-        return getConfigurationOrCreate().getProtocolId();
-    }
-
-    /**
-     * The protocol id
-     * @param protocolId
-     */
-    public void setProtocolId(byte protocolId) {
-        getConfigurationOrCreate().setProtocolId(protocolId);
-    }
-
-    public byte getPriorityFlag() {
-        return getConfigurationOrCreate().getPriorityFlag();
-    }
-
-    /**
-     * Allows the originating SME to assign a priority level to the short message.
-     * Only for SubmitSm and SubmitMulti.
-     * Four Priority Levels are supported:
-     * <ul>
-     *     <li>0: Level 0 (lowest) priority</li>
-     *     <li>1: Level 1 priority</li>
-     *     <li>2: Level 2 priority</li>
-     *     <li>3: Level 3 (highest) priority</li>
-     * </ul>
-     * @param priorityFlag
-     */
-    public void setPriorityFlag(byte priorityFlag) {
-        getConfigurationOrCreate().setPriorityFlag(priorityFlag);
-    }
-
-    public byte getReplaceIfPresentFlag() {
-        return getConfigurationOrCreate().getReplaceIfPresentFlag();
-    }
-
-    /**
-     * Used to request the SMSC to replace a previously submitted message, that is still pending delivery.
-     * The SMSC will replace an existing message provided that the source address, destination address and service
-     * type match the same fields in the new message.
-     * The following replace if present flag values are defined:
-     * <ul>
-     *     <li>0: Don't replace</li>
-     *     <li>1: Replace</li>
-     * </ul>
-     * @param replaceIfPresentFlag
-     */
-    public void setReplaceIfPresentFlag(byte replaceIfPresentFlag) {
-        getConfigurationOrCreate().setReplaceIfPresentFlag(replaceIfPresentFlag);
-    }
-
-    public String getSourceAddr() {
-        return getConfigurationOrCreate().getSourceAddr();
-    }
-
-    /**
-     * Defines the address of SME (Short Message Entity) which originated this message.
-     * @param sourceAddr
-     */
-    public void setSourceAddr(String sourceAddr) {
-        getConfigurationOrCreate().setSourceAddr(sourceAddr);
-    }
-
-    public String getDestAddr() {
-        return getConfigurationOrCreate().getDestAddr();
-    }
-
-    /**
-     * Defines the destination SME address. For mobile terminated messages, this is the directory number of the recipient MS.
-     * Only for SubmitSm, SubmitMulti, CancelSm and DataSm.
-     * @param destAddr
-     */
-    public void setDestAddr(String destAddr) {
-        getConfigurationOrCreate().setDestAddr(destAddr);
-    }
-
-    public byte getTypeOfNumber() {
-        return getConfigurationOrCreate().getTypeOfNumber();
-    }
-
-    /**
-     * Defines the type of number (TON) to be used in the SME.
-     * The following TON values are defined:
-     * <ul>
-     *     <li>0: Unknown</li>
-     *     <li>1: International</li>
-     *     <li>2: National</li>
-     *     <li>3: Network Specific</li>
-     *     <li>4: Subscriber Number</li>
-     *     <li>5: Alphanumeric</li>
-     *     <li>6: Abbreviated</li>
-     * </ul>
-     * @param typeOfNumber
-     */
-    public void setTypeOfNumber(byte typeOfNumber) {
-        getConfigurationOrCreate().setTypeOfNumber(typeOfNumber);
-    }
-
-    public byte getNumberingPlanIndicator() {
-        return getConfigurationOrCreate().getNumberingPlanIndicator();
-    }
-
-    /**
-     * Defines the numeric plan indicator (NPI) to be used in the SME.
-     * The following NPI values are defined:
-     * <ul>
-     *     <li>0: Unknown</li>
-     *     <li>1: ISDN (E163/E164)</li>
-     *     <li>2: Data (X.121)</li>
-     *     <li>3: Telex (F.69)</li>
-     *     <li>6: Land Mobile (E.212)</li>
-     *     <li>8: National</li>
-     *     <li>9: Private</li>
-     *     <li>10: ERMES</li>
-     *     <li>13: Internet (IP)</li>
-     *     <li>18: WAP Client Id (to be defined by WAP Forum)</li>
-     * </ul>
-     * @param numberingPlanIndicator
-     */
-    public void setNumberingPlanIndicator(byte numberingPlanIndicator) {
-        getConfigurationOrCreate().setNumberingPlanIndicator(numberingPlanIndicator);
-    }
-
-    public boolean getUsingSSL() {
-        return getConfigurationOrCreate().getUsingSSL();
-    }
-
-    /**
-     * Whether using SSL with the smpps protocol
-     * @param usingSSL
-     */
-    public void setUsingSSL(boolean usingSSL) {
-        getConfigurationOrCreate().setUsingSSL(usingSSL);
-    }
-
-    public long getInitialReconnectDelay() {
-        return getConfigurationOrCreate().getInitialReconnectDelay();
-    }
-
-    /**
-     * Defines the initial delay in milliseconds after the consumer/producer tries to reconnect to the SMSC, after the connection was lost.
-     * @param initialReconnectDelay
-     */
-    public void setInitialReconnectDelay(long initialReconnectDelay) {
-        getConfigurationOrCreate().setInitialReconnectDelay(initialReconnectDelay);
-    }
-
-    public long getReconnectDelay() {
-        return getConfigurationOrCreate().getReconnectDelay();
-    }
-
-    /**
-     * Defines the interval in milliseconds between the reconnect attempts, if the connection to the SMSC was lost and the previous was not succeed.
-     * @param reconnectDelay
-     */
-    public void setReconnectDelay(long reconnectDelay) {
-        getConfigurationOrCreate().setReconnectDelay(reconnectDelay);
-    }
-
-    public boolean isLazySessionCreation() {
-        return getConfigurationOrCreate().isLazySessionCreation();
-    }
-
-    /**
-     * Sessions can be lazily created to avoid exceptions, if the SMSC is not available when the Camel producer is started.
-     * Camel will check the in message headers 'CamelSmppSystemId' and 'CamelSmppPassword' of the first exchange.
-     * If they are present, Camel will use these data to connect to the SMSC.
-     * @param lazySessionCreation
-     */
-    public void setLazySessionCreation(boolean lazySessionCreation) {
-        getConfigurationOrCreate().setLazySessionCreation(lazySessionCreation);
-    }
-
-    public String getHttpProxyHost() {
-        return getConfigurationOrCreate().getHttpProxyHost();
-    }
-
-    /**
-     * If you need to tunnel SMPP through a HTTP proxy, set this attribute to the hostname or ip address of your HTTP proxy.
-     * @param httpProxyHost
-     */
-    public void setHttpProxyHost(String httpProxyHost) {
-        getConfigurationOrCreate().setHttpProxyHost(httpProxyHost);
-    }
-
-    public Integer getHttpProxyPort() {
-        return getConfigurationOrCreate().getHttpProxyPort();
-    }
-
-    /**
-     * If you need to tunnel SMPP through a HTTP proxy, set this attribute to the port of your HTTP proxy.
-     * @param httpProxyPort
-     */
-    public void setHttpProxyPort(Integer httpProxyPort) {
-        getConfigurationOrCreate().setHttpProxyPort(httpProxyPort);
-    }
-
-    public String getHttpProxyUsername() {
-        return getConfigurationOrCreate().getHttpProxyUsername();
-    }
-
-    /**
-     * If your HTTP proxy requires basic authentication, set this attribute to the username required for your HTTP proxy.
-     * @param httpProxyUsername
-     */
-    public void setHttpProxyUsername(String httpProxyUsername) {
-        getConfigurationOrCreate().setHttpProxyUsername(httpProxyUsername);
-    }
-
-    public String getHttpProxyPassword() {
-        return getConfigurationOrCreate().getHttpProxyPassword();
-    }
-
-    /**
-     * If your HTTP proxy requires basic authentication, set this attribute to the password required for your HTTP proxy.
-     * @param httpProxyPassword
-     */
-    public void setHttpProxyPassword(String httpProxyPassword) {
-        getConfigurationOrCreate().setHttpProxyPassword(httpProxyPassword);
-    }
-
-    public SessionStateListener getSessionStateListener() {
-        return getConfigurationOrCreate().getSessionStateListener();
-    }
-
-    /**
-     * You can refer to a org.jsmpp.session.SessionStateListener in the Registry to receive callbacks when the session state changed.
-     * @param sessionStateListener
-     */
-    public void setSessionStateListener(SessionStateListener sessionStateListener) {
-        getConfigurationOrCreate().setSessionStateListener(sessionStateListener);
-    }
-
-    public String getAddressRange() {
-        return getConfigurationOrCreate().getAddressRange();
-    }
-
-    /**
-     *  You can specify the address range for the SmppConsumer as defined in section 5.2.7 of the SMPP 3.4 specification.
-     *  The SmppConsumer will receive messages only from SMSC's which target an address (MSISDN or IP address) within this range.
-     * @param addressRange
-     */
-    public void setAddressRange(String addressRange) {
-        getConfigurationOrCreate().setAddressRange(addressRange);
-    }
-
-    public SmppSplittingPolicy getSplittingPolicy() {
-        return getConfigurationOrCreate().getSplittingPolicy();
-    }
-
-    /**
-     * You can specify a policy for handling long messages:
-     * <ul>
-     *     <li>ALLOW - the default, long messages are split to 140 bytes per message</li>
-     *     <li>TRUNCATE - long messages are split and only the first fragment will be sent to the SMSC.
-     *     Some carriers drop subsequent fragments so this reduces load on the SMPP connection sending parts of a message that will never be delivered.</li>
-     *     <li>REJECT - if a message would need to be split, it is rejected with an SMPP NegativeResponseException and the reason code signifying the message is too long.</li>
-     * </ul>
-     * @param splittingPolicy
-     */
-    public void setSplittingPolicy(SmppSplittingPolicy splittingPolicy) {
-        getConfigurationOrCreate().setSplittingPolicy(splittingPolicy);
-    }
-
-    /**
-     * These headers will be passed to the proxy server while establishing the connection.
-     * @param proxyHeaders
-     */
-    public void setProxyHeaders(Map<String, String> proxyHeaders) {
-        getConfigurationOrCreate().setProxyHeaders(proxyHeaders);
-    }
-
-    public Map<String, String> getProxyHeaders() {
-        return getConfigurationOrCreate().getProxyHeaders();
-    }
 }
\ No newline at end of file


Mime
View raw message