|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use Message | |
---|---|
org.usergrid.mq | |
org.usergrid.mq.cassandra | |
org.usergrid.persistence.cassandra |
Uses of Message in org.usergrid.mq |
---|
Methods in org.usergrid.mq that return Message | |
---|---|
Message |
QueueManager.getMessage(UUID messageId)
|
Message |
QueueManager.postToQueue(String queuePath,
Message message)
|
Methods in org.usergrid.mq that return types with arguments of type Message | |
---|---|
static List<Message> |
Message.fromList(List<Map<String,Object>> l)
|
List<Message> |
QueueResults.getMessages()
|
List<Message> |
QueueManager.postToQueue(String queuePath,
List<Message> messages)
|
static List<Message> |
Message.sort(List<Message> messages)
|
static List<Message> |
Message.sortReversed(List<Message> messages)
|
Methods in org.usergrid.mq with parameters of type Message | |
---|---|
static int |
Message.compare(Message m1,
Message m2)
|
Message |
QueueManager.postToQueue(String queuePath,
Message message)
|
Method parameters in org.usergrid.mq with type arguments of type Message | |
---|---|
List<Message> |
QueueManager.postToQueue(String queuePath,
List<Message> messages)
|
void |
QueueResults.setMessages(List<Message> messages)
|
static List<Message> |
Message.sort(List<Message> messages)
|
static List<Message> |
Message.sortReversed(List<Message> messages)
|
Constructors in org.usergrid.mq with parameters of type Message | |
---|---|
QueueResults(Message message)
|
Constructor parameters in org.usergrid.mq with type arguments of type Message | |
---|---|
QueueResults(List<Message> messages)
|
|
QueueResults(String path,
UUID queue,
List<Message> messages,
UUID last,
UUID consumer)
|
Uses of Message in org.usergrid.mq.cassandra |
---|
Methods in org.usergrid.mq.cassandra that return Message | |
---|---|
Message |
QueueManagerImpl.batchPostToQueue(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
String queuePath,
Message message,
MessageIndexUpdate indexUpdate,
long timestamp)
|
static Message |
CassandraMQUtils.deserializeMessage(List<me.prettyprint.hector.api.beans.HColumn<String,ByteBuffer>> columns)
|
Message |
MessageIndexUpdate.getMessage()
|
Message |
QueueManagerImpl.getMessage(UUID messageId)
|
Message |
QueueManagerImpl.postToQueue(String queuePath,
Message message)
|
Methods in org.usergrid.mq.cassandra that return types with arguments of type Message | |
---|---|
List<Message> |
QueueManagerImpl.postToQueue(String queuePath,
List<Message> messages)
|
Methods in org.usergrid.mq.cassandra with parameters of type Message | |
---|---|
static me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> |
CassandraMQUtils.addMessageToMutator(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m,
Message message,
long timestamp)
|
Message |
QueueManagerImpl.batchPostToQueue(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> batch,
String queuePath,
Message message,
MessageIndexUpdate indexUpdate,
long timestamp)
|
Message |
QueueManagerImpl.postToQueue(String queuePath,
Message message)
|
static Map<ByteBuffer,ByteBuffer> |
CassandraMQUtils.serializeMessage(Message message)
Encode a message into a set of columns. |
Method parameters in org.usergrid.mq.cassandra with type arguments of type Message | |
---|---|
List<Message> |
QueueManagerImpl.postToQueue(String queuePath,
List<Message> messages)
|
Constructors in org.usergrid.mq.cassandra with parameters of type Message | |
---|---|
MessageIndexUpdate(Message message)
|
Uses of Message in org.usergrid.persistence.cassandra |
---|
Methods in org.usergrid.persistence.cassandra that return Message | |
---|---|
Message |
EntityManagerImpl.storeEventAsMessage(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m,
Event event,
long timestamp)
|
Methods in org.usergrid.persistence.cassandra with parameters of type Message | |
---|---|
void |
CounterUtils.addMessageCounterMutations(me.prettyprint.hector.api.mutation.Mutator<ByteBuffer> m,
UUID applicationId,
UUID queueId,
Message msg,
long timestamp)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |