org.usergrid.mq.cassandra
Class QueueManagerFactoryImpl
java.lang.Object
org.usergrid.mq.cassandra.QueueManagerFactoryImpl
- All Implemented Interfaces:
- org.springframework.beans.factory.Aware, org.springframework.context.ApplicationContextAware, QueueManagerFactory
public class QueueManagerFactoryImpl
- extends Object
- implements QueueManagerFactory, org.springframework.context.ApplicationContextAware
Field Summary |
static me.prettyprint.cassandra.serializers.BytesArraySerializer |
bae
|
static me.prettyprint.cassandra.serializers.ByteBufferSerializer |
be
|
static me.prettyprint.cassandra.serializers.DynamicCompositeSerializer |
dce
|
static String |
IMPLEMENTATION_DESCRIPTION
|
static me.prettyprint.cassandra.serializers.LongSerializer |
le
|
static org.slf4j.Logger |
logger
|
static me.prettyprint.cassandra.serializers.StringSerializer |
se
|
static me.prettyprint.cassandra.serializers.UUIDSerializer |
ue
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
logger
public static final org.slf4j.Logger logger
IMPLEMENTATION_DESCRIPTION
public static String IMPLEMENTATION_DESCRIPTION
se
public static final me.prettyprint.cassandra.serializers.StringSerializer se
be
public static final me.prettyprint.cassandra.serializers.ByteBufferSerializer be
ue
public static final me.prettyprint.cassandra.serializers.UUIDSerializer ue
bae
public static final me.prettyprint.cassandra.serializers.BytesArraySerializer bae
dce
public static final me.prettyprint.cassandra.serializers.DynamicCompositeSerializer dce
le
public static final me.prettyprint.cassandra.serializers.LongSerializer le
QueueManagerFactoryImpl
public QueueManagerFactoryImpl(CassandraService cass,
CounterUtils counterUtils)
- Must be constructed with a CassandraClientPool.
- Parameters:
cass
- the cassandra client poolcounterUtils
- the CounterUtils
getImpementationDescription
public String getImpementationDescription()
throws Exception
- Description copied from interface:
QueueManagerFactory
- A string description provided by the implementing class.
- Specified by:
getImpementationDescription
in interface QueueManagerFactory
- Returns:
- description text
- Throws:
Exception
- the exception
getQueueManager
public QueueManager getQueueManager(UUID applicationId)
- Description copied from interface:
QueueManagerFactory
- Gets the entity manager.
- Specified by:
getQueueManager
in interface QueueManagerFactory
- Parameters:
applicationId
- the application id
- Returns:
- EntityDao for the specfied parameters
setApplicationContext
public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
throws org.springframework.beans.BeansException
- Specified by:
setApplicationContext
in interface org.springframework.context.ApplicationContextAware
- Throws:
org.springframework.beans.BeansException
Copyright © 2013. All Rights Reserved.