public class

CassandraDBObjectStore

extends Object
implements MuleContextAware PartitionableObjectStore<T extends Serializable>
java.lang.Object
   ↳ com.mulesoft.mule.cassandradb.CassandraDBObjectStore

Summary

Fields
private static String FALLBACK_PARTITION_NAME
private Cassandra.Client client Cassandra Client
private ConsistencyLevel consistencyLevel Consistency Level.
private MuleContext context
private String defaultPartitionName
private String host
private String keyspace
protected static final Log logger
private String password
private int port
private TTransport tr Generic class that encapsulates the I/O layer.
private String username
Public Constructors
CassandraDBObjectStore()
Public Methods
List<Serializable> allKeys()
List<Serializable> allKeys(String partition)
List<String> allPartitions()
void close()
void close(String s)
boolean contains(Serializable key, String partition)
boolean contains(Serializable key)
void disposePartition(String partitionName)
ConsistencyLevel getConsistencyLevel()
boolean isPersistent()
void open(String partition)
void open()
Serializable remove(Serializable key, String partition)
Serializable remove(Serializable key)
Serializable retrieve(Serializable key)
Serializable retrieve(Serializable key, String partition)
void setClient(Cassandra.Client client)
void setConsistencyLevel(ConsistencyLevel consistencyLevel)
void setDefaultPartitionName(String defaultPartitionName)
void setHost(String host)
void setKeyspace(String keyspace)
void setMuleContext(MuleContext muleContext)
void setPassword(String password)
void setPort(int port)
void setUsername(String username)
void store(Serializable key, Serializable value)
void store(Serializable key, Serializable value, String partition)
[Expand]
Inherited Methods
From class java.lang.Object
From interface org.mule.api.context.MuleContextAware
From interface org.mule.api.store.ListableObjectStore
From interface org.mule.api.store.ObjectStore
From interface org.mule.api.store.PartitionableObjectStore

Fields

private static String FALLBACK_PARTITION_NAME

private Cassandra.Client client

Cassandra Client

private ConsistencyLevel consistencyLevel

Consistency Level. Can be one of ANY, ONE (default), TWO, THREE, QUORUM, LOCAL_QUORUM, EACH_QUORUM, ALL. See http://wiki.apache.org/cassandra/API for more details.

private MuleContext context

private String defaultPartitionName

private String host

private String keyspace

protected static final Log logger

private String password

private int port

private TTransport tr

Generic class that encapsulates the I/O layer. This is basically a thin wrapper around the combined functionality of Java input/output streams.

private String username

Public Constructors

public CassandraDBObjectStore ()

Public Methods

public List<Serializable> allKeys ()

Throws
ObjectStoreException

public List<Serializable> allKeys (String partition)

Parameters
partition
Throws
ObjectStoreException

public List<String> allPartitions ()

Throws
ObjectStoreException

public void close ()

Throws
ObjectStoreException

public void close (String s)

Parameters
s
Throws
ObjectStoreException

public boolean contains (Serializable key, String partition)

Parameters
key
partition
Throws
ObjectStoreException

public boolean contains (Serializable key)

Parameters
key
Throws
ObjectStoreException

public void disposePartition (String partitionName)

Parameters
partitionName
Throws
ObjectStoreException

public ConsistencyLevel getConsistencyLevel ()

public boolean isPersistent ()

public void open (String partition)

Parameters
partition
Throws
ObjectStoreException

public void open ()

Throws
ObjectStoreException

public Serializable remove (Serializable key, String partition)

Parameters
key
partition
Throws
ObjectStoreException

public Serializable remove (Serializable key)

Parameters
key
Throws
ObjectStoreException

public Serializable retrieve (Serializable key)

Parameters
key
Throws
ObjectStoreException

public Serializable retrieve (Serializable key, String partition)

Parameters
key
partition
Throws
ObjectStoreException

public void setClient (Cassandra.Client client)

Parameters
client

public void setConsistencyLevel (ConsistencyLevel consistencyLevel)

Parameters
consistencyLevel

public void setDefaultPartitionName (String defaultPartitionName)

Parameters
defaultPartitionName

public void setHost (String host)

Parameters
host

public void setKeyspace (String keyspace)

Parameters
keyspace

public void setMuleContext (MuleContext muleContext)

Parameters
muleContext

public void setPassword (String password)

Parameters
password

public void setPort (int port)

Parameters
port

public void setUsername (String username)

Parameters
username

public void store (Serializable key, Serializable value)

Parameters
key
value
Throws
ObjectStoreException

public void store (Serializable key, Serializable value, String partition)

Parameters
key
value
partition
Throws
ObjectStoreException