public class OneUserSubscriptionStore extends JdbcAbstractStore
JdbcAbstractStore.Creator<T>, JdbcAbstractStore.DataType, JdbcAbstractStore.EntityPopulator<T>, JdbcAbstractStore.SqlOperation<R>, JdbcAbstractStore.StatementValues<T>
datasource, logger
Constructor and Description |
---|
OneUserSubscriptionStore(SecurityContext securityContext,
javax.sql.DataSource dataSource,
Container container,
java.lang.String subject) |
Modifier and Type | Method and Description |
---|---|
void |
allowSynchronization(Container container,
boolean sync) |
boolean |
isSubscribed(Container container) |
boolean |
isSyncAllowed(Container container) |
java.util.List<ContainerSubscription> |
listSubscriptions(java.lang.String type) |
void |
subscribe(Container container) |
void |
unsubscribe(Container container) |
void |
unsubscribeAll(java.lang.String subject) |
batchInsert, batchInsert, delete, delete, delete, doOrContinue, doOrFail, getConnection, insert, insert, insert, insert, insertAndReturn, insertWithSerial, lastInsertId, select, select, select, unique, unique, unique, unique, unique, update, update, update, update, update
public OneUserSubscriptionStore(SecurityContext securityContext, javax.sql.DataSource dataSource, Container container, java.lang.String subject)
public void subscribe(Container container) throws java.sql.SQLException
java.sql.SQLException
public boolean isSubscribed(Container container) throws java.sql.SQLException
java.sql.SQLException
public void unsubscribe(Container container) throws java.sql.SQLException
java.sql.SQLException
public void unsubscribeAll(java.lang.String subject) throws java.sql.SQLException
java.sql.SQLException
public java.util.List<ContainerSubscription> listSubscriptions(java.lang.String type) throws java.sql.SQLException
type
- might be null to search all subscriptionsjava.sql.SQLException
public void allowSynchronization(Container container, boolean sync) throws java.sql.SQLException
java.sql.SQLException
public boolean isSyncAllowed(Container container) throws java.sql.SQLException
java.sql.SQLException
Copyright © 2021. All Rights Reserved.