org.infinispan.server.hotrod

Class HotRodServer

java.lang.Object

org.infinispan.server.core.AbstractProtocolServer

org.infinispan.server.hotrod.HotRodServer

All Implemented Interfaces:

Log, ProtocolServer

public class HotRodServer
extends AbstractProtocolServer
implements Log

Hot Rod server, in charge of defining its encoder/decoder and, if clustered, update the topology information on startup and shutdown.

TODO: It's too late for 5.1.1 series. In 5.2, split class into: local and cluster hot rod servers This should safe some memory for the local case and the code should be cleaner

Since:

4.1

Author:

Galder Zamarreño

Constructor Summary

Constructors

Constructor and Description
HotRodServer()

Method Summary

Methods

Modifier and Type	Method and Description
protected ConfigurationBuilder	createTopologyCacheConfig(long distSyncTimeout)
static int	DEFAULT_TOPOLOGY_ID()
ServerAddress	getAddress()
Cache<byte[],byte[]>	getCacheInstance(String cacheName, EmbeddedCacheManager cacheManager, boolean skipCacheCheck)
HotRodDecoder	getDecoder() Gets the decoder for this protocol server.
HotRodEncoder	getEncoder() Gets the encoder for this protocol server.
scala.collection.Seq<QueryFacade>	getQueryFacades()
boolean	isCacheNameKnown(String cacheName)
Cache<Object,Object>	startDefaultCache()
void	startInternal(HotRodServerConfiguration configuration, EmbeddedCacheManager cacheManager)
void	startTransport()
void	tryRegisterMigrationManager(String cacheName, Cache<byte[],byte[]> cache)

Methods inherited from class org.infinispan.server.core.AbstractProtocolServer

cacheManager, configuration, getCacheManager, getConfiguration, getHost, getPipeline, getPort, registerTransportMBean, start, stop, transport, 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.hotrod.logging.Log

log, logErrorDetectingCrashedMember, logUnableToUpdateView, logViewNullWhileDetectingCrashedMember

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

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

Constructor Detail

HotRodServer

public HotRodServer()

Method Detail

DEFAULT_TOPOLOGY_ID

public static int DEFAULT_TOPOLOGY_ID()

getAddress

public ServerAddress getAddress()

getQueryFacades

public scala.collection.Seq<QueryFacade> getQueryFacades()

getEncoder

public HotRodEncoder getEncoder()

Description copied from interface: ProtocolServer

Gets the encoder for this protocol server. The encoder is responsible for writing back common header responses back to client. This method can return null if the server has no encoder. You can find an example of the server that has no encoder in the Memcached server.

Specified by:

getEncoder in interface ProtocolServer

getDecoder

public HotRodDecoder getDecoder()

Description copied from interface: ProtocolServer

Gets the decoder for this protocol server. The decoder is responsible for reading client requests. This method cannot return null.

Specified by:

getDecoder in interface ProtocolServer

startInternal

public void startInternal(HotRodServerConfiguration configuration,
                 EmbeddedCacheManager cacheManager)

Overrides:

startInternal in class AbstractProtocolServer

startTransport

public void startTransport()

Overrides:

startTransport in class AbstractProtocolServer

startDefaultCache

public Cache<Object,Object> startDefaultCache()

Overrides:

startDefaultCache in class AbstractProtocolServer

createTopologyCacheConfig

protected ConfigurationBuilder createTopologyCacheConfig(long distSyncTimeout)

isCacheNameKnown

public boolean isCacheNameKnown(String cacheName)

getCacheInstance

public Cache<byte[],byte[]> getCacheInstance(String cacheName,
                                    EmbeddedCacheManager cacheManager,
                                    boolean skipCacheCheck)

tryRegisterMigrationManager

public void tryRegisterMigrationManager(String cacheName,
                               Cache<byte[],byte[]> cache)