public class UserSubscriptionStore extends JdbcAbstractStore
JdbcAbstractStore.Creator<T>, JdbcAbstractStore.DataType, JdbcAbstractStore.EntityPopulator<T>, JdbcAbstractStore.SqlOperation<Res>, JdbcAbstractStore.StatementValues<T>
datasource, logger
Constructor and Description |
---|
UserSubscriptionStore(SecurityContext securityContext,
javax.sql.DataSource dataSource,
Container container) |
Modifier and Type | Method and Description |
---|---|
void |
allowSynchronization(java.lang.String subject,
Container container,
boolean sync) |
boolean |
isSubscribed(java.lang.String subject,
Container container) |
boolean |
isSyncAllowed(java.lang.String subject,
Container container) |
java.util.List<Container> |
listSubscriptions(java.lang.String subject,
java.lang.String type) |
void |
subscribe(java.lang.String subject,
Container container) |
void |
unsubscribe(java.lang.String subject,
Container container) |
void |
unsubscribeAll(java.lang.String subject) |
batchInsert, batchInsert, delete, doOrContinue, doOrFail, getConnection, insert, insert, insert, insert, insertAndReturn, insertWithSerial, inTransaction, lastInsertId, select, select, select, staticInTransaction, unique, unique, unique, unique, update, update, update, update, update
public UserSubscriptionStore(SecurityContext securityContext, javax.sql.DataSource dataSource, Container container)
public void subscribe(java.lang.String subject, Container container) throws java.sql.SQLException
java.sql.SQLException
public boolean isSubscribed(java.lang.String subject, Container container) throws java.sql.SQLException
java.sql.SQLException
public void unsubscribe(java.lang.String subject, 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<Container> listSubscriptions(java.lang.String subject, java.lang.String type) throws java.sql.SQLException
java.sql.SQLException
public void allowSynchronization(java.lang.String subject, Container container, boolean sync) throws java.sql.SQLException
java.sql.SQLException
public boolean isSyncAllowed(java.lang.String subject, Container container) throws java.sql.SQLException
java.sql.SQLException
Copyright © 2021. All Rights Reserved.