Class NettyExecutorProtocolHolderFactory

java.lang.Object

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

All Implemented Interfaces:

BabelProtocolHolderFactory

public final class NettyExecutorProtocolHolderFactory
extends Object
implements BabelProtocolHolderFactory

Factory for creating NettyExecutorProtocolHolder instances backed by a Netty EventLoopGroup.

Constructor Summary

Constructors

Constructor	Description
NettyExecutorProtocolHolderFactory(int maxQueueCapacity, io.netty.channel.EventLoopGroup executor)	Constructs a new Netty executor protocol holder factory.

Method Summary

Modifier and Type	Method	Description
BabelProtocolHolder	createInstance(BabelProtocol protocol, Set<ProtocolExtension<? extends BabelProtocol>> extensions)	Creates a new BabelProtocolHolder wrapping the given protocol and extensions.

Methods inherited from class Object

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

Constructor Details

NettyExecutorProtocolHolderFactory

public NettyExecutorProtocolHolderFactory(int maxQueueCapacity,
 io.netty.channel.EventLoopGroup executor)

Constructs a new Netty executor protocol holder factory.

Parameters:

maxQueueCapacity - maximum queue capacity for each created holder

executor - the shared Netty event loop group

Method Details

createInstance

public BabelProtocolHolder createInstance(BabelProtocol protocol,
 Set<ProtocolExtension<? extends BabelProtocol>> extensions)

Description copied from interface: BabelProtocolHolderFactory

Creates a new BabelProtocolHolder wrapping the given protocol and extensions.

Specified by:

createInstance in interface BabelProtocolHolderFactory

Parameters:

protocol - the protocol instance to wrap

extensions - the set of protocol extensions configured for the protocol

Returns:

a new BabelProtocolHolder managing the protocol