Skip to content

Commit 3aaa3f9

Browse files
authored
Propagate back-pressure correctly in MP REST Client SSE publisher (#5426)
* Propagate backpressure correctly in MP REST Client SSE publisher #5425
1 parent 8a63706 commit 3aaa3f9

File tree

1 file changed

+2
-2
lines changed
  • ext/microprofile/mp-rest-client/src/main/java/org/glassfish/jersey/microprofile/restclient

1 file changed

+2
-2
lines changed

ext/microprofile/mp-rest-client/src/main/java/org/glassfish/jersey/microprofile/restclient/SseEventPublisher.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright (c) 2021 Oracle and/or its affiliates. All rights reserved.
2+
* Copyright (c) 2021, 2023 Oracle and/or its affiliates. All rights reserved.
33
* Copyright (c) 2021 Payara Foundation and/or its affiliates. All rights reserved.
44
*
55
* This program and the accompanying materials are made available under the
@@ -66,7 +66,7 @@ public class SseEventPublisher extends EventInput implements Publisher<InboundEv
6666

6767
this.executor = executor;
6868
this.genericType = genericType;
69-
this.publisher = new JerseyPublisher<>(executor::submit, JerseyPublisher.PublisherStrategy.BEST_EFFORT);
69+
this.publisher = new JerseyPublisher<>(executor::submit, JerseyPublisher.PublisherStrategy.BLOCKING);
7070
}
7171

7272
private static final Logger LOG = Logger.getLogger(SseEventPublisher.class.getName());

0 commit comments

Comments
 (0)