Package com.ibm.fhir.bucket.client

Class FhirClient

java.lang.Object

com.ibm.fhir.bucket.client.FhirClient

public class FhirClient
extends Object

Handles pooled HTTP/S connections to a FHIR server. Derived from the former High Volume Ingestion Tool (HVIT) which is known to scale to a large number of client connections.

Constructor Summary

Constructors

Constructor	Description
FhirClient(ClientPropertyAdapter cpa)	Public constructor

Method Summary

Modifier and Type	Method	Description
void	addHeader(String key, String value)	Add the given key/value as a header
FhirServerResponse	get(String url, Function<Reader,Resource> fn)
org.apache.http.pool.PoolStats	getPoolInformation()	Get statistics from the internal HTTP connection manager
void	init(String tenantName)	Initialize the SSL connection pool after all the required field values have been injected
protected org.apache.http.impl.client.CloseableHttpClient	obtainCloseableHttpClient(org.apache.http.conn.ConnectionKeepAliveStrategy connKeepAliveStrategy)	Overridden by child classes for specialized behavior.
FhirServerResponse	post(String url, String body)	Issue a POST request at the given url
protected void	processOperationalOutcome(FhirServerResponse sr, org.apache.http.HttpEntity entity)	Extract the operational outcome message from the response entity
FhirServerResponse	put(String url, Map<String,String> headers, String body)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

FhirClient

public FhirClient(ClientPropertyAdapter cpa)

Public constructor

Parameters:

cpa -

Method Detail

addHeader

public void addHeader(String key,
                      String value)

Add the given key/value as a header

Parameters:

key -

value -

init

public void init(String tenantName)

Initialize the SSL connection pool after all the required field values have been injected

get

public FhirServerResponse get(String url,
                              Function<Reader,Resource> fn)

post

public FhirServerResponse post(String url,
                               String body)

Issue a POST request at the given url

Parameters:

sUrl -

body -

Returns:

put

public FhirServerResponse put(String url,
                              Map<String,String> headers,
                              String body)

shutdown

public void shutdown()

getPoolInformation

public org.apache.http.pool.PoolStats getPoolInformation()

Get statistics from the internal HTTP connection manager

Returns:

processOperationalOutcome

protected void processOperationalOutcome(FhirServerResponse sr,
                                         org.apache.http.HttpEntity entity)

Extract the operational outcome message from the response entity

Parameters:

sr -

entity -

obtainCloseableHttpClient

protected org.apache.http.impl.client.CloseableHttpClient obtainCloseableHttpClient(org.apache.http.conn.ConnectionKeepAliveStrategy connKeepAliveStrategy)

Overridden by child classes for specialized behavior.

Parameters:

connKeepAliveStrategy -