Class MembershipProviderExtension

java.lang.Object

pt.unl.fct.di.novasys.babel2.core.membership.MembershipProviderExtension

All Implemented Interfaces:

ProtocolExtension<MembershipProviderBabelProtocol>, EventHandler<ProtocolEvent>

public class MembershipProviderExtension
extends Object
implements ProtocolExtension<MembershipProviderBabelProtocol>

ProtocolExtension that routes AskNeighbourSet events from consumer protocols to the associated MembershipProviderBabelProtocol.

When a consumer protocol calls askNeighbourSet, an AskNeighbourSet event is dispatched through the runtime. This extension intercepts those events and calls getNeighbours on the provider protocol, which is responsible for sending back a NeighbourSet response.

The extension does not handle any method-level annotations.

Register via MembershipProviderExtensionFactory on the BabelBootstrap.

See Also:

• MembershipProviderBabelProtocol
• MembershipProviderExtensionFactory

Field Summary

Fields inherited from interface EventHandler

HANDLER_METHOD_NAME

Modifier and Type	Field	Description
static final String	HANDLER_METHOD_NAME	The name of the functional method.

Constructor Summary

Constructors

Constructor	Description
MembershipProviderExtension(MembershipProviderBabelProtocol protocol)	Constructs a MembershipProviderExtension bound to the given provider protocol.

Method Summary

Modifier and Type	Method	Description
Set<Class<? extends ProtocolEvent>>	eventsClass()	Returns the set of ProtocolEvent types that this extension handles.
void	handleEvent(ProtocolEvent event)	Handles an AskNeighbourSet event by calling MembershipProviderBabelProtocol.getNeighbours(Class) on the provider.

Methods inherited from class Object

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

Methods inherited from interface ProtocolExtension

annotationClass, register

Modifier and Type	Method	Description
default Set<Class<? extends Annotation>>	annotationClass()	Returns the set of method-level annotation types that this extension processes.
default void	register(Method method, MethodHandles.Lookup lookup, MembershipProviderBabelProtocol protocol, BabelProtocolHolder holder, Annotation annotation)	Called by SharedExecutorProtocolHolder during initialisation for each method on the protocol that carries one of the annotations returned by ProtocolExtension.annotationClass().

Constructor Details

MembershipProviderExtension

public MembershipProviderExtension(MembershipProviderBabelProtocol protocol)

Constructs a MembershipProviderExtension bound to the given provider protocol.

Parameters:

protocol - the membership provider that will receive AskNeighbourSet callbacks

Method Details

handleEvent

public void handleEvent(ProtocolEvent event)

Handles an AskNeighbourSet event by calling MembershipProviderBabelProtocol.getNeighbours(Class) on the provider.

Specified by:

handleEvent in interface EventHandler<ProtocolEvent>

Specified by:

handleEvent in interface ProtocolExtension<MembershipProviderBabelProtocol>

Parameters:

event - the event to handle; must be an AskNeighbourSet

Throws:

IllegalArgumentException - if event is not an AskNeighbourSet

eventsClass

public Set<Class<? extends ProtocolEvent>> eventsClass()

Description copied from interface: ProtocolExtension

Returns the set of ProtocolEvent types that this extension handles. Events of these types are routed to ProtocolExtension.handleEvent(ProtocolEvent) instead of the protocol's own @UponBabelEvent-annotated handlers.

Specified by:

eventsClass in interface ProtocolExtension<MembershipProviderBabelProtocol>

Returns:

a list of event classes; may be empty