@ConnectionManagement(configElementName="windowsConfig", friendlyName="Windows Service Bus") public class WindowsConnectionStrategy extends BaseConnectionStrategy
amqpClient, blobContainer, muleContext, namespace, restClient
Constructor and Description |
---|
WindowsConnectionStrategy() |
Modifier and Type | Method and Description |
---|---|
void |
connect(String namespace,
String username,
String password,
String fqdn,
String port,
Boolean disableCnCheck)
Connect
|
String |
connectionId()
Connection Id
username@fqdn/namespace
|
String |
getBaseUrl() |
String |
getSASToken(String url) |
void |
setFqdn(String fqdn) |
void |
setNamespace(String namespace) |
void |
setPassword(String password) |
void |
setPort(String port) |
void |
setUsername(String username) |
disconnect, getAMQPClient, getCloudBlobContainer, getRestClient, getSkipConnectivityTest, isConnected, setMuleContext, setSkipConnectivityTest, testConnectivity, testConnectivityAmqpClient
@Connect @TestConnectivity public void connect(@ConnectionKey@FriendlyName(value="Service Namespace")@Placement(group="Connection",order=1) String namespace, @ConnectionKey@FriendlyName(value="Username")@Placement(group="Connection",order=2) String username, @FriendlyName(value="Password")@Placement(group="Connection",order=3)@Password String password, @FriendlyName(value="Fully Qualified Domain Name")@Placement(group="Connection",order=4) String fqdn, @FriendlyName(value="Port")@Placement(group="Connection",order=5)@Default(value="9355") String port, @FriendlyName(value="Disable SSL certificate validation")@Placement(group="Connection",order=6)@Default(value="false") Boolean disableCnCheck) throws org.mule.api.ConnectionException
username
- Shared Key Namepassword
- Shared Keynamespace
- Azure Service Namespacefqdn
- Fully Qualified Domain Nameport
- disableCnCheck
- 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 String getBaseUrl()
getBaseUrl
in interface ConnectionStrategy
getBaseUrl
in class BaseConnectionStrategy
public void setUsername(String username)
public void setPassword(String password)
public void setNamespace(String namespace)
public void setFqdn(String fqdn)
public void setPort(String port)
Copyright © 2010–2017. All rights reserved.