Package org.apache.curator.x.discovery.server.contexts

Class GenericDiscoveryContext<T>

java.lang.Object

org.apache.curator.x.discovery.server.contexts.GenericDiscoveryContext<T>

All Implemented Interfaces:

javax.ws.rs.ext.ContextResolver<DiscoveryContext<T>>, DiscoveryContext<T>

Direct Known Subclasses:

MapDiscoveryContext

@Provider
public class GenericDiscoveryContext<T>
extends Object
implements DiscoveryContext<T>, javax.ws.rs.ext.ContextResolver<DiscoveryContext<T>>

For convenience, a version of DiscoveryContext that uses any generic type as the payload

Constructor Summary

Constructors

Constructor	Description
GenericDiscoveryContext(ServiceDiscovery<T> serviceDiscovery, ProviderStrategy<T> providerStrategy, int instanceRefreshMs, com.google.common.reflect.TypeToken<T> payloadType)
GenericDiscoveryContext(ServiceDiscovery<T> serviceDiscovery, ProviderStrategy<T> providerStrategy, int instanceRefreshMs, Class<T> payloadType)

Method Summary

Modifier and Type	Method	Description
DiscoveryContext<T>	getContext(Class<?> type)
int	getInstanceRefreshMs()	Return the threshold in milliseconds to consider a registration stale
ProviderStrategy<T>	getProviderStrategy()	Return the provider strategy to use for DiscoveryResource.getAny(String)
ServiceDiscovery<T>	getServiceDiscovery()	Return the service singleton
void	marshallJson(com.fasterxml.jackson.databind.node.ObjectNode node, String fieldName, T payload)	Serialize your payload
T	unMarshallJson(com.fasterxml.jackson.databind.JsonNode node)	Deserialize your payload

Methods inherited from class java.lang.Object

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

Constructor Details

GenericDiscoveryContext

public GenericDiscoveryContext(ServiceDiscovery<T> serviceDiscovery,
 ProviderStrategy<T> providerStrategy,
 int instanceRefreshMs,
 Class<T> payloadType)

GenericDiscoveryContext

public GenericDiscoveryContext(ServiceDiscovery<T> serviceDiscovery,
 ProviderStrategy<T> providerStrategy,
 int instanceRefreshMs,
 com.google.common.reflect.TypeToken<T> payloadType)

Method Details

getProviderStrategy

public ProviderStrategy<T> getProviderStrategy()

Description copied from interface: DiscoveryContext

Return the provider strategy to use for DiscoveryResource.getAny(String)

Specified by:

getProviderStrategy in interface DiscoveryContext<T>

Returns:

strategy

getInstanceRefreshMs

public int getInstanceRefreshMs()

Description copied from interface: DiscoveryContext

Return the threshold in milliseconds to consider a registration stale

Specified by:

getInstanceRefreshMs in interface DiscoveryContext<T>

Returns:

number of milliseconds

getServiceDiscovery

public ServiceDiscovery<T> getServiceDiscovery()

Description copied from interface: DiscoveryContext

Return the service singleton

Specified by:

getServiceDiscovery in interface DiscoveryContext<T>

Returns:

service

marshallJson

public void marshallJson(com.fasterxml.jackson.databind.node.ObjectNode node,
 String fieldName,
 T payload)
                  throws Exception

Description copied from interface: DiscoveryContext

Serialize your payload

Specified by:

marshallJson in interface DiscoveryContext<T>

Parameters:

node - the node to serialize into

fieldName - field name to use

payload - the payload value (can be null)

Throws:

Exception - any errors

unMarshallJson

public T unMarshallJson(com.fasterxml.jackson.databind.JsonNode node)
                 throws Exception

Description copied from interface: DiscoveryContext

Deserialize your payload

Specified by:

unMarshallJson in interface DiscoveryContext<T>

Parameters:

node - the node that has the payload

Returns:

the payload or null

Throws:

Exception - any errors

getContext

public DiscoveryContext<T> getContext(Class<?> type)

Specified by:

getContext in interface javax.ws.rs.ext.ContextResolver<T>