org.apache.nifi.registry.client.impl

Class AbstractJerseyClient

java.lang.Object

org.apache.nifi.registry.client.impl.AbstractJerseyClient

Direct Known Subclasses:

JerseyBucketClient, JerseyFlowClient, JerseyFlowSnapshotClient, JerseyItemsClient, JerseyUserClient

public class AbstractJerseyClient
extends Object

Base class for the client operations to share exception handling. Sub-classes should always execute a request from getRequestBuilder(target) to ensure proper headers are sent.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static interface	AbstractJerseyClient.NiFiRegistryAction<T> An action to execute with the given return type.

Field Summary

Fields

Modifier and Type	Field and Description
private Map<String,String>	headers

Constructor Summary

Constructors

Constructor and Description
AbstractJerseyClient(Map<String,String> headers)

Method Summary

Modifier and Type	Method and Description
protected <T> T	executeAction(String errorMessage, AbstractJerseyClient.NiFiRegistryAction<T> action) Executes the given action and returns the result.
protected Map<String,String>	getHeaders()
protected Throwable	getIOExceptionCause(Throwable e)
protected javax.ws.rs.client.Invocation.Builder	getRequestBuilder(javax.ws.rs.client.WebTarget webTarget) Creates a new Invocation.Builder for the given WebTarget with the headers added to the builder.

Methods inherited from class java.lang.Object

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

Field Detail

headers

private final Map<String,String> headers

Constructor Detail

AbstractJerseyClient

public AbstractJerseyClient(Map<String,String> headers)

Method Detail

getHeaders

protected Map<String,String> getHeaders()

getRequestBuilder

protected javax.ws.rs.client.Invocation.Builder getRequestBuilder(javax.ws.rs.client.WebTarget webTarget)

Creates a new Invocation.Builder for the given WebTarget with the headers added to the builder.

Parameters:

webTarget - the target for the request

Returns:

the builder for the target with the headers added

executeAction

protected <T> T executeAction(String errorMessage,
                              AbstractJerseyClient.NiFiRegistryAction<T> action)
                       throws NiFiRegistryException,
                              IOException

Executes the given action and returns the result.

Type Parameters:

T - the return type of the action

Parameters:

action - the action to execute

errorMessage - the message to use if a NiFiRegistryException is thrown

Returns:

the result of the action

Throws:

NiFiRegistryException - if any exception other than IOException is encountered

IOException - if an I/O error occurs communicating with the registry

getIOExceptionCause

protected Throwable getIOExceptionCause(Throwable e)

Parameters:

e - an exception that was encountered interacting with the registry

Returns:

the IOException that caused this exception, or null if the an IOException did not cause this exception