public class QCNSubscription extends QuerySubscription
Constructor and Description |
---|
QCNSubscription(DataServicePersistenceContext context, ObjectLevelReadQuery query, java.util.Map<java.lang.String,java.lang.String> parameters) |
Modifier and Type | Method and Description |
---|---|
DataServiceChangeNotificationListener |
getDatabaseEventListener() |
boolean |
isIgnoreOwnTransactions() |
void |
newObject(java.lang.String queryName, java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
Retrieve the changed object based on its ROWID.
|
void |
removedObject(java.lang.String queryName, java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
Attempt to retrieve the removedObject from the cache.
|
java.lang.Object |
retrieveChangedObject(java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
Search for the object that was changed based on it's rowId
|
void |
setDatabaseEventListener(DataServiceChangeNotificationListener databaseEventListener) |
void |
setIgnoreOwnTransactions(boolean ignoreOwnTransactions) |
void |
unsubscribe() |
void |
updatedObject(java.lang.String queryName, java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
Retrieve the changed object based on its ROWID.
|
getParameters, getSubscriptionId
addClientNotifier, getClientNotifiers, getContext, newObject, notifierClosed, removeClientNotifier, removedObject, updatedObject
public QCNSubscription(DataServicePersistenceContext context, ObjectLevelReadQuery query, java.util.Map<java.lang.String,java.lang.String> parameters)
public DataServiceChangeNotificationListener getDatabaseEventListener()
public boolean isIgnoreOwnTransactions()
public void setDatabaseEventListener(DataServiceChangeNotificationListener databaseEventListener)
public void setIgnoreOwnTransactions(boolean ignoreOwnTransactions)
public void newObject(java.lang.String queryName, java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
queryName
-entityName
-transactionId
-rowId
-public void removedObject(java.lang.String queryName, java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
queryName
-entityName
-transactionId
-rowId
-public void updatedObject(java.lang.String queryName, java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
queryName
-entityName
-transactionId
-rowId
-public java.lang.Object retrieveChangedObject(java.lang.String entityName, java.lang.String transactionId, java.lang.String rowId)
entityName
-transactionId
-rowId
-cacheOnly
-public void unsubscribe()
unsubscribe
in class Subscription