org.usergrid.mq.cassandra
Class CassandraMQUtils
java.lang.Object
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
|
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 |
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
CassandraMQUtils
public CassandraMQUtils()
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.