org.infinispan.server.core

Class AbstractProtocolServer

java.lang.Object

org.infinispan.server.core.AbstractProtocolServer

All Implemented Interfaces:

Log, ProtocolServer

Direct Known Subclasses:

HotRodServer, MemcachedServer, WebSocketServer

public abstract class AbstractProtocolServer
extends Object
implements ProtocolServer, Log

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

Since:

4.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
AbstractProtocolServer(String protocolName)

Method Summary

Methods

Modifier and Type	Method and Description
protected EmbeddedCacheManager	cacheManager()
protected org.infinispan.server.core.ProtocolServer.SuitableConfiguration	configuration()
EmbeddedCacheManager	getCacheManager()
org.infinispan.server.core.ProtocolServer.SuitableConfiguration	getConfiguration() Returns the configuration used to start this server
String	getHost()
LifecycleChannelPipelineFactory	getPipeline() Returns a pipeline factory
int	getPort()
protected void	registerTransportMBean()
void	start(org.infinispan.server.core.ProtocolServer.SuitableConfiguration configuration, EmbeddedCacheManager cacheManager) Starts the server backed by the given cache manager and with the corresponding configuration.
Cache<Object,Object>	startDefaultCache()
protected void	startInternal(org.infinispan.server.core.ProtocolServer.SuitableConfiguration configuration, EmbeddedCacheManager cacheManager)
void	startTransport()
void	stop() Stops the server
protected NettyTransport	transport()
protected void	unregisterTransportMBean()

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

getDecoder, getEncoder

Methods inherited from interface org.infinispan.server.core.logging.Log

debug, debug, debug, debug, debug, debugf, error, info, info, isDebugEnabled, isTraceEnabled, log, logChannelStillBound, logChannelStillConnected, logErrorBeforeReadingRequest, logExceptionReported, logPostingShutdownRequest, logServerDidNotClose, logServerDidNotUnbind, logSettingMasterThreadsNotSupported, logStartWithArgs, trace, trace, trace, trace, tracef, warn

Constructor Detail

AbstractProtocolServer

public AbstractProtocolServer(String protocolName)

Method Detail

transport

protected NettyTransport transport()

cacheManager

protected EmbeddedCacheManager cacheManager()

configuration

protected org.infinispan.server.core.ProtocolServer.SuitableConfiguration configuration()

startInternal

protected void startInternal(org.infinispan.server.core.ProtocolServer.SuitableConfiguration configuration,
                 EmbeddedCacheManager cacheManager)

start

public final void start(org.infinispan.server.core.ProtocolServer.SuitableConfiguration configuration,
         EmbeddedCacheManager cacheManager)

Description copied from interface: ProtocolServer

Starts the server backed by the given cache manager and with the corresponding configuration.

Specified by:

start in interface ProtocolServer

startTransport

public void startTransport()

getPipeline

public LifecycleChannelPipelineFactory getPipeline()

Description copied from interface: ProtocolServer

Returns a pipeline factory

Specified by:

getPipeline in interface ProtocolServer

registerTransportMBean

protected void registerTransportMBean()

unregisterTransportMBean

protected void unregisterTransportMBean()

stop

public void stop()

Description copied from interface: ProtocolServer

Stops the server

Specified by:

stop in interface ProtocolServer

getCacheManager

public EmbeddedCacheManager getCacheManager()

getConfiguration

public org.infinispan.server.core.ProtocolServer.SuitableConfiguration getConfiguration()

Description copied from interface: ProtocolServer

Returns the configuration used to start this server

Specified by:

getConfiguration in interface ProtocolServer

getHost

public String getHost()

getPort

public int getPort()

startDefaultCache

public Cache<Object,Object> startDefaultCache()