net.bluemind.user.persistence

Class UserSubscriptionStore

java.lang.Object

net.bluemind.core.jdbc.JdbcAbstractStore

net.bluemind.user.persistence.UserSubscriptionStore

public class UserSubscriptionStore
extends JdbcAbstractStore

Nested Class Summary

Nested classes/interfaces inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

JdbcAbstractStore.Creator<T>, JdbcAbstractStore.DataType, JdbcAbstractStore.EntityPopulator<T>, JdbcAbstractStore.SqlOperation<R>, JdbcAbstractStore.StatementValues<T>

Field Summary

Fields inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

datasource, logger

Constructor Summary

Constructors

Constructor and Description
UserSubscriptionStore(SecurityContext securityContext, javax.sql.DataSource dataSource, Container container)

Method Summary

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<java.lang.String>	listSubscriptions(java.lang.String subject, java.lang.String type)
void	subscribe(java.lang.String subject, Container container)
java.util.List<java.lang.String>	subscribers(java.lang.String containerUid)
void	unsubscribe(java.lang.String subject, java.lang.String containerUid)
void	unsubscribeAll(java.lang.String subject)

Methods inherited from class net.bluemind.core.jdbc.JdbcAbstractStore

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

UserSubscriptionStore

public UserSubscriptionStore(SecurityContext securityContext,
                             javax.sql.DataSource dataSource,
                             Container container)

Method Detail

subscribe

public void subscribe(java.lang.String subject,
                      Container container)
               throws java.sql.SQLException

Throws:

java.sql.SQLException

isSubscribed

public boolean isSubscribed(java.lang.String subject,
                            Container container)
                     throws java.sql.SQLException

Throws:

java.sql.SQLException

unsubscribe

public void unsubscribe(java.lang.String subject,
                        java.lang.String containerUid)
                 throws java.sql.SQLException

Throws:

java.sql.SQLException

unsubscribeAll

public void unsubscribeAll(java.lang.String subject)
                    throws java.sql.SQLException

Throws:

java.sql.SQLException

listSubscriptions

public java.util.List<java.lang.String> listSubscriptions(@NotNull
                                                          java.lang.String subject,
                                                          java.lang.String type)
                                                   throws java.sql.SQLException

Parameters:

subject - user uid

type - might be null to search all subscriptions

Returns:

a list of container uid the subject is subscribed to

Throws:

java.sql.SQLException

subscribers

public java.util.List<java.lang.String> subscribers(@NotNull
                                                    java.lang.String containerUid)
                                             throws java.sql.SQLException

Throws:

java.sql.SQLException

allowSynchronization

public void allowSynchronization(java.lang.String subject,
                                 Container container,
                                 boolean sync)
                          throws java.sql.SQLException

Throws:

java.sql.SQLException

isSyncAllowed

public boolean isSyncAllowed(java.lang.String subject,
                             Container container)
                      throws java.sql.SQLException

Throws:

java.sql.SQLException