commit 8a5378f5a32c6c5bd59babb8bc92cd07e9ad4da6
author sboikov <sboikov@gridgain.com> Wed Sep 07 12:25:07 2016 +0300
committer sboikov <sboikov@gridgain.com> Wed Sep 07 12:25:07 2016 +0300
tree 2149c06a499e64cbeb595549fa2b028c55190c73
parent 224cae1dd5dc5d95843c6ea1a72f61f27ea35cb4

test

modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java

diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
index a672d7c..9388a8e 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/odbc/OdbcProcessor.java
@@ -29,6 +29,7 @@
 import org.apache.ignite.internal.util.nio.GridNioCodecFilter;
 import org.apache.ignite.internal.util.nio.GridNioFilter;
 import org.apache.ignite.internal.util.nio.GridNioServer;
+import org.apache.ignite.internal.util.nio.GridNioSession;
 import org.apache.ignite.internal.util.typedef.F;
 import org.apache.ignite.internal.util.typedef.internal.U;
 import org.apache.ignite.marshaller.Marshaller;
@@ -123,7 +124,11 @@
                 for (int port = hostPort.portFrom(); port <= hostPort.portTo(); port++) {
                     try {
                         GridNioFilter[] filters = new GridNioFilter[] {
-                            new GridNioAsyncNotifyFilter(ctx.gridName(), odbcExecSvc, log),
+                            new GridNioAsyncNotifyFilter(ctx.gridName(), odbcExecSvc, log) {
+                                @Override public void onSessionOpened(GridNioSession ses) throws IgniteCheckedException {
+                                    proceedSessionOpened(ses);
+                                }
+                            },
                             new GridNioCodecFilter(new OdbcBufferedParser(), log, false)
                         };