Package org.infinispan.server.hotrod
Class HotRodServer
- java.lang.Object
-
- org.infinispan.server.core.AbstractProtocolServer<HotRodServerConfiguration>
-
- org.infinispan.server.hotrod.HotRodServer
-
- All Implemented Interfaces:
ProtocolServer<HotRodServerConfiguration>
public class HotRodServer extends AbstractProtocolServer<HotRodServerConfiguration>
Hot Rod server, in charge of defining its encoder/decoder and, if clustered, update the topology information on startup and shutdown.- Since:
- 4.1
- Author:
- Galder ZamarreƱo
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
HotRodServer.ExtendedCacheInfo
-
Field Summary
Fields Modifier and Type Field Description static int
DEFAULT_HOTROD_PORT
static int
LISTENERS_CHECK_INTERVAL
-
Fields inherited from class org.infinispan.server.core.AbstractProtocolServer
adminEndpoint, cacheManager, configuration, server, transport
-
-
Constructor Summary
Constructors Constructor Description HotRodServer()
-
Method Summary
-
Methods inherited from class org.infinispan.server.core.AbstractProtocolServer
defaultCacheName, getBlockingManager, getCacheManager, getConfiguration, getEnclosingProtocolServer, getExecutor, getHost, getName, getPort, getQualifiedName, getServerStateManager, getTransport, isCacheIgnored, isTransportEnabled, registerMetrics, registerServerMBeans, setEnclosingProtocolServer, setServerManagement, start, unregisterMetrics, unregisterServerMBeans
-
-
-
-
Field Detail
-
DEFAULT_HOTROD_PORT
public static final int DEFAULT_HOTROD_PORT
- See Also:
- Constant Field Values
-
LISTENERS_CHECK_INTERVAL
public static final int LISTENERS_CHECK_INTERVAL
- See Also:
- Constant Field Values
-
-
Method Detail
-
hasDefaultCache
public boolean hasDefaultCache()
-
getAddress
public ServerAddress getAddress()
-
getMarshaller
public Marshaller getMarshaller()
-
getTimeService
public TimeService getTimeService()
-
getClientListenerRegistry
public org.infinispan.server.hotrod.ClientListenerRegistry getClientListenerRegistry()
-
getClientCounterNotificationManager
public ClientCounterManagerNotificationManager getClientCounterNotificationManager()
-
getEncoder
public io.netty.channel.ChannelOutboundHandler 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.
-
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.
-
getChannelMatcher
public io.netty.channel.group.ChannelMatcher getChannelMatcher()
Description copied from interface:ProtocolServer
Returns aChannelMatcher
which matches channels which belong to this protocol server
-
startInternal
protected void startInternal()
- Overrides:
startInternal
in classAbstractProtocolServer<HotRodServerConfiguration>
-
getInitializer
public io.netty.channel.ChannelInitializer<io.netty.channel.Channel> getInitializer()
Description copied from interface:ProtocolServer
Returns a pipeline factory
-
startTransport
protected void startTransport()
- Overrides:
startTransport
in classAbstractProtocolServer<HotRodServerConfiguration>
-
startCaches
protected void startCaches()
- Overrides:
startCaches
in classAbstractProtocolServer<HotRodServerConfiguration>
-
createTopologyCacheConfig
protected ConfigurationBuilder createTopologyCacheConfig(long distSyncTimeout)
-
cache
public AdvancedCache<byte[],byte[]> cache(HotRodServer.ExtendedCacheInfo cacheInfo, HotRodHeader header, Subject subject)
-
multimap
public EmbeddedMultimapCache<byte[],byte[]> multimap(HotRodHeader header, Subject subject, boolean supportsDuplicates)
-
getCacheInfo
public HotRodServer.ExtendedCacheInfo getCacheInfo(HotRodHeader header)
-
getCacheInfo
public HotRodServer.ExtendedCacheInfo getCacheInfo(String cacheName, byte hotRodVersion, long messageId, boolean checkIgnored)
-
updateCacheInfo
public void updateCacheInfo(HotRodServer.ExtendedCacheInfo info)
-
getAddressCache
public Cache<Address,ServerAddress> getAddressCache()
-
addCacheEventFilterFactory
public void addCacheEventFilterFactory(String name, CacheEventFilterFactory factory)
-
removeCacheEventFilterFactory
public void removeCacheEventFilterFactory(String name)
-
addCacheEventConverterFactory
public void addCacheEventConverterFactory(String name, CacheEventConverterFactory factory)
-
removeCacheEventConverterFactory
public void removeCacheEventConverterFactory(String name)
-
addCacheEventFilterConverterFactory
public void addCacheEventFilterConverterFactory(String name, CacheEventFilterConverterFactory factory)
-
removeCacheEventFilterConverterFactory
public void removeCacheEventFilterConverterFactory(String name)
-
setMarshaller
public void setMarshaller(Marshaller marshaller)
-
addKeyValueFilterConverterFactory
public void addKeyValueFilterConverterFactory(String name, KeyValueFilterConverterFactory factory)
-
removeKeyValueFilterConverterFactory
public void removeKeyValueFilterConverterFactory(String name)
-
getIterationManager
public IterationManager getIterationManager()
-
stop
public void stop()
Description copied from interface:ProtocolServer
Stops the server.- Specified by:
stop
in interfaceProtocolServer<HotRodServerConfiguration>
- Overrides:
stop
in classAbstractProtocolServer<HotRodServerConfiguration>
-
accessLogging
public HotRodAccessLogging accessLogging()
-
buildMetadata2x
public Metadata.Builder buildMetadata2x(long lifespan, TimeUnitValue lifespanUnit, long maxIdle, TimeUnitValue maxIdleUnit)
-
buildMetadata
public Metadata.Builder buildMetadata(long lifespan, TimeUnitValue lifespanUnit, long maxIdle, TimeUnitValue maxIdleUnit)
-
-