Prevent double encoding

Atmosphere · Nov 12, 2013 · 0770b52 · 0770b52 · buildhive · Nov 12, 2013
1 parent 5d7dced
commit 0770b52
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/modules/cpr/src/main/java/org/atmosphere/client/TrackMessageSizeInterceptor.java b/modules/cpr/src/main/java/org/atmosphere/client/TrackMessageSizeInterceptor.java
@@ -128,8 +128,10 @@ public byte[] transformPayload(AtmosphereResponse response, byte[] responseDraft
                 response.setCharacterEncoding(OUT_ENCODING);
 
                 CharBuffer cb = inCharset.newDecoder().decode(ByteBuffer.wrap(responseDraft, 0, responseDraft.length));
+                String s = cb.toString();
 
-                if (cb.toString().trim().length() == 0) {
+                if (s.trim().length() == 0 || s.indexOf(endString) != -1) {
+                    logger.debug("Already filtered {}", s);
                     return responseDraft;
                 }