org.mule.modules.cassandradb.configurations

Class BasicAuthConnectionStrategy

java.lang.Object

org.mule.modules.cassandradb.configurations.BasicAuthConnectionStrategy

@ConnectionManagement(configElementName="config",
                      friendlyName="Configuration")
public class BasicAuthConnectionStrategy
extends Object

Constructor Summary

Constructors

Constructor and Description
BasicAuthConnectionStrategy()

Method Summary

Modifier and Type	Method and Description
void	connect(String username, String password) Method invoked when a connection is required
String	connectionId() Connection Identifier
void	disconnect() Disconnect
CassandraClient	getCassandraClient()
String	getClusterName()
String	getClusterNodes()
com.datastax.driver.core.ProtocolOptions.Compression	getCompression()
String	getHost()
String	getKeyspace()
LoadBalancingPolicyEnum	getLoadBalancingPolicy()
int	getMaxSchemaAgreementWaitSeconds()
String	getPort()
com.datastax.driver.core.ProtocolVersion	getProtocolVersion()
boolean	isConnected() Are we connected
boolean	isSslEnabled()
void	setCassandraClient(CassandraClient cassandraClient)
void	setClusterName(String clusterName)
void	setClusterNodes(String clusterNodes)
void	setCompression(com.datastax.driver.core.ProtocolOptions.Compression compression)
void	setHost(String host)
void	setKeyspace(String keyspace)
void	setLoadBalancingPolicy(LoadBalancingPolicyEnum loadBalancingPolicy)
void	setMaxSchemaAgreementWaitSeconds(int maxSchemaAgreementWaitSeconds)
void	setPort(String port)
void	setProtocolVersion(com.datastax.driver.core.ProtocolVersion protocolVersion)
void	setSslEnabled(boolean sslEnabled)

Methods inherited from class java.lang.Object

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

Constructor Detail

BasicAuthConnectionStrategy

public BasicAuthConnectionStrategy()

Method Detail

getClusterNodes

public String getClusterNodes()

setClusterNodes

public void setClusterNodes(String clusterNodes)

connect

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

Method invoked when a connection is required

Parameters:

username - A username. NOTE: Please use a dummy username if you have disabled authentication

password - A password. NOTE: Leave empty if not required. If specified, the connector will try to login with this credentials

Throws:

org.mule.api.ConnectionException - if the connection is not established

disconnect

@Disconnect
public void disconnect()

Disconnect

isConnected

@ValidateConnection
public boolean isConnected()

Are we connected

Returns:

the connection status of the connector.

connectionId

@ConnectionIdentifier
public String connectionId()

Connection Identifier

Returns:

the connection identifier.

getHost

public String getHost()

Returns:

the host connection url.

setHost

public void setHost(String host)

getPort

public String getPort()

setPort

public void setPort(String port)

getKeyspace

public String getKeyspace()

setKeyspace

public void setKeyspace(String keyspace)

getClusterName

public String getClusterName()

setClusterName

public void setClusterName(String clusterName)

getProtocolVersion

public com.datastax.driver.core.ProtocolVersion getProtocolVersion()

setProtocolVersion

public void setProtocolVersion(com.datastax.driver.core.ProtocolVersion protocolVersion)

getMaxSchemaAgreementWaitSeconds

public int getMaxSchemaAgreementWaitSeconds()

setMaxSchemaAgreementWaitSeconds

public void setMaxSchemaAgreementWaitSeconds(int maxSchemaAgreementWaitSeconds)

getCompression

public com.datastax.driver.core.ProtocolOptions.Compression getCompression()

setCompression

public void setCompression(com.datastax.driver.core.ProtocolOptions.Compression compression)

isSslEnabled

public boolean isSslEnabled()

setSslEnabled

public void setSslEnabled(boolean sslEnabled)

getLoadBalancingPolicy

public LoadBalancingPolicyEnum getLoadBalancingPolicy()

setLoadBalancingPolicy

public void setLoadBalancingPolicy(LoadBalancingPolicyEnum loadBalancingPolicy)

getCassandraClient

public CassandraClient getCassandraClient()

setCassandraClient

public void setCassandraClient(CassandraClient cassandraClient)