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

Class IntegerDiscoveryContext

java.lang.Object

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

All Implemented Interfaces:

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

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

For convenience, a version of DiscoveryContext that uses an int as the payload

Constructor Summary

Constructors

Constructor and Description
IntegerDiscoveryContext(ServiceDiscovery<Integer> serviceDiscovery, ProviderStrategy<Integer> providerStrategy, int instanceRefreshMs)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

IntegerDiscoveryContext

public IntegerDiscoveryContext(ServiceDiscovery<Integer> serviceDiscovery,
                               ProviderStrategy<Integer> providerStrategy,
                               int instanceRefreshMs)

Method Detail

getProviderStrategy

public ProviderStrategy<Integer> getProviderStrategy()

Description copied from interface: DiscoveryContext

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

Specified by:

getProviderStrategy in interface DiscoveryContext<Integer>

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<Integer>

Returns:

number of milliseconds

getServiceDiscovery

public ServiceDiscovery<Integer> getServiceDiscovery()

Description copied from interface: DiscoveryContext

Return the service singleton

Specified by:

getServiceDiscovery in interface DiscoveryContext<Integer>

Returns:

service

marshallJson

public void marshallJson(org.codehaus.jackson.node.ObjectNode node,
                         String fieldName,
                         Integer payload)
                  throws Exception

Description copied from interface: DiscoveryContext

Serialize your payload

Specified by:

marshallJson in interface DiscoveryContext<Integer>

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 Integer unMarshallJson(org.codehaus.jackson.JsonNode node)
                       throws Exception

Description copied from interface: DiscoveryContext

Deserialize your payload

Specified by:

unMarshallJson in interface DiscoveryContext<Integer>

Parameters:

node - the node that has the payload

Returns:

the payload or null

Throws:

Exception - any errors

getContext

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

Specified by:

getContext in interface javax.ws.rs.ext.ContextResolver<DiscoveryContext<Integer>>