atavism.server.messages

Class SubscriptionManager

java.lang.Object

atavism.server.messages.SubscriptionManager

All Implemented Interfaces:

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

Direct Known Subclasses:

NamespaceSubscriptionManager

public class SubscriptionManager
extends java.lang.Object
implements MessageDispatch, com.github.benmanes.caffeine.cache.RemovalListener<atavism.server.messages.DeferredMessage,Message>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	SubscriptionManager.SubscriptionKey

Field Summary

Fields inherited from interface atavism.msgsys.MessageCallback

NO_FLAGS, RESPONSE_EXPECTED

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SubscriptionManager(int subscriptionFlags)

Method Summary

Modifier and Type	Method and Description
protected MessageTypeFilter	createFilter(java.util.Collection<MessageType> types)
static SubscriptionManager	get()
static SubscriptionManager	get(int flags)
protected static SubscriptionManager	get(int flags, java.util.Collection<Namespace> namespaces, java.util.function.Function<SubscriptionManager.SubscriptionKey,SubscriptionManager> f)
void	handleMessage(Message msg, int flags) Handle message.
void	onRemoval(atavism.server.messages.DeferredMessage dm, Message message, com.github.benmanes.caffeine.cache.RemovalCause cause)
static void	start(MessageType... types)
void	subscribe(MessageDispatch subscriber, MessageType... types)
void	subscribe(MessageDispatch subscriber, OID oid, java.util.Collection<MessageType> types)
void	subscribe(MessageDispatch subscriber, OID oid, MessageType... types)
void	unsubscribe(MessageDispatch subscriber)
void	unsubscribe(MessageDispatch subscriber, OID oid)
void	unsubscribe(MessageDispatch subscriber, OID oid, java.util.Collection<MessageType> types)
void	unsubscribe(MessageDispatch subscriber, OID oid, MessageType... types)

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriptionManager

protected SubscriptionManager(int subscriptionFlags)

Method Detail

get

public static SubscriptionManager get()

get

public static SubscriptionManager get(int flags)

get

protected static SubscriptionManager get(int flags,
                                         java.util.Collection<Namespace> namespaces,
                                         java.util.function.Function<SubscriptionManager.SubscriptionKey,SubscriptionManager> f)

start

public static void start(MessageType... types)

createFilter

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

subscribe

public void subscribe(MessageDispatch subscriber,
                      OID oid,
                      java.util.Collection<MessageType> types)

subscribe

public void subscribe(MessageDispatch subscriber,
                      MessageType... types)

subscribe

public void subscribe(MessageDispatch subscriber,
                      OID oid,
                      MessageType... types)

unsubscribe

public void unsubscribe(MessageDispatch subscriber)

unsubscribe

public void unsubscribe(MessageDispatch subscriber,
                        OID oid)

unsubscribe

public void unsubscribe(MessageDispatch subscriber,
                        OID oid,
                        java.util.Collection<MessageType> types)

unsubscribe

public void unsubscribe(MessageDispatch subscriber,
                        OID oid,
                        MessageType... types)

handleMessage

public void handleMessage(Message msg,
                          int flags)

Description copied from interface: MessageCallback

Handle message.

Specified by:

handleMessage in interface MessageCallback

Parameters:

msg - Message sent from other agent.

flags - Bitwise OR of MessageCallback.NO_FLAGS, MessageCallback.RESPONSE_EXPECTED.

onRemoval

public void onRemoval(atavism.server.messages.DeferredMessage dm,
                      Message message,
                      com.github.benmanes.caffeine.cache.RemovalCause cause)

Specified by:

onRemoval in interface com.github.benmanes.caffeine.cache.RemovalListener<atavism.server.messages.DeferredMessage,Message>