org.mule.modules.microsoftservicebus.connection

Class UsernamePasswordConnectionStrategy

java.lang.Object

org.mule.modules.microsoftservicebus.connection.BaseConnectionStrategy

org.mule.modules.microsoftservicebus.connection.AzureConnectionStrategy

org.mule.modules.microsoftservicebus.connection.UsernamePasswordConnectionStrategy

All Implemented Interfaces:

ConnectionStrategy

@ConnectionManagement(configElementName="azureConfig",
                      friendlyName="Azure Service Bus")
public class UsernamePasswordConnectionStrategy
extends AzureConnectionStrategy

Field Summary

Fields inherited from class org.mule.modules.microsoftservicebus.connection.BaseConnectionStrategy

amqpClient, blobContainer, muleContext, namespace, restClient

Constructor Summary

Constructors

Constructor and Description
UsernamePasswordConnectionStrategy()

Method Summary

Modifier and Type	Method and Description
void	connect(String namespace, String userName, String password, String blobAccountName, String blobAccountKey, String blobContainerName) Connect
String	connectionId() namespace_keyname
String	getSASToken(String url)
void	setKey(String key)
void	setNamespace(String namespace)

Methods inherited from class org.mule.modules.microsoftservicebus.connection.AzureConnectionStrategy

createAMQPClient, createRestClient, getBaseUrl

Methods inherited from class org.mule.modules.microsoftservicebus.connection.BaseConnectionStrategy

disconnect, getAMQPClient, getCloudBlobContainer, getMaxConnections, getRestClient, getSkipConnectivityTest, isConnected, setMaxConnections, setMuleContext, setSkipConnectivityTest, testConnectivity, testConnectivityAmqpClient

Methods inherited from class java.lang.Object

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

Constructor Detail

UsernamePasswordConnectionStrategy

public UsernamePasswordConnectionStrategy()

Method Detail

connect

@Connect
 @TestConnectivity
public void connect(@ConnectionKey @FriendlyName(value="Service Namespace") @Placement(group="Connection",order=1)
                                                String namespace,
                                                @ConnectionKey @FriendlyName(value="Shared Access Key Name") @Placement(group="Connection",order=2)
                                                String userName,
                                                @FriendlyName(value="Shared Access Key") @Placement(group="Connection",order=3) @Password
                                                String password,
                                                @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

Connect

Parameters:

userName - Shared Key Name

password - Shared Key

namespace - Azure Service Namespace

blobAccountName - The account name of the Blob Storage that will be used to store large messages.

blobAccountKey - The account key of the Blob Storage that will be used to store large messages.

blobContainerName - 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.

Throws:

org.mule.api.ConnectionException - thrown when a connection cannot be established

connectionId

@ConnectionIdentifier
public String connectionId()

namespace_keyname

Returns:

connection id value composed of the namespace and kayName

getSASToken

public String getSASToken(String url)
                   throws ServiceBusException

Specified by:

getSASToken in interface ConnectionStrategy

Specified by:

getSASToken in class BaseConnectionStrategy

Throws:

ServiceBusException

setKey

public void setKey(String key)

setNamespace

public void setNamespace(String namespace)