org.apache.james.mailbox.hbase.user

Class HBaseSubscriptionMapper

java.lang.Object

org.apache.james.mailbox.store.transaction.NonTransactionalMapper

org.apache.james.mailbox.hbase.HBaseNonTransactionalMapper

org.apache.james.mailbox.hbase.user.HBaseSubscriptionMapper

All Implemented Interfaces:

Mapper, SubscriptionMapper

public class HBaseSubscriptionMapper
extends HBaseNonTransactionalMapper
implements SubscriptionMapper

HBase implementation of a SubscriptionMapper. I don't know if this class is thread-safe!

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.james.mailbox.store.transaction.Mapper

Mapper.Transaction<T>, Mapper.VoidTransaction

Constructor Summary

Constructors

Constructor and Description
HBaseSubscriptionMapper(org.apache.hadoop.conf.Configuration conf)

Method Summary

Methods

Modifier and Type	Method and Description
void	delete(Subscription subscription) Deletes the given subscription.
Subscription	findMailboxSubscriptionForUser(String user, String mailbox) Finds any subscriptions for a given user to the given mailbox.
List<Subscription>	findSubscriptionsForUser(String user) Finds subscriptions for the given user.
void	save(Subscription subscription) Saves the given subscription.

Methods inherited from class org.apache.james.mailbox.hbase.HBaseNonTransactionalMapper

endRequest

Methods inherited from class org.apache.james.mailbox.store.transaction.NonTransactionalMapper

execute

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.james.mailbox.store.transaction.Mapper

endRequest, execute

Constructor Detail

HBaseSubscriptionMapper

public HBaseSubscriptionMapper(org.apache.hadoop.conf.Configuration conf)

Method Detail

findMailboxSubscriptionForUser

public Subscription findMailboxSubscriptionForUser(String user,
                                          String mailbox)
                                            throws SubscriptionException

Description copied from interface: SubscriptionMapper

Finds any subscriptions for a given user to the given mailbox.

Specified by:

findMailboxSubscriptionForUser in interface SubscriptionMapper

Parameters:

user - not null

mailbox - not null

Returns:

Subscription, or null when the user is not subscribed to the given mailbox

Throws:

SubscriptionException

save

public void save(Subscription subscription)
          throws SubscriptionException

Description copied from interface: SubscriptionMapper

Saves the given subscription.

Specified by:

save in interface SubscriptionMapper

Parameters:

subscription - not null

Throws:

SubscriptionException

See Also:

SubscriptionMapper.save(Subscription)

findSubscriptionsForUser

public List<Subscription> findSubscriptionsForUser(String user)
                                            throws SubscriptionException

Description copied from interface: SubscriptionMapper

Finds subscriptions for the given user.

Specified by:

findSubscriptionsForUser in interface SubscriptionMapper

Parameters:

user - not null

Returns:

not null

Throws:

SubscriptionException

See Also:

SubscriptionMapper.findSubscriptionsForUser(java.lang.String)

delete

public void delete(Subscription subscription)
            throws SubscriptionException

Description copied from interface: SubscriptionMapper

Deletes the given subscription.

Specified by:

delete in interface SubscriptionMapper

Parameters:

subscription - not null

Throws:

SubscriptionException

See Also:

SubscriptionMapper.delete(Subscription)