de.jw.cloud42.core.eventing.storage
Class DefaultSubscriberStore

java.lang.Object
  de.jw.cloud42.core.eventing.storage.DefaultSubscriberStore

All Implemented Interfaces:

SubscriberStore

public class DefaultSubscriberStore
extends java.lang.Object
implements SubscriberStore

Default implementation of a subscriber store. Uses a database with Hibernate to save Subscriptions.

Author:

fbitzer

Constructor Summary

DefaultSubscriberStore()

Method Summary

void	delete(java.lang.String subscriberID) Delete a subscriber.
Subscription	retrieve(java.lang.String id) Get a subscriber.
java.util.Iterator	retrieveAllSubscribers(java.lang.String topic) Get an iterator over all present subscribers for a specific topic.
void	store(Subscription s) Save a subscriber.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSubscriberStore

public DefaultSubscriberStore()

Method Detail

retrieve

public Subscription retrieve(java.lang.String id)

Get a subscriber.

Specified by:

retrieve in interface SubscriberStore

Returns:

The Subscription or null if no subscription with given id exists.

store

public void store(Subscription s)

Save a subscriber.

Specified by:

store in interface SubscriberStore

Parameters:

s - the Subscription to store.

topic - the topic for the subscription.

delete

public void delete(java.lang.String subscriberID)

Delete a subscriber.

Specified by:

delete in interface SubscriberStore

retrieveAllSubscribers

public java.util.Iterator retrieveAllSubscribers(java.lang.String topic)

Get an iterator over all present subscribers for a specific topic.

Specified by:

retrieveAllSubscribers in interface SubscriberStore

Parameters:

The - topic.

Returns: