atavism.server.messages

Class NamespaceSubscriptionManager

java.lang.Object

atavism.server.messages.SubscriptionManager

atavism.server.messages.NamespaceSubscriptionManager

All Implemented Interfaces:

MessageCallback, MessageDispatch, com.github.benmanes.caffeine.cache.RemovalListener<atavism.server.messages.DeferredMessage,Message>

public class NamespaceSubscriptionManager
extends SubscriptionManager

Nested Class Summary

Nested classes/interfaces inherited from class atavism.server.messages.SubscriptionManager

SubscriptionManager.SubscriptionKey

Field Summary

Fields inherited from interface atavism.msgsys.MessageCallback

NO_FLAGS, RESPONSE_EXPECTED

Method Summary

Modifier and Type	Method and Description
protected MessageTypeFilter	createFilter(java.util.Collection<MessageType> types)
static SubscriptionManager	get(java.util.Collection<Namespace> namespaces)
static SubscriptionManager	get(int flags, java.util.Collection<Namespace> namespaces)

Methods inherited from class atavism.server.messages.SubscriptionManager

get, get, get, handleMessage, onRemoval, start, subscribe, subscribe, subscribe, unsubscribe, unsubscribe, unsubscribe, unsubscribe

Methods inherited from class java.lang.Object

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

Method Detail

get

public static SubscriptionManager get(java.util.Collection<Namespace> namespaces)

get

public static SubscriptionManager get(int flags,
                                      java.util.Collection<Namespace> namespaces)

createFilter

protected MessageTypeFilter createFilter(java.util.Collection<MessageType> types)

Overrides:

createFilter in class SubscriptionManager