Package io.clonecloudstore.common.quarkus.client

Class SimpleClientAbstract<S extends Closeable>

java.lang.Object
io.clonecloudstore.common.quarkus.client.SimpleClientAbstract<S>
Type Parameters:
S - the type for the Rest Service as Quarkus definition
All Implemented Interfaces:
Closeable, AutoCloseable
Direct Known Subclasses:
AccessorBucketApiClient, AccessorBucketInternalApiClient, ClientAbstract, OwnershipApiClient, TopologyApiClient
public abstract class SimpleClientAbstract<S extends Closeable> extends Object implements Closeable
Client Abstraction

  • Field Details

  • Constructor Details

  • Method Details

    • getFactory

      protected SimpleClientFactoryAbstract<S> getFactory()
      Returns:
      the Factory used by this client

    • reopen

      public void reopen()
      Close and reopens Quarkus Rest client

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • setOpId

      public void setOpId(String opId)
      Set the current Operation Id

    • bodyCompressed

      public static void bodyCompressed(boolean compressedBody)
      Parameters:
      compressedBody - True, client provides compressed body

    • isBodyCompressed

      public static boolean isBodyCompressed()
      Returns:
      True if the client provides compressed body

    • acceptCompression

      public static void acceptCompression(boolean acceptCompression)
      Parameters:
      acceptCompression - True, client requires compressed response

    • isAcceptCompression

      public static boolean isAcceptCompression()
      Returns:
      True if the client requires compressed response

    • setHeadersMap

      public static void setHeadersMap(Map<String,String> headersMap)
      Parameters:
      headersMap - the apiBusinessIn as map to setup as headers

    • getHeadersMap

      public static Map<String,String> getHeadersMap()
      Returns:
      True if the client requires compressed response

    • setDtoFromHeaders

      public static void setDtoFromHeaders(Object result)
      Set object received from headers

    • setCompressionStatusFromHeaders

      public static void setCompressionStatusFromHeaders(Boolean compressed)
      Set Compression status received from headers

    • getDtoFromHeaders

      public static Object getDtoFromHeaders()
      Returns:
      received Object from Headers

    • getCompressionStatusFromHeaders

      public static boolean getCompressionStatusFromHeaders()
      Returns:
      received Compression status from Headers

    • resetQueryContext

      public void resetQueryContext()
      Clean all Query context

    • setMdcOpId

      public static String setMdcOpId(String opId)
      Check opId and put it in MDC
      Returns:
      the value to use

    • getMdcOpId

      public static String getMdcOpId()
      Returns:
      the current OpId or a new one if none

    • getOpId

      public String getOpId()
      Get the current Operation Id

    • resetMdcOpId

      public void resetMdcOpId()
      Reset OpId to empty

    • getService

      protected S getService()
      Get the associated ServiceRest

    • getUri

      protected URI getUri()
      Get the URI defined from construction