Fix #315 Update Glokka from 1.4 to 1.6

xitrum-framework · Mar 6, 2014 · adfb884 · adfb884
1 parent b375e48
commit adfb884
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 8 deletions.
diff --git a/CHANGELOG.rst b/CHANGELOG.rst
@@ -7,7 +7,7 @@
 * `#318 <https://github.com/ngocdaothanh/xitrum/issues/318>`_
   Fix Netty memory leak at xitrum.util.UrlSafeBase64
 * `#315 <https://github.com/ngocdaothanh/xitrum/issues/315>`_
-  Update Glokka from 1.4 to 1.5
+  Update Glokka from 1.4 to 1.6
 
 3.2:
 

diff --git a/build.sbt b/build.sbt
@@ -31,7 +31,7 @@ libraryDependencies += "io.netty" % "netty-all" % "4.0.17.Final"
 libraryDependencies += "org.javassist" % "javassist" % "3.18.1-GA"
 
 // For clustering SockJS; Akka is included here
-libraryDependencies += "tv.cntt" %% "glokka" % "1.5"
+libraryDependencies += "tv.cntt" %% "glokka" % "1.6"
 
 // Redirect Akka log to SLF4J
 libraryDependencies += "com.typesafe.akka" %% "akka-slf4j" % "2.2.4"

diff --git a/src/main/scala/xitrum/sockjs/NonWebSocketSession.scala b/src/main/scala/xitrum/sockjs/NonWebSocketSession.scala
@@ -113,23 +113,24 @@ class NonWebSocketSession(var receiverCliento: Option[ActorRef], pathPrefix: Str
       unwatchAndStop()
 
     case SubscribeFromReceiverClient =>
+      val s = sender()
       if (closed) {
-        sender ! SubscribeResultToReceiverClientClosed
+        s ! SubscribeResultToReceiverClientClosed
       } else {
         lastSubscribedAt = System.currentTimeMillis()
         if (receiverCliento.isEmpty) {
-          receiverCliento = Some(sender)
-          context.watch(sender)
+          receiverCliento = Some(s)
+          context.watch(s)
           context.setReceiveTimeout(SockJsAction.TIMEOUT_HEARTBEAT)
 
           if (bufferForClientSubscriber.isEmpty) {
-            sender ! SubscribeResultToReceiverClientWaitForMessage
+            s ! SubscribeResultToReceiverClientWaitForMessage
           } else {
-            sender ! SubscribeResultToReceiverClientMessages(bufferForClientSubscriber.toList)
+            s ! SubscribeResultToReceiverClientMessages(bufferForClientSubscriber.toList)
             bufferForClientSubscriber.clear()
           }
         } else {
-          sender ! SubscribeResultToReceiverClientAnotherConnectionStillOpen
+          s ! SubscribeResultToReceiverClientAnotherConnectionStillOpen
         }
       }