You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cxf.apache.org by se...@apache.org on 2017/03/22 12:19:20 UTC
cxf git commit: Fixing few checkstyle issues
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 <sb...@gmail.com>
Authored: Wed Mar 22 12:19:05 2017 +0000
Committer: Sergey Beryozkin <sb...@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;
}