public class

S3ConnectorConfigConnectionManagementConnectionManager

extends ExpressionEvaluatorSupport
implements MetadataAware MuleContextAware ProcessAdapter<O> Capabilities Disposable Initialisable Testable ConnectorMetaDataEnabled ConnectionManagementConnectionManager<Key extends ConnectionManagementConnectionKey, Adapter extends ConnectionManagementConnectorAdapter, Strategy>
java.lang.Object
   ↳ org.mule.devkit.processor.ExpressionEvaluatorSupport
     ↳ org.mule.module.s3.connectivity.S3ConnectorConfigConnectionManagementConnectionManager

Class Overview

A S3ConnectorConfigConnectionManagementConnectionManager is a wrapper around S3Connector that adds connection management capabilities to the pojo.

Summary

Constants
String DEVKIT_BUILD
String DEVKIT_VERSION
String MIN_MULE_VERSION
String MODULE_NAME
String MODULE_VERSION
[Expand]
Inherited Constants
From interface org.mule.api.lifecycle.Disposable
From interface org.mule.api.lifecycle.Initialisable
Fields
private String accessKey
private KeyedObjectPool connectionPool Connector Pool
private Integer connectionTimeout
private Integer maxConnections
protected MuleContext muleContext Mule Context
protected PoolingProfile poolingProfile
private Protocol protocol
private String proxyDomain
private String proxyHost
private String proxyPassword
private Integer proxyPort
private String proxyUsername
private String proxyWorkstation
protected RetryPolicyTemplate retryPolicyTemplate
private String secretKey
private Integer socketTimeout
Public Constructors
S3ConnectorConfigConnectionManagementConnectionManager()
Public Methods
S3ConnectorConnectionManagementAdapter acquireConnection(ConnectionManagementConfigS3ConnectorConnectionKey key)
void destroyConnection(ConnectionManagementConfigS3ConnectorConnectionKey key, S3ConnectorConnectionManagementAdapter connection)
void dispose()
String getAccessKey()
Retrieves accessKey
ConnectionManagementConnectionAdapter getConnectionAdapter(ConnectionManagementConnectorAdapter adapter)
ConnectionManagementConfigS3ConnectorConnectionKey getConnectionKey(MessageProcessor messageProcessor, MuleEvent event)
Integer getConnectionTimeout()
Retrieves connectionTimeout
ConnectionManagementConfigS3ConnectorConnectionKey getDefaultConnectionKey()
String getDevkitBuild()
String getDevkitVersion()
ConnectionManagementConfigS3ConnectorConnectionKey getEvaluatedConnectionKey(MuleEvent event)
Integer getMaxConnections()
Retrieves maxConnections
Result<MetaData> getMetaData(MetaDataKey metaDataKey)
Result<List<MetaDataKey>> getMetaDataKeys()
String getMinMuleVersion()
String getModuleName()
String getModuleVersion()
MuleContext getMuleContext()
Retrieves muleContext
PoolingProfile getPoolingProfile()
Retrieves poolingProfile
<P> ProcessTemplate<P, S3ConnectorConnectionManagementAdapter> getProcessTemplate()
Protocol getProtocol()
Retrieves protocol
String getProxyDomain()
Retrieves proxyDomain
String getProxyHost()
Retrieves proxyHost
String getProxyPassword()
Retrieves proxyPassword
Integer getProxyPort()
Retrieves proxyPort
String getProxyUsername()
Retrieves proxyUsername
String getProxyWorkstation()
Retrieves proxyWorkstation
RetryPolicyTemplate getRetryPolicyTemplate()
Retrieves retryPolicyTemplate
String getSecretKey()
Retrieves secretKey
Integer getSocketTimeout()
Retrieves socketTimeout
void initialise()
boolean isCapableOf(ModuleCapability capability)
Returns true if this module implements such capability
ConnectionManagementConnectionAdapter newConnection()
ConnectionManagementConnectorAdapter newConnector(ConnectionManagementConnectionAdapter<Config, ConnectionManagementConfigS3ConnectorConnectionKey> connection)
void releaseConnection(ConnectionManagementConfigS3ConnectorConnectionKey key, S3ConnectorConnectionManagementAdapter connection)
void setAccessKey(String value)
Sets accessKey
void setConnectionTimeout(Integer value)
Sets connectionTimeout
void setMaxConnections(Integer value)
Sets maxConnections
void setMuleContext(MuleContext value)
Sets muleContext
void setPoolingProfile(PoolingProfile value)
Sets poolingProfile
void setProtocol(Protocol value)
Sets protocol
void setProxyDomain(String value)
Sets proxyDomain
void setProxyHost(String value)
Sets proxyHost
void setProxyPassword(String value)
Sets proxyPassword
void setProxyPort(Integer value)
Sets proxyPort
void setProxyUsername(String value)
Sets proxyUsername
void setProxyWorkstation(String value)
Sets proxyWorkstation
void setRetryPolicyTemplate(RetryPolicyTemplate value)
Sets retryPolicyTemplate
void setSecretKey(String value)
Sets secretKey
void setSocketTimeout(Integer value)
Sets socketTimeout
TestResult test()
[Expand]
Inherited Methods
From class org.mule.devkit.processor.ExpressionEvaluatorSupport
From class java.lang.Object
From interface org.mule.api.MetadataAware
From interface org.mule.api.context.MuleContextAware
From interface org.mule.api.devkit.ProcessAdapter
From interface org.mule.api.devkit.capability.Capabilities
From interface org.mule.api.lifecycle.Disposable
From interface org.mule.api.lifecycle.Initialisable
From interface org.mule.common.Testable
From interface org.mule.common.metadata.ConnectorMetaDataEnabled
From interface org.mule.devkit.internal.connection.management.ConnectionManagementConnectionManager

Constants

private static final String DEVKIT_BUILD

Constant Value: "mule-devkit-3.7.0.2589.361fd9f"

private static final String DEVKIT_VERSION

Constant Value: "3.7.0"

private static final String MIN_MULE_VERSION

Constant Value: "3.5.0"

private static final String MODULE_NAME

Constant Value: "Amazon S3"

private static final String MODULE_VERSION

Constant Value: "3.0.0-SNAPSHOT"

Fields

private String accessKey

private KeyedObjectPool connectionPool

Connector Pool

private Integer connectionTimeout

private Integer maxConnections

protected MuleContext muleContext

Mule Context

protected PoolingProfile poolingProfile

private Protocol protocol

private String proxyDomain

private String proxyHost

private String proxyPassword

private Integer proxyPort

private String proxyUsername

private String proxyWorkstation

protected RetryPolicyTemplate retryPolicyTemplate

private String secretKey

private Integer socketTimeout

Public Constructors

public S3ConnectorConfigConnectionManagementConnectionManager ()

Public Methods

public S3ConnectorConnectionManagementAdapter acquireConnection (ConnectionManagementConfigS3ConnectorConnectionKey key)

Parameters
key
Throws
Exception

public void destroyConnection (ConnectionManagementConfigS3ConnectorConnectionKey key, S3ConnectorConnectionManagementAdapter connection)

Parameters
key
connection
Throws
Exception

public void dispose ()

public String getAccessKey ()

Retrieves accessKey

public ConnectionManagementConnectionAdapter getConnectionAdapter (ConnectionManagementConnectorAdapter adapter)

Parameters
adapter

public ConnectionManagementConfigS3ConnectorConnectionKey getConnectionKey (MessageProcessor messageProcessor, MuleEvent event)

Parameters
messageProcessor
event
Throws
Exception

public Integer getConnectionTimeout ()

Retrieves connectionTimeout

public ConnectionManagementConfigS3ConnectorConnectionKey getDefaultConnectionKey ()

public String getDevkitBuild ()

public String getDevkitVersion ()

public ConnectionManagementConfigS3ConnectorConnectionKey getEvaluatedConnectionKey (MuleEvent event)

Parameters
event
Throws
Exception

public Integer getMaxConnections ()

Retrieves maxConnections

public Result<MetaData> getMetaData (MetaDataKey metaDataKey)

Parameters
metaDataKey

public Result<List<MetaDataKey>> getMetaDataKeys ()

public String getMinMuleVersion ()

public String getModuleName ()

public String getModuleVersion ()

public MuleContext getMuleContext ()

Retrieves muleContext

public PoolingProfile getPoolingProfile ()

Retrieves poolingProfile

public ProcessTemplate<P, S3ConnectorConnectionManagementAdapter> getProcessTemplate ()

public Protocol getProtocol ()

Retrieves protocol

public String getProxyDomain ()

Retrieves proxyDomain

public String getProxyHost ()

Retrieves proxyHost

public String getProxyPassword ()

Retrieves proxyPassword

public Integer getProxyPort ()

Retrieves proxyPort

public String getProxyUsername ()

Retrieves proxyUsername

public String getProxyWorkstation ()

Retrieves proxyWorkstation

public RetryPolicyTemplate getRetryPolicyTemplate ()

Retrieves retryPolicyTemplate

public String getSecretKey ()

Retrieves secretKey

public Integer getSocketTimeout ()

Retrieves socketTimeout

public void initialise ()

public boolean isCapableOf (ModuleCapability capability)

Returns true if this module implements such capability

Parameters
capability

public ConnectionManagementConnectionAdapter newConnection ()

public ConnectionManagementConnectorAdapter newConnector (ConnectionManagementConnectionAdapter<Config, ConnectionManagementConfigS3ConnectorConnectionKey> connection)

Parameters
connection

public void releaseConnection (ConnectionManagementConfigS3ConnectorConnectionKey key, S3ConnectorConnectionManagementAdapter connection)

Parameters
key
connection
Throws
Exception

public void setAccessKey (String value)

Sets accessKey

Parameters
value Value to set

public void setConnectionTimeout (Integer value)

Sets connectionTimeout

Parameters
value Value to set

public void setMaxConnections (Integer value)

Sets maxConnections

Parameters
value Value to set

public void setMuleContext (MuleContext value)

Sets muleContext

Parameters
value Value to set

public void setPoolingProfile (PoolingProfile value)

Sets poolingProfile

Parameters
value Value to set

public void setProtocol (Protocol value)

Sets protocol

Parameters
value Value to set

public void setProxyDomain (String value)

Sets proxyDomain

Parameters
value Value to set

public void setProxyHost (String value)

Sets proxyHost

Parameters
value Value to set

public void setProxyPassword (String value)

Sets proxyPassword

Parameters
value Value to set

public void setProxyPort (Integer value)

Sets proxyPort

Parameters
value Value to set

public void setProxyUsername (String value)

Sets proxyUsername

Parameters
value Value to set

public void setProxyWorkstation (String value)

Sets proxyWorkstation

Parameters
value Value to set

public void setRetryPolicyTemplate (RetryPolicyTemplate value)

Sets retryPolicyTemplate

Parameters
value Value to set

public void setSecretKey (String value)

Sets secretKey

Parameters
value Value to set

public void setSocketTimeout (Integer value)

Sets socketTimeout

Parameters
value Value to set

public TestResult test ()