org.usergrid.mq
Class QueueQuery

java.lang.Object
  extended by org.usergrid.mq.Query
      extended by org.usergrid.mq.QueueQuery

public class QueueQuery
extends Query


Nested Class Summary
 
Nested classes/interfaces inherited from class org.usergrid.mq.Query
Query.CounterFilterPredicate, Query.FilterOperator, Query.FilterPredicate, Query.SortDirection, Query.SortPredicate
 
Field Summary
 
Fields inherited from class org.usergrid.mq.Query
categories, connection, counterFilters, cursor, DEFAULT_LIMIT, filterPredicates, finishTime, groups, identifiers, level, limit, limitSet, mergeSelectResults, pad, permissions, resolution, reversed, reversedSet, selectSubjects, sortPredicates, startResult, startTime, type, users
 
Constructor Summary
QueueQuery()
           
QueueQuery(Query q)
           
QueueQuery(QueueQuery q)
           
 
Method Summary
static QueueQuery fromQL(String ql)
           
static QueueQuery fromQueryParams(Map<String,List<String>> params)
           
 UUID getConsumerId()
           
static UUID getConsumerId(String consumer)
           
 UUID getLastMessageId()
           
 long getLastTimestamp()
           
 int getNextCount()
           
 QueuePosition getPosition()
           
 int getPreviousCount()
           
 boolean isPositionSet()
           
 boolean isSynchronized()
           
 boolean isUpdate()
           
static QueueQuery newQueryIfNull(QueueQuery query)
           
 void setConsumerId(UUID consumerId)
           
 void setLastMessageId(UUID lastMessageId)
           
 void setLastTimestamp(long lastTimestamp)
           
 void setNextCount(int nextCount)
           
 void setPosition(QueuePosition position)
           
 void setPositionIfUnset(QueuePosition position)
           
 void setPreviousCount(int previousCount)
           
 void setSynchronized(boolean _synchronized)
           
 void setUpdate(boolean update)
           
 String toString()
           
 QueueQuery withConsumer(String consumer)
           
 QueueQuery withConsumerId(UUID consumerId)
           
 QueueQuery withLastMessageId(UUID lastMessageId)
           
 QueueQuery withLastTimestamp(long lastTimestamp)
           
 QueueQuery withNextCount(int nextCount)
           
 QueueQuery withPosition(QueuePosition position)
           
 QueueQuery withPositionInUnset(QueuePosition position)
           
 QueueQuery withPreviousCount(int previousCount)
           
 QueueQuery withSynchronized(boolean _synchronized)
           
 QueueQuery withUpdate(boolean update)
           
 
Methods inherited from class org.usergrid.mq.Query
addCategory, addCounterFilter, addEqualityFilter, addFilter, addFilter, addFilter, addGroup, addIdentifier, addSelect, addSelect, addSort, addSort, addSort, addUser, containsEmailIdentifiersOnly, containsNameIdentifiersOnly, containsNameOrEmailIdentifiersOnly, containsSingleEmailIdentifier, containsSingleNameIdentifier, containsSingleNameOrEmailIdentifier, containsSingleUuidIdentifier, containsUuidIdentifersOnly, findForProperty, fromEmail, fromIdentifier, fromJsonString, fromName, fromUUID, getCategories, getConnectionType, getCounterFilters, getCursor, getEmailIdentifiers, getEntityType, getEqualityFilters, getFilterForProperty, getFilterPredicates, getFinishTime, getGroups, getIdentifiers, getLimit, getLimit, getNameAndEmailIdentifiers, getNameIdentifiers, getPermissions, getResolution, getResultsLevel, getSelectAssignments, getSelectionResult, getSelectionResults, getSelectSubjects, getSingleEmailIdentifier, getSingleNameIdentifier, getSingleNameOrEmailIdentifier, getSingleUuidIdentifier, getSortPredicates, getStartResult, getStartTime, getUsers, getUuidIdentifiers, hasFilterPredicates, hasFilterPredicatesExcludingSubkeys, hasFiltersForProperty, hasFiltersForProperty, hasSelectSubjects, hasSortPredicates, isIdsOnly, isLimitSet, isMergeSelectResults, isPad, isReversed, isReversedSet, newQueryIfNull, removeFiltersForProperty, searchForProperty, setCategories, setConnectionType, setCounterFilters, setCursor, setEntityType, setFinishTime, setGroups, setIdentifiers, setIdsOnly, setLimit, setMergeSelectResults, setPad, setPermissions, setResolution, setResultsLevel, setReversed, setStartResult, setStartTime, setUsers, withConnectionType, withCursor, withEntityType, withLimit, withMergeSelectResults, withPermissions, withResultsLevel, withStartResult
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

QueueQuery

public QueueQuery()

QueueQuery

public QueueQuery(Query q)

QueueQuery

public QueueQuery(QueueQuery q)
Method Detail

newQueryIfNull

public static QueueQuery newQueryIfNull(QueueQuery query)

fromQL

public static QueueQuery fromQL(String ql)

fromQueryParams

public static QueueQuery fromQueryParams(Map<String,List<String>> params)

getConsumerId

public UUID getConsumerId()

setConsumerId

public void setConsumerId(UUID consumerId)

withConsumerId

public QueueQuery withConsumerId(UUID consumerId)

withConsumer

public QueueQuery withConsumer(String consumer)

getLastTimestamp

public long getLastTimestamp()

setLastTimestamp

public void setLastTimestamp(long lastTimestamp)

withLastTimestamp

public QueueQuery withLastTimestamp(long lastTimestamp)

getLastMessageId

public UUID getLastMessageId()

setLastMessageId

public void setLastMessageId(UUID lastMessageId)

withLastMessageId

public QueueQuery withLastMessageId(UUID lastMessageId)

getPreviousCount

public int getPreviousCount()

setPreviousCount

public void setPreviousCount(int previousCount)

withPreviousCount

public QueueQuery withPreviousCount(int previousCount)

getNextCount

public int getNextCount()

setNextCount

public void setNextCount(int nextCount)

withNextCount

public QueueQuery withNextCount(int nextCount)

getPosition

public QueuePosition getPosition()

isPositionSet

public boolean isPositionSet()

setPosition

public void setPosition(QueuePosition position)

setPositionIfUnset

public void setPositionIfUnset(QueuePosition position)

withPosition

public QueueQuery withPosition(QueuePosition position)

withPositionInUnset

public QueueQuery withPositionInUnset(QueuePosition position)

getConsumerId

public static UUID getConsumerId(String consumer)

isSynchronized

public boolean isSynchronized()

setSynchronized

public void setSynchronized(boolean _synchronized)

withSynchronized

public QueueQuery withSynchronized(boolean _synchronized)

isUpdate

public boolean isUpdate()

setUpdate

public void setUpdate(boolean update)

withUpdate

public QueueQuery withUpdate(boolean update)

toString

public String toString()
Overrides:
toString in class Query


Copyright © 2013. All Rights Reserved.