'How to build a Fallback return which honors this signature Uni<Response>

openjdk version "11.0.14" 2022-01-18 OpenJDK Runtime Environment GraalVM CE 22.0.0.2 (build 11.0.14+9-jvmci-22.0-b05) OpenJDK 64-Bit Server VM GraalVM CE 22.0.0.2 (build 11.0.14+9-jvmci-22.0-b05, mixed mode, sharing)

    <?xml version="1.0"?>
    <project xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 
       https://maven.apache.org/xsd/maven-4.0.0.xsd" 
         xmlns="http://maven.apache.org/POM/4.0.0" 
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance">
        <modelVersion>4.0.0</modelVersion>
        <groupId>org.p</groupId>
        <artifactId>quarkus-mvp-asynch</artifactId>
        <version>1.0.0-SNAPSHOT</version>
        <properties>
            <compiler-plugin.version>3.8.1</compiler-plugin.version>
            <maven.compiler.parameters>true</maven.compiler.parameters>
            <maven.compiler.source>11</maven.compiler.source>
            <maven.compiler.target>11</maven.compiler.target>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <quarkus.platform.artifact-id>quarkus-bom</quarkus.platform.artifact-id>
            <quarkus.platform.group-id>io.quarkus.platform</quarkus.platform.group-id>
            <quarkus.platform.version>2.3.1.Final</quarkus.platform.version>
            <surefire-plugin.version>3.0.0-M5</surefire-plugin.version>
            <wiremock.version>2.31.5</wiremock.version>
        </properties>
        <dependencyManagement>
            <dependencies>
                <dependency>
                    <groupId>${quarkus.platform.group-id}</groupId>
                    <artifactId>${quarkus.platform.artifact-id}</artifactId>
                    <version>${quarkus.platform.version}</version>
                    <type>pom</type>
                    <scope>import</scope>
                </dependency>
            </dependencies>
        </dependencyManagement>
        <dependencies>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-resteasy-reactive</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-resteasy-reactive-jackson</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-rest-client-reactive</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-rest-client-reactive-jackson</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-arc</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-smallrye-fault-tolerance</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-reactive-routes</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-smallrye-health</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-smallrye-openapi</artifactId>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-junit5</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>io.quarkus</groupId>
                <artifactId>quarkus-jacoco</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>io.rest-assured</groupId>
                <artifactId>rest-assured</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>com.github.tomakehurst</groupId>
                <artifactId>wiremock-jre8</artifactId>
                <version>2.31.0</version>
                <scope>test</scope>
            </dependency>
        </dependencies>
        <build>
            <plugins>
                <plugin>

I have multi-asynchronous rest client calls. I want the be able to handle a Timeout for a single client with out effecting the other clients. I want to be able to produce a 206 with the other client data when all complete, so I need the FallBack to return the same object (javax.ws.rs.core.Response) as does the service adapter. Currently I try


    import javax.ws.rs.core.Response;
    
    import org.eclipse.microprofile.rest.client.annotation.RegisterClientHeaders;
    import org.eclipse.microprofile.rest.client.inject.RegisterRestClient;
    
    import io.smallrye.mutiny.Uni;
    
    @RegisterRestClient(configKey="setup-api")
    @RegisterClientHeaders(SetupHeaderFactory.class)
    public interface JokesSetupService {
    
        @GET
        @Path("/jokesetup/{id}")
        @Produces(MediaType.APPLICATION_JSON)
        Uni<Response> getByIdAsync(@PathParam("id") String id);
    }
    
        @Timeout(3000)
        @CircuitBreaker
        @CircuitBreakerName("setup-breaker")
        @Fallback(SetupFallBack.class)
        public Uni<Response>getByIdAsync(String id){
            LOGGER.debug("JOKE SETUP ADAPTER------------------------  getByIdAsyn");
            return jokesSetupService.getByIdAsync(id);
        }
    
    public class SetupFallBack implements FallbackHandler<Uni<Response>>  {
    
        private static final Logger LOGGER = 
        LoggerFactory.getLogger(SetupFallBack.class);
    
        @Inject
        FallBackErrorHandler fallBackErrorHandler;
        @Override
        public Uni<Response> handle(ExecutionContext context) {
            LOGGER.debug("SETUP FALLBACK ");
            LOGGER.debug("************** - CALL FAILED BECAUSE OF : " + 
            context.getFailure().getMessage());
                
            return Uni.createFrom().item(fallBackErrorHandler.buildUniResponse(context));
        }
    
    }



Sources

This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.

Source: Stack Overflow

Solution Source