Class NettyExecutorProtocolHolder

java.lang.Object

pt.unl.fct.di.novasys.babel2.core.AbstractBabelProtocolHolder

pt.unl.fct.di.novasys.babel2.core.NettyExecutorProtocolHolder

All Implemented Interfaces:

BabelProtocolHolder

public final class NettyExecutorProtocolHolder
extends AbstractBabelProtocolHolder

Protocol holder implementation executing protocol event handlers on a Netty EventLoopGroup.

Uses a high-performance lock-free MPSC event queue to serialize event processing on the Netty event loop.

Field Summary

Fields inherited from class AbstractBabelProtocolHolder

protocol

Modifier and Type	Field	Description
protected final BabelProtocol	protocol	The managed protocol instance.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	NettyExecutorProtocolHolder(BabelProtocol protocol, Set<ProtocolExtension<? extends BabelProtocol>> extensions, io.netty.channel.EventLoopGroup executor, int maxQueueCapacity)	Constructs a new Netty executor protocol holder.

Method Summary

Modifier and Type	Method	Description
void	deliverEvent(BabelEvent event)	Enqueues or delivers an event to the underlying protocol.

Methods inherited from class AbstractBabelProtocolHolder

createHandler, eventHandlers, getInnerProtocol, holdsProtocol, interestedEvents, interestedInMessages, interestedOutFailedMessages, interestedOutSuccessMessages, invokeHandler, invokeHandler, invokeHandler, invokeHandler

Modifier and Type	Method	Description
<T> T	createHandler(Method method, MethodHandles.Lookup lookup, Class<? extends BabelProtocol> protocolClass, Class<T> handlerInterface, String handlerMethodName, Class<?>[] erasedParamType, Class<?>[] actualParamType)	Creates a typed functional-interface handler for the given method using LambdaMetafactory.
Map<Class<? extends ProtocolEvent>, EventHandler<? extends ProtocolEvent>>	eventHandlers()	Returns the mapping of handled ProtocolEvent classes to their compiled event handlers.
BabelProtocol	getInnerProtocol()	Returns the underlying protocol instance managed by this holder.
boolean	holdsProtocol(Class<? extends BabelProtocol> protocolClass)	Returns whether this holder manages a protocol that is an instance of or assignable to the given protocol class.
Set<Class<? extends ProtocolEvent>>	interestedEvents()	Returns the set of ProtocolEvent classes that this protocol has registered interest in.
Set<Class<? extends BabelMessage>>	interestedInMessages()	Returns the set of BabelMessage classes that this protocol is interested in receiving.
Set<Class<? extends BabelMessage>>	interestedOutFailedMessages()	Returns the set of BabelMessage classes for which this protocol handles delivery failure.
Set<Class<? extends BabelMessage>>	interestedOutSuccessMessages()	Returns the set of BabelMessage classes for which this protocol handles successful delivery.
protected void	invokeHandler(MessageInEvent event)	Invokes the compiled handler for the specified inbound message event.
protected void	invokeHandler(MessageOutFailedEvent event)	Invokes the compiled handler for the specified outbound message failure event.
protected void	invokeHandler(MessageOutSuccessEvent event)	Invokes the compiled handler for the specified outbound message success event.
protected void	invokeHandler(ProtocolEvent event)	Invokes the compiled handler for the specified protocol event.

Methods inherited from class Object

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

Constructor Details

NettyExecutorProtocolHolder

protected NettyExecutorProtocolHolder(BabelProtocol protocol,
 Set<ProtocolExtension<? extends BabelProtocol>> extensions,
 io.netty.channel.EventLoopGroup executor,
 int maxQueueCapacity)

Constructs a new Netty executor protocol holder.

Parameters:

protocol - the managed protocol instance

extensions - registered protocol extensions

executor - the Netty event loop group executing event handlers

maxQueueCapacity - maximum capacity of the internal event queue

Method Details

deliverEvent

public void deliverEvent(BabelEvent event)

Description copied from interface: BabelProtocolHolder

Enqueues or delivers an event to the underlying protocol.

Parameters:

event - the event to deliver