@ConnectionManagement(configElementName="azureSASConfig", friendlyName="Shared Access Signature") public class SharedAccessSignatureConnectionStrategy extends AzureConnectionStrategy
amqpClient, blobContainer, muleContext, namespace, restClient
Constructor and Description |
---|
SharedAccessSignatureConnectionStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
connect(String namespace,
String sharedAccessSignature,
String blobAccountName,
String blobAccountKey,
String blobContainerName)
Connect
|
String |
connectionId()
namespace_sasObject
|
String |
getSASToken(String url) |
SharedAccessSignatureProvider |
getTokenProvider() |
List<String> |
getTokens() |
void |
setTokenProvider(SharedAccessSignatureProvider provider) |
void |
setTokens(List<String> tokens) |
protected boolean |
testConnectivity() |
createAMQPClient, createRestClient, getBaseUrl
disconnect, getAMQPClient, getCloudBlobContainer, getRestClient, getSkipConnectivityTest, isConnected, setMuleContext, setSkipConnectivityTest, testConnectivityAmqpClient
public SharedAccessSignatureConnectionStrategy()
@Connect @TestConnectivity public void connect(@ConnectionKey@FriendlyName(value="Service Namespace")@Placement(group="Connection",order=1) String namespace, @ConnectionKey@FriendlyName(value="Shared Access Signature")@Placement(group="Connection",order=2)@Optional String sharedAccessSignature, @FriendlyName(value="Storage Account Name")@Placement(group="Blob Storage Connection")@Summary(value="(Optional) The account name of the Blob Storage that will be used to store large messages.")@Optional String blobAccountName, @FriendlyName(value="Storage Access Key")@Placement(group="Blob Storage Connection")@Password@Summary(value="(Optional) The account key of the Blob Storage that will be used to store large messages.")@Optional String blobAccountKey, @FriendlyName(value="Container Name")@Placement(group="Blob Storage Connection")@Summary(value="(Optional) The container name in the Blob Storage that will be used to store large messages. If this parameter is not provided a default container will be created")@Optional String blobContainerName) throws org.mule.api.ConnectionException
namespace
- Azure Service NamespacesharedAccessSignature
- Shared Access Signature (optional - can be left empty if advanced section is configured)org.mule.api.ConnectionException
@ConnectionIdentifier public String connectionId()
public String getSASToken(String url) throws ServiceBusException
getSASToken
in interface ConnectionStrategy
getSASToken
in class BaseConnectionStrategy
ServiceBusException
public SharedAccessSignatureProvider getTokenProvider()
public void setTokenProvider(SharedAccessSignatureProvider provider)
protected boolean testConnectivity()
testConnectivity
in class BaseConnectionStrategy
Copyright © 2010–2017. All rights reserved.