diff --git a/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/AsyncToSyncChannelServer.java b/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/AsyncToSyncChannelServer.java
index 26511a870f..94cd125610 100644
--- a/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/AsyncToSyncChannelServer.java
+++ b/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/AsyncToSyncChannelServer.java
@@ -58,7 +58,7 @@ final public class AsyncToSyncChannelServer implements SyncChannelServer, Accept
         }
 
         // Can we just just undo the adaptor
-        if( channel.getClass() == SyncToAsyncChannel.class ) {
+        if( channel.getClass() == SyncToAsyncChannelServer.class ) {
             return ((SyncToAsyncChannelServer)channel).getSynchChannelServer();
         }
         
diff --git a/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/SyncToAsyncChannelServer.java b/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/SyncToAsyncChannelServer.java
index 92308a02c6..2c3ec3bf8c 100644
--- a/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/SyncToAsyncChannelServer.java
+++ b/activeio/activeio-core/src/main/java/org/apache/activeio/adapter/SyncToAsyncChannelServer.java
@@ -62,7 +62,7 @@ final public class SyncToAsyncChannelServer implements AsyncChannelServer, Runna
         }
 
         // Can we just just undo the adaptor
-        if( channel.getClass() == SyncToAsyncChannel.class ) {
+        if( channel.getClass() == AsyncToSyncChannelServer.class ) {
             return ((AsyncToSyncChannelServer)channel).getAsyncChannelServer();
         }