org.mule.modules.microsoftservicebus.connection

Class BaseConnectionStrategy

java.lang.Object

org.mule.modules.microsoftservicebus.connection.BaseConnectionStrategy

All Implemented Interfaces:

ConnectionStrategy

Direct Known Subclasses:

AzureConnectionStrategy, WindowsConnectionStrategy

public abstract class BaseConnectionStrategy
extends Object
implements ConnectionStrategy

Field Summary

Fields

Modifier and Type	Field and Description
protected AmqpClient	amqpClient
protected com.microsoft.azure.storage.blob.CloudBlobContainer	blobContainer
protected org.mule.api.MuleContext	muleContext
protected String	namespace
protected RestClient	restClient

Constructor Summary

Constructors

Constructor and Description
BaseConnectionStrategy()

Method Summary

Modifier and Type	Method and Description
void	disconnect() Disconnect
AmqpClient	getAMQPClient()
abstract String	getBaseUrl()
com.microsoft.azure.storage.blob.CloudBlobContainer	getCloudBlobContainer()
Integer	getMaxConnections()
RestClient	getRestClient()
abstract String	getSASToken(String url)
boolean	getSkipConnectivityTest()
boolean	isConnected() Are we connected
void	setMaxConnections(Integer maxConnections)
void	setMuleContext(org.mule.api.MuleContext muleContext)
void	setSkipConnectivityTest(boolean value)
protected boolean	testConnectivity()
protected void	testConnectivityAmqpClient()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

restClient

protected RestClient restClient

amqpClient

protected AmqpClient amqpClient

blobContainer

protected com.microsoft.azure.storage.blob.CloudBlobContainer blobContainer

namespace

protected String namespace

muleContext

@Inject
protected org.mule.api.MuleContext muleContext

Constructor Detail

BaseConnectionStrategy

public BaseConnectionStrategy()

Method Detail

getSASToken

public abstract String getSASToken(String url)
                            throws ServiceBusException

Specified by:

getSASToken in interface ConnectionStrategy

Throws:

ServiceBusException

getBaseUrl

public abstract String getBaseUrl()

Specified by:

getBaseUrl in interface ConnectionStrategy

testConnectivity

protected boolean testConnectivity()

testConnectivityAmqpClient

protected void testConnectivityAmqpClient()
                                   throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

isConnected

@ValidateConnection
public boolean isConnected()

Are we connected

Returns:

true if the amqp client is connected, false otherwise

disconnect

@Disconnect
public void disconnect()

Disconnect

getAMQPClient

public AmqpClient getAMQPClient()

Specified by:

getAMQPClient in interface ConnectionStrategy

getRestClient

public RestClient getRestClient()

Specified by:

getRestClient in interface ConnectionStrategy

getCloudBlobContainer

public com.microsoft.azure.storage.blob.CloudBlobContainer getCloudBlobContainer()

Specified by:

getCloudBlobContainer in interface ConnectionStrategy

setMuleContext

public void setMuleContext(org.mule.api.MuleContext muleContext)

getSkipConnectivityTest

public boolean getSkipConnectivityTest()

setSkipConnectivityTest

public void setSkipConnectivityTest(boolean value)

getMaxConnections

public Integer getMaxConnections()

setMaxConnections

public void setMaxConnections(Integer maxConnections)