org.mule.module.dynamicscrm.connection

Class BaseCrmConnectionStrategy

java.lang.Object

org.mule.module.dynamicscrm.connection.BaseCrmConnectionStrategy

Direct Known Subclasses:

ClaimsConnectionStrategy, KerberosConnectionStrategy, LegacyConnectionStrategy, NtlmConnectionStrategy, OnlineConnectionStrategy

public abstract class BaseCrmConnectionStrategy
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static Pattern	urlPattern
protected String	username

Constructor Summary

Constructors

Constructor and Description
BaseCrmConnectionStrategy()

Method Summary

Modifier and Type	Method and Description
protected void	callSimpleQueryToTestConnection(IOrganizationService client)
protected void	configureHttpConduit(org.apache.cxf.transport.http.HTTPConduit httpConduit)
void	connect(String username, String password, String organizationServiceUrl) Creates and establishes a new connection against the CRM instance.
protected org.apache.http.impl.client.HttpClientBuilder	createHttpClientBuilder()
protected abstract IOrganizationService	createOrganizationServiceClient(String username, String password, String organizationServiceUrl)
void	destroySession() Disconnects the client from the current session
Integer	getConnectionTimeout()
boolean	getDisableCnCheck()
org.mule.api.MuleContext	getMuleContext()
protected org.apache.cxf.Bus	getNewBusForClient(boolean policyEngineEnabled)
protected IOrganizationService	getNewClientInstance(URL organizationServiceWsdlUrl, boolean policyEngineEnabled, WebServiceFeature... features)
protected OrganizationService	getNewServiceInstance(org.apache.cxf.Bus bus, URL organizationServiceWsdlUrl)
IOrganizationService	getOrganizationServiceClient()
protected Document	getOrganizationServiceWsdl(URL organizationServiceWsdlUrl)
String	getProxyConnection()
String	getSessionId() Returns the session id for the current connection
boolean	isConnected() Returns whether the client is connected
void	setConnectionTimeout(Integer connectionTimeout)
void	setDisableCnCheck(Boolean disableCnCheck)
void	setMuleContext(org.mule.api.MuleContext context)
void	setProxyConnection(String proxyConnection)
protected abstract void	testClientConnectivity(IOrganizationService client, String organizationServiceUrl)
void	testConnectivity(String username, String password, String organizationServiceUrl)

Methods inherited from class java.lang.Object

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

Field Detail

urlPattern

protected static final Pattern urlPattern

username

protected String username

Constructor Detail

BaseCrmConnectionStrategy

public BaseCrmConnectionStrategy()

Method Detail

connect

@Connect
public void connect(@ConnectionKey
                             String username,
                             @Password
                             String password,
                             @ConnectionKey
                             String organizationServiceUrl)
                      throws org.mule.api.ConnectionException

Creates and establishes a new connection against the CRM instance.

Parameters:

username - User to authenticate with.

password - Password for the user to authenticate with.

organizationServiceUrl - The path to the Microsoft Dynamics CRM Organization service (https://crm.myorganization.com/XRMServices/2011/Organization.svc).

Throws:

org.mule.api.ConnectionException - If the connection failed

testConnectivity

@TestConnectivity
public void testConnectivity(String username,
                                               String password,
                                               String organizationServiceUrl)
                                        throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

destroySession

@Disconnect
public void destroySession()

Disconnects the client from the current session

getSessionId

@ConnectionIdentifier
public String getSessionId()

Returns the session id for the current connection

Returns:

the session id for the current connection

isConnected

@ValidateConnection
public boolean isConnected()

Returns whether the client is connected

Returns:

whether the client is connected

createHttpClientBuilder

protected org.apache.http.impl.client.HttpClientBuilder createHttpClientBuilder()
                                                                         throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

getNewBusForClient

protected org.apache.cxf.Bus getNewBusForClient(boolean policyEngineEnabled)

getNewServiceInstance

protected OrganizationService getNewServiceInstance(org.apache.cxf.Bus bus,
                                                    URL organizationServiceWsdlUrl)
                                             throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

getNewClientInstance

protected IOrganizationService getNewClientInstance(URL organizationServiceWsdlUrl,
                                                    boolean policyEngineEnabled,
                                                    WebServiceFeature... features)
                                             throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

createOrganizationServiceClient

protected abstract IOrganizationService createOrganizationServiceClient(String username,
                                                                        String password,
                                                                        String organizationServiceUrl)
                                                                 throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

testClientConnectivity

protected abstract void testClientConnectivity(IOrganizationService client,
                                               String organizationServiceUrl)
                                        throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

configureHttpConduit

protected void configureHttpConduit(org.apache.cxf.transport.http.HTTPConduit httpConduit)

getOrganizationServiceWsdl

protected Document getOrganizationServiceWsdl(URL organizationServiceWsdlUrl)
                                       throws org.mule.api.ConnectionException

Throws:

org.mule.api.ConnectionException

callSimpleQueryToTestConnection

protected void callSimpleQueryToTestConnection(IOrganizationService client)
                                        throws IOrganizationServiceRetrieveMultipleOrganizationServiceFaultFaultFaultMessage

Throws:

IOrganizationServiceRetrieveMultipleOrganizationServiceFaultFaultFaultMessage

getDisableCnCheck

public boolean getDisableCnCheck()

setDisableCnCheck

public void setDisableCnCheck(Boolean disableCnCheck)

getConnectionTimeout

public Integer getConnectionTimeout()

setConnectionTimeout

public void setConnectionTimeout(Integer connectionTimeout)

getProxyConnection

public String getProxyConnection()

setProxyConnection

public void setProxyConnection(String proxyConnection)

getOrganizationServiceClient

public IOrganizationService getOrganizationServiceClient()

getMuleContext

public org.mule.api.MuleContext getMuleContext()

setMuleContext

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