Merge pull request #3 from robertroeser/master

added exception handler

Author: rdegnan

reactivesocket-local/build.gradle

@@ -0,0 +1,14 @@
+group 'io.reactivesocket'
+version '0.1.3-SNAPSHOT'
+
+apply plugin: 'java'
+
+sourceCompatibility = 1.8
+
+repositories {
+    mavenCentral()
+}
+
+dependencies {
+    testCompile group: 'junit', name: 'junit', version: '4.11'
+}

reactivesocket-netty/src/main/java/io/reactivesocket/netty/websocket/server/ReactiveSocketServerHandler.java

@@ -27,11 +27,15 @@
 import io.reactivesocket.LeaseGovernor;
 import io.reactivesocket.ReactiveSocket;
 import io.reactivesocket.netty.MutableDirectByteBuf;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.util.concurrent.ConcurrentHashMap;
 
 @ChannelHandler.Sharable
 public class ReactiveSocketServerHandler extends SimpleChannelInboundHandler<BinaryWebSocketFrame> {
+    private Logger logger = LoggerFactory.getLogger(ReactiveSocketServerHandler.class);
+
     private ConcurrentHashMap<ChannelId, ServerWebSocketDuplexConnection> duplexConnections = new ConcurrentHashMap<>();
 
     private ConnectionSetupHandler setupHandler;
@@ -74,4 +78,11 @@ protected void channelRead0(ChannelHandlerContext ctx, BinaryWebSocketFrame msg)
                 .forEach(o -> o.onNext(from));
         }
     }
+
+    @Override
+    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
+        super.exceptionCaught(ctx, cause);
+
+        logger.error("caught an unhandled exception", cause);
+    }
 }