org.mule.transport.amqp.internal.connector
Class AmqpsConnector

java.lang.Object
  extended by org.mule.transport.AbstractConnector
      extended by org.mule.transport.amqp.internal.connector.AmqpConnector
          extended by org.mule.transport.amqp.internal.connector.AmqpsConnector
All Implemented Interfaces:
EventListener, javax.resource.spi.work.WorkListener, org.mule.api.lifecycle.Disposable, org.mule.api.lifecycle.Initialisable, org.mule.api.lifecycle.Lifecycle, org.mule.api.lifecycle.LifecycleStateEnabled, org.mule.api.lifecycle.Startable, org.mule.api.lifecycle.Stoppable, org.mule.api.NameableObject, org.mule.api.NamedObject, org.mule.api.transport.Connectable, org.mule.api.transport.Connector

public class AmqpsConnector
extends AmqpConnector

Connects to a particular virtual host on a particular AMQP broker.


Field Summary
static String AMQPS
           
 
Fields inherited from class org.mule.transport.amqp.internal.connector.AmqpConnector
ALL_USER_HEADERS, AMQP, AMQP_DELIVERY_TAG, DEFAULT_NUMBER_OF_CHANNELS, ENDPOINT_DEFAULT_EXCHANGE_ALIAS, ENDPOINT_EXCHANGE_PREFIX, ENDPOINT_PROPERTY_EXCHANGE_AUTO_DELETE, ENDPOINT_PROPERTY_EXCHANGE_DURABLE, ENDPOINT_PROPERTY_EXCHANGE_TYPE, ENDPOINT_PROPERTY_QUEUE_AUTO_DELETE, ENDPOINT_PROPERTY_QUEUE_DURABLE, ENDPOINT_PROPERTY_QUEUE_EXCLUSIVE, ENDPOINT_PROPERTY_ROUTING_KEY, ENDPOINT_QUEUE_PREFIX, EXCHANGE, MESSAGE_PROPERTY_APP_ID, MESSAGE_PROPERTY_CHANNEL, MESSAGE_PROPERTY_CLUSTER_ID, MESSAGE_PROPERTY_CONSUMER_TAG, MESSAGE_PROPERTY_CONTENT_ENCODING, MESSAGE_PROPERTY_CONTENT_TYPE, MESSAGE_PROPERTY_CORRELATION_ID, MESSAGE_PROPERTY_DELIVERY_MODE, MESSAGE_PROPERTY_DELIVERY_TAG, MESSAGE_PROPERTY_EXPIRATION, MESSAGE_PROPERTY_MESSAGE_ID, MESSAGE_PROPERTY_NEXT_PUBLISH_SEQ_NO, MESSAGE_PROPERTY_PRIORITY, MESSAGE_PROPERTY_REDELIVER, MESSAGE_PROPERTY_REPLY_TO, MESSAGE_PROPERTY_ROUTING_KEY, MESSAGE_PROPERTY_TIMESTAMP, MESSAGE_PROPERTY_TYPE, MESSAGE_PROPERTY_USER_ID, NUMBER_OF_CHANNELS, RETURN_CONTEXT_PREFIX, RETURN_EXCHANGE, RETURN_LISTENER, RETURN_REPLY_CODE, RETURN_REPLY_TEXT, RETURN_ROUTING_KEY
 
Fields inherited from class org.mule.transport.AbstractConnector
createMultipleTransactedReceivers, DEFAULT_NUM_CONCURRENT_TX_RECEIVERS, dispatcherFactory, dispatcherPoolFactory, dispatchers, initialStateStopped, lifecycleManager, logger, muleContext, muleMessageFactory, name, numberOfConcurrentTransactedReceivers, PROPERTY_POLLING_FREQUENCY, receivers, requesterFactory, requesters, serviceDescriptor, serviceOverrides, sessionHandler, startOnConnect
 
Fields inherited from interface org.mule.api.transport.Connector
INT_VALUE_NOT_SET
 
Fields inherited from interface org.mule.api.lifecycle.Disposable
PHASE_NAME
 
Constructor Summary
AmqpsConnector(org.mule.api.MuleContext muleContext)
           
 
Method Summary
 void doInitialise()
           
 String getProtocol()
           
 String getSslProtocol()
           
 TrustManager getSslTrustManager()
           
 void setExplicitTrustStoreOnly(boolean explicitTrustStoreOnly)
           
 void setKeyManagerAlgorithm(String keyManagerAlgorithm)
           
 void setKeyPassword(String keyPassword)
           
 void setKeyStore(String keyStore)
           
 void setKeyStorePassword(String storePassword)
           
 void setKeyStoreType(String keystoreType)
           
 void setSslProtocol(String sslProtocol)
           
 void setSslTrustManager(TrustManager sslTrustManager)
           
 void setTrustManagerAlgorithm(String trustManagerAlgorithm)
           
 void setTrustManagerFactory(TrustManagerFactory trustManagerFactory)
           
 void setTrustStore(String trustStore)
           
 void setTrustStorePassword(String trustStorePassword)
           
 void setTrustStoreType(String trustStoreType)
           
 
Methods inherited from class org.mule.transport.amqp.internal.connector.AmqpConnector
addFallbackAddresses, configureDefaultReturnListener, connectToFirstResponsiveBroker, createOperationResource, doConnect, doDisconnect, doDispose, doStart, doStop, getAckMode, getChannelHandler, getConnection, getConnectionFactory, getDefaultReturnListener, getDeliveryMode, getHost, getNumberOfChannels, getOperationResourceFactory, getPort, getPrefetchCount, getPrefetchSize, getPriority, getReceiveTransformer, getReplyToHandler, getRequestedHeartbeat, isExclusiveConsumers, isImmediate, isMandatory, isNoLocal, isRequestBrokerConfirms, setAckMode, setActiveDeclarationsOnly, setChannelHandler, setConnectionFactory, setDefaultReturnEndpoint, setDeliveryMode, setExclusiveConsumers, setFallbackAddresses, setHost, setImmediate, setMandatory, setNoLocal, setNumberOfChannels, setPassword, setPort, setPrefetchCount, setPrefetchSize, setPriority, setRequestBrokerConfirms, setRequestedHeartbeat, setUsername, setVirtualHost
 
Methods inherited from class org.mule.transport.AbstractConnector
clearDispatchers, clearRequesters, configureDispatcherPool, connect, createDefaultRedeliveryPolicy, createDispatcherMessageProcessor, createMuleMessageFactory, createReceiver, createScheduler, destroyReceiver, disconnect, dispose, disposeReceivers, disposeWorkManagers, doUnregisterListener, fireNotification, getConnectEventId, getConnectionDescription, getDefaultExchangePattern, getDefaultInboundTransformers, getDefaultOutboundTransformers, getDefaultResponseTransformers, getDispatcherFactory, getDispatcherPoolFactory, getDispatcherThreadingProfile, getDispatcherWorkManager, getInboundExchangePatterns, getLifecycleState, getMaxDispatchersActive, getMaxRequestersActive, getMaxTotalDispatchers, getMuleContext, getMuleMessageFactory, getName, getNumberOfConcurrentTransactedReceivers, getOutboundExchangePatterns, getOutputStream, getReceiver, getReceiverKey, getReceivers, getReceivers, getReceiverThreadingProfile, getReceiverWorkManager, getRequesterFactory, getRequesterThreadingProfile, getRequesterWorkManager, getRetryPolicyTemplate, getScheduler, getServiceDescriptor, getServiceOverrides, getSessionHandler, getSupportedProtocols, getTransactionalResource, handleWorkException, initFromServiceDescriptor, initialise, initialiseFromUrl, initWorkManagers, isConnected, isConnecting, isCreateMultipleTransactedReceivers, isDisposed, isEnableMessageEvents, isInitialised, isInitialStateStopped, isResponseEnabled, isStarted, isStarting, isStopped, isStopping, isValidateConnections, lookupReceiver, registerListener, registerSupportedMetaProtocol, registerSupportedProtocol, registerSupportedProtocolWithoutPrefix, request, request, setConnected, setConnecting, setCreateMultipleTransactedReceivers, setDispatcherFactory, setDispatcherPoolFactory, setDispatcherPoolMaxWait, setDispatcherPoolWhenExhaustedAction, setDispatcherThreadingProfile, setDynamicNotification, setInitialStateStopped, setMaxDispatchersActive, setMaxRequestersActive, setName, setNumberOfConcurrentTransactedReceivers, setReceiverThreadingProfile, setRequesterFactory, setRequesterPoolMaxWait, setRequesterPoolWhenExhaustedAction, setRequesterThreadingProfile, setRetryPolicyTemplate, setServiceOverrides, setSessionHandler, setSupportedProtocols, setupDispatchReturn, setupRequestReturn, setValidateConnections, shutdownScheduler, start, startAfterConnect, stop, supportsProtocol, toString, unregisterListener, unregisterSupportedProtocol, updateCachedNotificationHandler, validateConnection, workAccepted, workCompleted, workRejected, workStarted
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

AMQPS

public static final String AMQPS
See Also:
Constant Field Values
Constructor Detail

AmqpsConnector

public AmqpsConnector(org.mule.api.MuleContext muleContext)
Method Detail

getProtocol

public String getProtocol()
Specified by:
getProtocol in interface org.mule.api.transport.Connector
Overrides:
getProtocol in class AmqpConnector

doInitialise

public void doInitialise()
                  throws org.mule.api.lifecycle.InitialisationException
Overrides:
doInitialise in class AmqpConnector
Throws:
org.mule.api.lifecycle.InitialisationException

getSslTrustManager

public TrustManager getSslTrustManager()

setSslTrustManager

public void setSslTrustManager(TrustManager sslTrustManager)

getSslProtocol

public String getSslProtocol()

setSslProtocol

public void setSslProtocol(String sslProtocol)

setKeyPassword

public void setKeyPassword(String keyPassword)

setKeyStore

public void setKeyStore(String keyStore)
                 throws IOException
Throws:
IOException

setKeyStoreType

public void setKeyStoreType(String keystoreType)

setKeyStorePassword

public void setKeyStorePassword(String storePassword)

setKeyManagerAlgorithm

public void setKeyManagerAlgorithm(String keyManagerAlgorithm)

setTrustStore

public void setTrustStore(String trustStore)
                   throws IOException
Throws:
IOException

setTrustStorePassword

public void setTrustStorePassword(String trustStorePassword)

setTrustStoreType

public void setTrustStoreType(String trustStoreType)

setTrustManagerAlgorithm

public void setTrustManagerAlgorithm(String trustManagerAlgorithm)

setTrustManagerFactory

public void setTrustManagerFactory(TrustManagerFactory trustManagerFactory)

setExplicitTrustStoreOnly

public void setExplicitTrustStoreOnly(boolean explicitTrustStoreOnly)


Copyright © 2003–2015 MuleSoft, Inc.. All rights reserved.