org.usergrid.mq.cassandra
Class CassandraMQUtils

java.lang.Object
  extended by org.usergrid.mq.cassandra.CassandraMQUtils

public class CassandraMQUtils
extends Object


Field Summary
static me.prettyprint.cassandra.serializers.BytesArraySerializer bae
           
static me.prettyprint.cassandra.serializers.ByteBufferSerializer be
           
static me.prettyprint.cassandra.serializers.DynamicCompositeSerializer dce
           
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
CassandraMQUtils()
           
 
Method Summary
static me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> addMessageToMutator(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m, Message message, long timestamp)
           
static me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> addQueueToMutator(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m, Queue queue, long timestamp)
           
static Message deserializeMessage(List<me.prettyprint.hector.api.beans.HColumn<String,ByteBuffer>> columns)
           
static Queue deserializeQueue(List<me.prettyprint.hector.api.beans.HColumn<String,ByteBuffer>> columns)
           
static long getLongFromRowKey(ByteBuffer bytes)
           
static ByteBuffer getQueueShardRowKey(UUID uuid, long ts)
           
static UUID getUUIDFromRowKey(ByteBuffer bytes)
           
static void logBatchOperation(String operation, Object columnFamily, Object key, Object columnName, Object columnValue, long timestamp)
           
static Map<ByteBuffer,ByteBuffer> serializeMessage(Message message)
          Encode a message into a set of columns.
static Map<ByteBuffer,ByteBuffer> serializeQueue(Queue queue)
           
 
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

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

CassandraMQUtils

public CassandraMQUtils()
Method Detail

logBatchOperation

public static void logBatchOperation(String operation,
                                     Object columnFamily,
                                     Object key,
                                     Object columnName,
                                     Object columnValue,
                                     long timestamp)

serializeMessage

public static Map<ByteBuffer,ByteBuffer> serializeMessage(Message message)
Encode a message into a set of columns. JMS properties are encoded as strings and longs everything else is binary JSON.

Parameters:
message -
Returns:

addMessageToMutator

public static me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> addMessageToMutator(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m,
                                                                                         Message message,
                                                                                         long timestamp)

deserializeMessage

public static Message deserializeMessage(List<me.prettyprint.hector.api.beans.HColumn<String,ByteBuffer>> columns)

serializeQueue

public static Map<ByteBuffer,ByteBuffer> serializeQueue(Queue queue)

deserializeQueue

public static Queue deserializeQueue(List<me.prettyprint.hector.api.beans.HColumn<String,ByteBuffer>> columns)

addQueueToMutator

public static me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> addQueueToMutator(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m,
                                                                                       Queue queue,
                                                                                       long timestamp)

getQueueShardRowKey

public static ByteBuffer getQueueShardRowKey(UUID uuid,
                                             long ts)

getUUIDFromRowKey

public static UUID getUUIDFromRowKey(ByteBuffer bytes)

getLongFromRowKey

public static long getLongFromRowKey(ByteBuffer bytes)


Copyright © 2013. All Rights Reserved.