public abstract class BaseConnectionStrategy extends Object implements ConnectionStrategy
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 and Description |
---|
BaseConnectionStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
disconnect()
Disconnect
|
AmqpClient |
getAMQPClient() |
abstract String |
getBaseUrl() |
com.microsoft.azure.storage.blob.CloudBlobContainer |
getCloudBlobContainer() |
RestClient |
getRestClient() |
abstract String |
getSASToken(String url) |
boolean |
getSkipConnectivityTest() |
boolean |
isConnected()
Are we connected
|
void |
setMuleContext(org.mule.api.MuleContext muleContext) |
void |
setSkipConnectivityTest(boolean value) |
protected boolean |
testConnectivity() |
protected void |
testConnectivityAmqpClient() |
protected RestClient restClient
protected AmqpClient amqpClient
protected com.microsoft.azure.storage.blob.CloudBlobContainer blobContainer
protected String namespace
@Inject protected org.mule.api.MuleContext muleContext
public abstract String getSASToken(String url) throws ServiceBusException
getSASToken
in interface ConnectionStrategy
ServiceBusException
public abstract String getBaseUrl()
getBaseUrl
in interface ConnectionStrategy
protected boolean testConnectivity()
protected void testConnectivityAmqpClient() throws org.mule.api.ConnectionException
org.mule.api.ConnectionException
@ValidateConnection public boolean isConnected()
@Disconnect public void disconnect()
public AmqpClient getAMQPClient()
getAMQPClient
in interface ConnectionStrategy
public RestClient getRestClient()
getRestClient
in interface ConnectionStrategy
public com.microsoft.azure.storage.blob.CloudBlobContainer getCloudBlobContainer()
getCloudBlobContainer
in interface ConnectionStrategy
public void setMuleContext(org.mule.api.MuleContext muleContext)
public boolean getSkipConnectivityTest()
public void setSkipConnectivityTest(boolean value)
Copyright © 2010–2017. All rights reserved.