Package org.infinispan.server.core

Class AbstractProtocolServer<C extends ProtocolServerConfiguration>

java.lang.Object

org.infinispan.server.core.AbstractProtocolServer<C>

All Implemented Interfaces:

AutoCloseable, ProtocolServer<C>

Direct Known Subclasses:

HotRodServer, MemcachedServer, RestServer

public abstract class AbstractProtocolServer<C extends ProtocolServerConfiguration>
extends Object
implements ProtocolServer<C>

A common protocol server dealing with common property parameter validation and assignment and transport lifecycle.

Since:

4.1

Author:

Galder Zamarreño, wburns

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	adminEndpoint
protected EmbeddedCacheManager	cacheManager
protected C	configuration
protected ServerManagement	server
protected NettyTransport	transport

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	AbstractProtocolServer(String protocolName)

Method Summary

Modifier and Type	Method	Description
String	defaultCacheName()
BlockingManager	getBlockingManager()
EmbeddedCacheManager	getCacheManager()
C	getConfiguration()	Returns the configuration used to start this server
ProtocolServer<?>	getEnclosingProtocolServer()	Returns the enclosing ProtocolServer.
ExecutorService	getExecutor()
String	getHost()
String	getName()	Returns the name of this server
Integer	getPort()
final String	getQualifiedName()
ServerStateManager	getServerStateManager()
NettyTransport	getTransport()	Returns the transport for this server
protected boolean	isCacheIgnored(String cache)
boolean	isTransportEnabled()
protected void	registerMetrics()
protected void	registerServerMBeans()
void	setEnclosingProtocolServer(ProtocolServer<?> enclosingProtocolServer)	Sets the enclosing ProtocolServer.
void	setServerManagement(ServerManagement server, boolean adminEndpoint)	Sets the ServerManagement instance for this protocol server
void	start(C configuration, EmbeddedCacheManager cacheManager)	Starts the server backed by the given cache manager, with the corresponding configuration.
protected void	startCaches()
protected void	startInternal()
protected void	startTransport()
void	stop()	Stops the server.
protected void	unregisterMetrics()
protected void	unregisterServerMBeans()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.server.core.ProtocolServer

close, getChannelMatcher, getDecoder, getEncoder, getInitializer, installDetector

Field Details

transport

protected NettyTransport transport

cacheManager

protected EmbeddedCacheManager cacheManager

configuration

protected C extends ProtocolServerConfiguration configuration

server

protected ServerManagement server

adminEndpoint

protected boolean adminEndpoint

Constructor Details

AbstractProtocolServer

protected AbstractProtocolServer(String protocolName)

Method Details

getName

public String getName()

Description copied from interface: ProtocolServer

Returns the name of this server

Specified by:

getName in interface ProtocolServer<C extends ProtocolServerConfiguration>

startInternal

protected void startInternal()

setServerManagement

public void setServerManagement(ServerManagement server,
 boolean adminEndpoint)

Description copied from interface: ProtocolServer

Sets the ServerManagement instance for this protocol server

Specified by:

setServerManagement in interface ProtocolServer<C extends ProtocolServerConfiguration>

isCacheIgnored

protected boolean isCacheIgnored(String cache)

getServerStateManager

public ServerStateManager getServerStateManager()

start

public void start(C configuration,
 EmbeddedCacheManager cacheManager)

Description copied from interface: ProtocolServer

Starts the server backed by the given cache manager, with the corresponding configuration. The cache manager is expected to be completely initialized and started prior to this call.

Specified by:

start in interface ProtocolServer<C extends ProtocolServerConfiguration>

startTransport

protected void startTransport()

getBlockingManager

public BlockingManager getBlockingManager()

getExecutor

public ExecutorService getExecutor()

registerServerMBeans

protected void registerServerMBeans()

unregisterServerMBeans

protected void unregisterServerMBeans()
                               throws Exception

Throws:

Exception

registerMetrics

protected void registerMetrics()

unregisterMetrics

protected void unregisterMetrics()

getQualifiedName

public final String getQualifiedName()

stop

public void stop()

Description copied from interface: ProtocolServer

Stops the server.

Specified by:

stop in interface ProtocolServer<C extends ProtocolServerConfiguration>

getCacheManager

public EmbeddedCacheManager getCacheManager()

getHost

public String getHost()

getPort

public Integer getPort()

getConfiguration

public C getConfiguration()

Description copied from interface: ProtocolServer

Returns the configuration used to start this server

Specified by:

getConfiguration in interface ProtocolServer<C extends ProtocolServerConfiguration>

startCaches

protected void startCaches()

defaultCacheName

public String defaultCacheName()

isTransportEnabled

public boolean isTransportEnabled()

getTransport

public NettyTransport getTransport()

Description copied from interface: ProtocolServer

Returns the transport for this server

Specified by:

getTransport in interface ProtocolServer<C extends ProtocolServerConfiguration>

setEnclosingProtocolServer

public void setEnclosingProtocolServer(ProtocolServer<?> enclosingProtocolServer)

Description copied from interface: ProtocolServer

Sets the enclosing ProtocolServer. Used by the single port server

Specified by:

setEnclosingProtocolServer in interface ProtocolServer<C extends ProtocolServerConfiguration>

getEnclosingProtocolServer

public ProtocolServer<?> getEnclosingProtocolServer()

Description copied from interface: ProtocolServer

Returns the enclosing ProtocolServer. May be null if this server has none.

Specified by:

getEnclosingProtocolServer in interface ProtocolServer<C extends ProtocolServerConfiguration>