Repository: cxf Updated Branches: refs/heads/master 06588cac6 -> 137485de3
Fixing few checkstyle issues Project: http://git-wip-us.apache.org/repos/asf/cxf/repo Commit: http://git-wip-us.apache.org/repos/asf/cxf/commit/137485de Tree: http://git-wip-us.apache.org/repos/asf/cxf/tree/137485de Diff: http://git-wip-us.apache.org/repos/asf/cxf/diff/137485de Branch: refs/heads/master Commit: 137485de37b3bf81e305e616a5af81741620f547 Parents: 06588ca Author: Sergey Beryozkin <sberyoz...@gmail.com> Authored: Wed Mar 22 12:19:05 2017 +0000 Committer: Sergey Beryozkin <sberyoz...@gmail.com> Committed: Wed Mar 22 12:19:05 2017 +0000 ---------------------------------------------------------------------- .../main/java/org/apache/cxf/jaxrs/sse/SseBroadcasterImpl.java | 3 ++- .../org/apache/cxf/jaxrs/sse/SseUnboundedSubscription.java | 6 +++--- 2 files changed, 5 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/cxf/blob/137485de/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseBroadcasterImpl.java ---------------------------------------------------------------------- diff --git a/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseBroadcasterImpl.java b/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseBroadcasterImpl.java index 06fb8e3..8a24369 100644 --- a/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseBroadcasterImpl.java +++ b/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseBroadcasterImpl.java @@ -56,7 +56,8 @@ public class SseBroadcasterImpl implements SseBroadcaster { @Override public void broadcast(OutboundSseEvent event) { - for (Map.Entry<Flow.Subscriber<? super OutboundSseEvent>, SseUnboundedSubscription> entry: subscribers.entrySet()) { + for (Map.Entry<Flow.Subscriber<? super OutboundSseEvent>, SseUnboundedSubscription> entry + : subscribers.entrySet()) { try { entry.getValue().send(event); } catch (final Exception ex) { http://git-wip-us.apache.org/repos/asf/cxf/blob/137485de/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseUnboundedSubscription.java ---------------------------------------------------------------------- diff --git a/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseUnboundedSubscription.java b/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseUnboundedSubscription.java index 7c0cb60..92f24ab 100644 --- a/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseUnboundedSubscription.java +++ b/rt/rs/sse/src/main/java/org/apache/cxf/jaxrs/sse/SseUnboundedSubscription.java @@ -27,13 +27,13 @@ import javax.ws.rs.sse.OutboundSseEvent; class SseUnboundedSubscription implements Subscription { // Has subscription been cancelled or not? - private boolean cancelled = false; + private boolean cancelled; // Current demand: what has been requested but not yet delivered - private long demand = 0; + private long demand; private final BlockingQueue<OutboundSseEvent> buffer = new LinkedBlockingQueue<>(); private final Flow.Subscriber<? super OutboundSseEvent> subscriber; - public SseUnboundedSubscription(Flow.Subscriber<? super OutboundSseEvent> subscriber) { + SseUnboundedSubscription(Flow.Subscriber<? super OutboundSseEvent> subscriber) { this.subscriber = subscriber; }