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.CacheInfo
-
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
cacheManager, configuration, transport
-
-
Constructor Summary
Constructors Constructor Description HotRodServer()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description org.infinispan.server.hotrod.logging.HotRodAccessLogging
accessLogging()
void
addCacheEventConverterFactory(java.lang.String name, CacheEventConverterFactory factory)
void
addCacheEventFilterConverterFactory(java.lang.String name, CacheEventFilterConverterFactory factory)
void
addCacheEventFilterFactory(java.lang.String name, CacheEventFilterFactory factory)
void
addKeyValueFilterConverterFactory(java.lang.String name, KeyValueFilterConverterFactory factory)
Metadata.Builder
buildMetadata(long lifespan, TimeUnitValue lifespanUnit, long maxIdle, TimeUnitValue maxIdleUnit)
Metadata.Builder
buildMetadata2x(long lifespan, TimeUnitValue lifespanUnit, long maxIdle, TimeUnitValue maxIdleUnit)
AdvancedCache<byte[],byte[]>
cache(HotRodServer.CacheInfo cacheInfo, HotRodHeader header, javax.security.auth.Subject subject)
protected ConfigurationBuilder
createTopologyCacheConfig(long distSyncTimeout)
ServerAddress
getAddress()
Cache<Address,ServerAddress>
getAddressCache()
HotRodServer.CacheInfo
getCacheInfo(java.lang.String cacheName, byte hotRodVersion, long messageId, boolean checkIgnored)
HotRodServer.CacheInfo
getCacheInfo(HotRodHeader header)
ClientCounterManagerNotificationManager
getClientCounterNotificationManager()
org.infinispan.server.hotrod.ClientListenerRegistry
getClientListenerRegistry()
HotRodDecoder
getDecoder()
Gets the decoder for this protocol server.io.netty.channel.ChannelOutboundHandler
getEncoder()
Gets the encoder for this protocol server.io.netty.channel.ChannelInitializer<io.netty.channel.Channel>
getInitializer()
Returns a pipeline factoryIterationManager
getIterationManager()
Marshaller
getMarshaller()
boolean
hasDefaultCache()
org.infinispan.multimap.impl.EmbeddedMultimapCache<WrappedByteArray,WrappedByteArray>
multimap(HotRodHeader header, javax.security.auth.Subject subject)
void
removeCacheEventConverterFactory(java.lang.String name)
void
removeCacheEventFilterConverterFactory(java.lang.String name)
void
removeCacheEventFilterFactory(java.lang.String name)
void
removeKeyValueFilterConverterFactory(java.lang.String name)
void
setMarshaller(Marshaller marshaller)
protected void
startDefaultCache()
protected void
startInternal(HotRodServerConfiguration configuration, EmbeddedCacheManager cacheManager)
protected void
startTransport()
void
stop()
Stops the serverjava.lang.String
toString()
void
updateCacheInfo(HotRodServer.CacheInfo info)
-
Methods inherited from class org.infinispan.server.core.AbstractProtocolServer
defaultCacheName, getCacheIgnore, getCacheManager, getConfiguration, getExecutor, getHost, getName, getPort, getQualifiedName, getTransport, isCacheIgnored, isTransportEnabled, registerServerMBeans, start, start, 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()
-
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.
-
startInternal
protected void startInternal(HotRodServerConfiguration configuration, EmbeddedCacheManager cacheManager)
- 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>
-
startDefaultCache
protected void startDefaultCache()
- Overrides:
startDefaultCache
in classAbstractProtocolServer<HotRodServerConfiguration>
-
createTopologyCacheConfig
protected ConfigurationBuilder createTopologyCacheConfig(long distSyncTimeout)
-
cache
public AdvancedCache<byte[],byte[]> cache(HotRodServer.CacheInfo cacheInfo, HotRodHeader header, javax.security.auth.Subject subject)
-
multimap
public org.infinispan.multimap.impl.EmbeddedMultimapCache<WrappedByteArray,WrappedByteArray> multimap(HotRodHeader header, javax.security.auth.Subject subject)
-
getCacheInfo
public HotRodServer.CacheInfo getCacheInfo(HotRodHeader header)
-
getCacheInfo
public HotRodServer.CacheInfo getCacheInfo(java.lang.String cacheName, byte hotRodVersion, long messageId, boolean checkIgnored)
-
updateCacheInfo
public void updateCacheInfo(HotRodServer.CacheInfo info)
-
getAddressCache
public Cache<Address,ServerAddress> getAddressCache()
-
addCacheEventFilterFactory
public void addCacheEventFilterFactory(java.lang.String name, CacheEventFilterFactory factory)
-
removeCacheEventFilterFactory
public void removeCacheEventFilterFactory(java.lang.String name)
-
addCacheEventConverterFactory
public void addCacheEventConverterFactory(java.lang.String name, CacheEventConverterFactory factory)
-
removeCacheEventConverterFactory
public void removeCacheEventConverterFactory(java.lang.String name)
-
addCacheEventFilterConverterFactory
public void addCacheEventFilterConverterFactory(java.lang.String name, CacheEventFilterConverterFactory factory)
-
removeCacheEventFilterConverterFactory
public void removeCacheEventFilterConverterFactory(java.lang.String name)
-
setMarshaller
public void setMarshaller(Marshaller marshaller)
-
addKeyValueFilterConverterFactory
public void addKeyValueFilterConverterFactory(java.lang.String name, KeyValueFilterConverterFactory factory)
-
removeKeyValueFilterConverterFactory
public void removeKeyValueFilterConverterFactory(java.lang.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 org.infinispan.server.hotrod.logging.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)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-