Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.ConcurrentHashMap<java.lang.String,java.util.List<Subscriber>> |
subscribers
Deprecated.
|
private java.util.concurrent.ConcurrentHashMap<java.lang.String,java.util.concurrent.ConcurrentHashMap<java.lang.String,SubscriptionSummary>> |
summaries
Deprecated.
|
Constructor and Description |
---|
InMemoryHubDAO()
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
Subscriber |
addSubscriber(Subscriber subscriber)
Deprecated.
|
Subscriber |
findSubscriber(java.lang.String topic,
java.lang.String callbackUrl)
Deprecated.
|
void |
handleSummary(java.lang.String topic,
SubscriptionSummary summary)
Deprecated.
|
void |
removeSubscriber(java.lang.String topic,
java.lang.String callback)
Deprecated.
|
java.util.List<? extends Subscriber> |
subscribersForTopic(java.lang.String topic)
Deprecated.
|
java.util.List<? extends SubscriptionSummary> |
summariesForTopic(java.lang.String topic)
Deprecated.
|
private final java.util.concurrent.ConcurrentHashMap<java.lang.String,java.util.List<Subscriber>> subscribers
private final java.util.concurrent.ConcurrentHashMap<java.lang.String,java.util.concurrent.ConcurrentHashMap<java.lang.String,SubscriptionSummary>> summaries
public Subscriber addSubscriber(Subscriber subscriber)
addSubscriber
in interface HubDAO
public void handleSummary(java.lang.String topic, SubscriptionSummary summary)
handleSummary
in interface HubDAO
public java.util.List<? extends Subscriber> subscribersForTopic(java.lang.String topic)
subscribersForTopic
in interface HubDAO
public java.util.List<? extends SubscriptionSummary> summariesForTopic(java.lang.String topic)
summariesForTopic
in interface HubDAO
public Subscriber findSubscriber(java.lang.String topic, java.lang.String callbackUrl)
findSubscriber
in interface HubDAO
public void removeSubscriber(java.lang.String topic, java.lang.String callback)
removeSubscriber
in interface HubDAO