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

Class StringDiscoveryContext

java.lang.Object

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

All Implemented Interfaces:

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

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

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

Constructor Summary

Constructors

Constructor and Description
StringDiscoveryContext(ServiceDiscovery<String> serviceDiscovery, ProviderStrategy<String> providerStrategy, int instanceRefreshMs)

Method Summary

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

StringDiscoveryContext

public StringDiscoveryContext(ServiceDiscovery<String> serviceDiscovery,
                              ProviderStrategy<String> providerStrategy,
                              int instanceRefreshMs)

Method Detail

getProviderStrategy

public ProviderStrategy<String> getProviderStrategy()

Description copied from interface: DiscoveryContext

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

Specified by:

getProviderStrategy in interface DiscoveryContext<String>

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

Returns:

number of milliseconds

getServiceDiscovery

public ServiceDiscovery<String> getServiceDiscovery()

Description copied from interface: DiscoveryContext

Return the service singleton

Specified by:

getServiceDiscovery in interface DiscoveryContext<String>

Returns:

service

marshallJson

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

Description copied from interface: DiscoveryContext

Serialize your payload

Specified by:

marshallJson in interface DiscoveryContext<String>

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

Description copied from interface: DiscoveryContext

Deserialize your payload

Specified by:

unMarshallJson in interface DiscoveryContext<String>

Parameters:

node - the node that has the payload

Returns:

the payload or null

Throws:

Exception - any errors

getContext

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

Specified by:

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