Class HotRodServer

java.lang.Object

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

org.infinispan.server.hotrod.HotRodServer

All Implemented Interfaces:

AutoCloseable, 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 final int	DEFAULT_HOTROD_PORT
static final 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

Modifier and Type	Method	Description
HotRodAccessLogging	accessLogging()
void	addCacheEventConverterFactory(String name, CacheEventConverterFactory factory)
void	addCacheEventFilterConverterFactory(String name, CacheEventFilterConverterFactory factory)
void	addCacheEventFilterFactory(String name, CacheEventFilterFactory factory)
void	addKeyValueFilterConverterFactory(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.ExtendedCacheInfo cacheInfo, HotRodHeader header, Subject subject)
protected ConfigurationBuilder	createTopologyCacheConfig(long distSyncTimeout)
ServerAddress	getAddress()
Cache<Address, ServerAddress>	getAddressCache()
HotRodServer.ExtendedCacheInfo	getCacheInfo(String cacheName, byte hotRodVersion, long messageId, boolean checkIgnored)
HotRodServer.ExtendedCacheInfo	getCacheInfo(HotRodHeader header)
io.netty.channel.group.ChannelMatcher	getChannelMatcher()	Returns a ChannelMatcher which matches channels which belong to this protocol server
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 factory
IterationManager	getIterationManager()
Marshaller	getMarshaller()
StreamingManager	getStreamingManager()
TimeService	getTimeService()
boolean	hasDefaultCache()
void	installDetector(io.netty.channel.Channel ch)	Installs a protocol detector on the channel
void	internalPostStart()
EmbeddedMultimapCache<byte[],byte[]>	multimap(HotRodHeader header, Subject subject, boolean supportsDuplicates)
void	removeCacheEventConverterFactory(String name)
void	removeCacheEventFilterConverterFactory(String name)
void	removeCacheEventFilterFactory(String name)
void	removeKeyValueFilterConverterFactory(String name)
void	setMarshaller(Marshaller marshaller)
protected void	startCaches()
protected void	startInternal()
protected void	startTransport()
void	stop()	Stops the server.
String	toString()
void	updateCacheInfo(HotRodServer.ExtendedCacheInfo info)

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

defaultCacheName, getBlockingManager, getCacheManager, getConfiguration, getEnclosingProtocolServer, getExecutor, getHost, getName, getPort, getQualifiedName, getServerStateManager, getTransport, isCacheIgnored, isTransportEnabled, postStart, registerMetrics, registerServerMBeans, setEnclosingProtocolServer, setServerManagement, start, unregisterMetrics, unregisterServerMBeans

Methods inherited from class java.lang.Object

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

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

close

Field Details

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

Constructor Details

HotRodServer

public HotRodServer()

Method Details

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 a ChannelMatcher which matches channels which belong to this protocol server

installDetector

public void installDetector(io.netty.channel.Channel ch)

Description copied from interface: ProtocolServer

Installs a protocol detector on the channel

Parameters:

ch -

startInternal

protected void startInternal()

Overrides:

startInternal in class AbstractProtocolServer<HotRodServerConfiguration>

internalPostStart

public void internalPostStart()

Overrides:

internalPostStart in class AbstractProtocolServer<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 class AbstractProtocolServer<HotRodServerConfiguration>

startCaches

protected void startCaches()

Overrides:

startCaches in class AbstractProtocolServer<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()

getStreamingManager

public StreamingManager getStreamingManager()

stop

public void stop()

Description copied from interface: ProtocolServer

Stops the server.

Specified by:

stop in interface ProtocolServer<HotRodServerConfiguration>

Overrides:

stop in class AbstractProtocolServer<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)

toString

public String toString()

Overrides:

toString in class Object