Package io.clonecloudstore.common.quarkus.client

Class ClientAbstract<I,O,S extends Closeable>

java.lang.Object

io.clonecloudstore.common.quarkus.client.SimpleClientAbstract<S>

io.clonecloudstore.common.quarkus.client.ClientAbstract<I,O,S>

Type Parameters:

I - the type for Business Input request (in GET or POST)

O - the type for Business Output request (in POST)

S - the type for the Rest Service as Quarkus definition

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

AccessorObjectApiClient, AccessorObjectInternalApiClient, LocalReplicatorApiClient, RemoteReplicatorApiClient

public abstract class ClientAbstract<I,O,S extends Closeable>
extends SimpleClientAbstract<S>

Client Abstraction with prepared methods for Get and Post request using InputStream

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CONTEXT_RECEIVE
static final int	CONTEXT_SENDING

Fields inherited from class io.clonecloudstore.common.quarkus.client.SimpleClientAbstract

exceptionMapper, MDC_COMPRESSED_CONTENT, MDC_COMPRESSED_RESPONSE, MDC_QUERY_HEADERS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ClientAbstract(ClientFactoryAbstract<S> factory, URI uri)	Constructor used by the Factory

Method Summary

Modifier and Type	Method	Description
protected abstract O	getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response)
protected ClientFactoryAbstract<S>	getFactory()
protected abstract Map<String,String>	getHeadersFor(I businessIn, int context)
protected InputStreamBusinessOut<O>	getInputStreamBusinessOutFromUni(boolean shallDecompress, io.smallrye.mutiny.Uni<InputStream> inputStreamUni)
protected O	getResultFromPostInputStreamUni(io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> uni, InputStream sendInputStream)
protected void	prepareInputStreamToReceive(boolean acceptCompressed, I businessIn)
protected InputStream	prepareInputStreamToSend(InputStream content, boolean shallCompress, boolean alreadyCompressed, I businessIn)

Methods inherited from class io.clonecloudstore.common.quarkus.client.SimpleClientAbstract

acceptCompression, bodyCompressed, close, getCompressionStatusFromHeaders, getDtoFromHeaders, getHeadersMap, getMdcOpId, getOpId, getService, getUri, isAcceptCompression, isBodyCompressed, reopen, resetMdcOpId, resetQueryContext, setCompressionStatusFromHeaders, setDtoFromHeaders, setHeadersMap, setMdcOpId, setOpId

Methods inherited from class java.lang.Object

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

Field Details

CONTEXT_SENDING

public static final int CONTEXT_SENDING

See Also:

• Constant Field Values

CONTEXT_RECEIVE

public static final int CONTEXT_RECEIVE

See Also:

• Constant Field Values

Constructor Details

ClientAbstract

protected ClientAbstract(ClientFactoryAbstract<S> factory,
 URI uri)

Constructor used by the Factory

Method Details

getApiBusinessOutFromResponseForCreate

protected abstract O getApiBusinessOutFromResponseForCreate(jakarta.ws.rs.core.Response response)

Returns:

the BusinessOut from the response content and/or headers for Create Operation

getHeadersFor

protected abstract Map<String,String> getHeadersFor(I businessIn,
 int context)

Parameters:

context - 1 for sending InputStream, -1 for receiving InputStream, or anything else

Returns:

the headers map

getFactory

protected ClientFactoryAbstract<S> getFactory()

Overrides:

getFactory in class SimpleClientAbstract<S extends Closeable>

Returns:

the Factory used by this client

prepareInputStreamToSend

protected InputStream prepareInputStreamToSend(InputStream content,
 boolean shallCompress,
 boolean alreadyCompressed,
 I businessIn)

getResultFromPostInputStreamUni

protected O getResultFromPostInputStreamUni(io.smallrye.mutiny.Uni<jakarta.ws.rs.core.Response> uni,
 InputStream sendInputStream)
                                     throws CcsWithStatusException

Throws:

CcsWithStatusException

prepareInputStreamToReceive

protected void prepareInputStreamToReceive(boolean acceptCompressed,
 I businessIn)

getInputStreamBusinessOutFromUni

protected InputStreamBusinessOut<O> getInputStreamBusinessOutFromUni(boolean shallDecompress,
 io.smallrye.mutiny.Uni<InputStream> inputStreamUni)
                                                              throws CcsWithStatusException

Throws:

CcsWithStatusException