cxf-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From serg...@apache.org
Subject cxf git commit: Fixing few checkstyle issues
Date Wed, 22 Mar 2017 12:19:20 GMT
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 <sberyozkin@gmail.com>
Authored: Wed Mar 22 12:19:05 2017 +0000
Committer: Sergey Beryozkin <sberyozkin@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;
     }
     


Mime
View raw message