org.usergrid.mq
Class QueueQuery
java.lang.Object
org.usergrid.mq.Query
org.usergrid.mq.QueueQuery
public class QueueQuery
- extends Query
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 |
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 |
QueueQuery
public QueueQuery()
QueueQuery
public QueueQuery(Query q)
QueueQuery
public QueueQuery(QueueQuery q)
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.