org.usergrid.mq.cassandra
Class QueueManagerFactoryImpl

java.lang.Object
  extended by 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
           
 
Constructor Summary
QueueManagerFactoryImpl(CassandraService cass, CounterUtils counterUtils)
          Must be constructed with a CassandraClientPool.
 
Method Summary
 String getImpementationDescription()
          A string description provided by the implementing class.
 QueueManager getQueueManager(UUID applicationId)
          Gets the entity manager.
 void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

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
Constructor Detail

QueueManagerFactoryImpl

public QueueManagerFactoryImpl(CassandraService cass,
                               CounterUtils counterUtils)
Must be constructed with a CassandraClientPool.

Parameters:
cass - the cassandra client pool
counterUtils - the CounterUtils
Method Detail

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.