Skip to content

Commit 0b1a09b

Browse files
committed
Ensure that SSE builder works in native
Fixes: quarkusio#36402
1 parent 798dba7 commit 0b1a09b

File tree

2 files changed

+10
-1
lines changed

2 files changed

+10
-1
lines changed

extensions/resteasy-classic/rest-client/deployment/src/main/java/io/quarkus/restclient/deployment/RestClientProcessor.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -19,6 +19,7 @@
1919
import jakarta.ws.rs.client.ClientRequestFilter;
2020
import jakarta.ws.rs.client.ClientResponseFilter;
2121
import jakarta.ws.rs.ext.Providers;
22+
import jakarta.ws.rs.sse.SseEventSource;
2223

2324
import org.eclipse.microprofile.config.Config;
2425
import org.eclipse.microprofile.config.ConfigProvider;
@@ -48,6 +49,7 @@
4849
import org.jboss.resteasy.microprofile.client.RestClientProxy;
4950
import org.jboss.resteasy.microprofile.client.async.AsyncInterceptorRxInvokerProvider;
5051
import org.jboss.resteasy.microprofile.client.publisher.MpPublisherMessageBodyReader;
52+
import org.jboss.resteasy.plugins.providers.sse.client.SseEventSourceImpl;
5153
import org.jboss.resteasy.spi.ResteasyConfiguration;
5254

5355
import io.quarkus.arc.BeanDestroyer;
@@ -122,8 +124,11 @@ void setupProviders(BuildProducer<NativeImageResourceBuildItem> resources,
122124
}
123125

124126
@BuildStep
125-
void setupClientBuilder(BuildProducer<NativeImageResourceBuildItem> resources) {
127+
void setupClientBuilder(BuildProducer<NativeImageResourceBuildItem> resources,
128+
BuildProducer<ServiceProviderBuildItem> serviceProviders) {
126129
resources.produce(new NativeImageResourceBuildItem("META-INF/services/jakarta.ws.rs.client.ClientBuilder"));
130+
serviceProviders.produce(new ServiceProviderBuildItem(SseEventSource.Builder.class.getName(),
131+
SseEventSourceImpl.SourceBuilder.class.getName()));
127132
}
128133

129134
@BuildStep

extensions/resteasy-reactive/jaxrs-client-reactive/deployment/src/main/java/io/quarkus/jaxrs/client/reactive/deployment/JaxrsClientReactiveProcessor.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -65,6 +65,7 @@
6565
import jakarta.ws.rs.core.UriBuilder;
6666
import jakarta.ws.rs.ext.ParamConverter;
6767
import jakarta.ws.rs.ext.ParamConverterProvider;
68+
import jakarta.ws.rs.sse.SseEventSource;
6869

6970
import org.eclipse.microprofile.config.Config;
7071
import org.eclipse.microprofile.config.ConfigProvider;
@@ -86,6 +87,7 @@
8687
import org.jboss.resteasy.reactive.client.impl.ClientBuilderImpl;
8788
import org.jboss.resteasy.reactive.client.impl.ClientImpl;
8889
import org.jboss.resteasy.reactive.client.impl.MultiInvoker;
90+
import org.jboss.resteasy.reactive.client.impl.SseEventSourceBuilderImpl;
8991
import org.jboss.resteasy.reactive.client.impl.StorkClientRequestFilter;
9092
import org.jboss.resteasy.reactive.client.impl.UniInvoker;
9193
import org.jboss.resteasy.reactive.client.impl.WebTargetImpl;
@@ -226,6 +228,8 @@ void registerClientResponseBuilder(BuildProducer<ServiceProviderBuildItem> servi
226228
serviceProviders.produce(new ServiceProviderBuildItem(ClientBuilder.class.getName(),
227229
ClientBuilderImpl.class.getName()));
228230

231+
serviceProviders.produce(new ServiceProviderBuildItem(SseEventSource.Builder.class.getName(),
232+
SseEventSourceBuilderImpl.class.getName()));
229233
}
230234

231235
@BuildStep

0 commit comments

Comments
 (0)