public class

SQSConnectorConfigConnectionManagementConnectionManager

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.modules.sqs.connectivity.SQSConnectorConfigConnectionManagementConnectionManager

Class Overview

A SQSConnectorConfigConnectionManagementConnectionManager is a wrapper around SQSConnector 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 String defaultQueueName
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
private RegionEndpoint region
protected RetryPolicyTemplate retryPolicyTemplate
private String secretKey
private Integer socketTimeout
private String url
Public Constructors
SQSConnectorConfigConnectionManagementConnectionManager()
Public Methods
SQSConnectorConnectionManagementAdapter acquireConnection(ConnectionManagementConfigSQSConnectorConnectionKey key)
void destroyConnection(ConnectionManagementConfigSQSConnectorConnectionKey key, SQSConnectorConnectionManagementAdapter connection)
void dispose()
String getAccessKey()
Retrieves accessKey
ConnectionManagementConnectionAdapter getConnectionAdapter(ConnectionManagementConnectorAdapter adapter)
ConnectionManagementConfigSQSConnectorConnectionKey getConnectionKey(MessageProcessor messageProcessor, MuleEvent event)
Integer getConnectionTimeout()
Retrieves connectionTimeout
ConnectionManagementConfigSQSConnectorConnectionKey getDefaultConnectionKey()
String getDefaultQueueName()
Retrieves defaultQueueName
String getDevkitBuild()
String getDevkitVersion()
ConnectionManagementConfigSQSConnectorConnectionKey getEvaluatedConnectionKey(MuleEvent event)
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, SQSConnectorConnectionManagementAdapter> 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
RegionEndpoint getRegion()
Retrieves region
RetryPolicyTemplate getRetryPolicyTemplate()
Retrieves retryPolicyTemplate
String getSecretKey()
Retrieves secretKey
Integer getSocketTimeout()
Retrieves socketTimeout
String getUrl()
Retrieves url
void initialise()
boolean isCapableOf(ModuleCapability capability)
Returns true if this module implements such capability
ConnectionManagementConnectionAdapter newConnection()
ConnectionManagementConnectorAdapter newConnector(ConnectionManagementConnectionAdapter<Config, ConnectionManagementConfigSQSConnectorConnectionKey> connection)
void releaseConnection(ConnectionManagementConfigSQSConnectorConnectionKey key, SQSConnectorConnectionManagementAdapter connection)
void setAccessKey(String value)
Sets accessKey
void setConnectionTimeout(Integer value)
Sets connectionTimeout
void setDefaultQueueName(String value)
Sets defaultQueueName
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 setRegion(RegionEndpoint value)
Sets region
void setRetryPolicyTemplate(RetryPolicyTemplate value)
Sets retryPolicyTemplate
void setSecretKey(String value)
Sets secretKey
void setSocketTimeout(Integer value)
Sets socketTimeout
void setUrl(String value)
Sets url
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 SQS"

private static final String MODULE_VERSION

Constant Value: "3.1.1"

Fields

private String accessKey

private KeyedObjectPool connectionPool

Connector Pool

private Integer connectionTimeout

private String defaultQueueName

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

private RegionEndpoint region

protected RetryPolicyTemplate retryPolicyTemplate

private String secretKey

private Integer socketTimeout

private String url

Public Constructors

public SQSConnectorConfigConnectionManagementConnectionManager ()

Public Methods

public SQSConnectorConnectionManagementAdapter acquireConnection (ConnectionManagementConfigSQSConnectorConnectionKey key)

Parameters
key
Throws
Exception

public void destroyConnection (ConnectionManagementConfigSQSConnectorConnectionKey key, SQSConnectorConnectionManagementAdapter connection)

Parameters
key
connection
Throws
Exception

public void dispose ()

public String getAccessKey ()

Retrieves accessKey

public ConnectionManagementConnectionAdapter getConnectionAdapter (ConnectionManagementConnectorAdapter adapter)

Parameters
adapter

public ConnectionManagementConfigSQSConnectorConnectionKey getConnectionKey (MessageProcessor messageProcessor, MuleEvent event)

Parameters
messageProcessor
event
Throws
Exception

public Integer getConnectionTimeout ()

Retrieves connectionTimeout

public ConnectionManagementConfigSQSConnectorConnectionKey getDefaultConnectionKey ()

public String getDefaultQueueName ()

Retrieves defaultQueueName

public String getDevkitBuild ()

public String getDevkitVersion ()

public ConnectionManagementConfigSQSConnectorConnectionKey getEvaluatedConnectionKey (MuleEvent event)

Parameters
event
Throws
Exception

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, SQSConnectorConnectionManagementAdapter> 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 RegionEndpoint getRegion ()

Retrieves region

public RetryPolicyTemplate getRetryPolicyTemplate ()

Retrieves retryPolicyTemplate

public String getSecretKey ()

Retrieves secretKey

public Integer getSocketTimeout ()

Retrieves socketTimeout

public String getUrl ()

Retrieves url

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, ConnectionManagementConfigSQSConnectorConnectionKey> connection)

Parameters
connection

public void releaseConnection (ConnectionManagementConfigSQSConnectorConnectionKey key, SQSConnectorConnectionManagementAdapter 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 setDefaultQueueName (String value)

Sets defaultQueueName

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 setRegion (RegionEndpoint value)

Sets region

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 void setUrl (String value)

Sets url

Parameters
value Value to set

public TestResult test ()