|
@@ -178,7 +178,7 @@ public class KernelAdapter extends Thread
|
|
|
} else {
|
|
} else {
|
|
|
// See if we already have one
|
|
// See if we already have one
|
|
|
MessageProtocol result = messageBuffers.get(p);
|
|
MessageProtocol result = messageBuffers.get(p);
|
|
|
- if( result != null ) {
|
|
|
|
|
|
|
+ if( result == null ) {
|
|
|
result = new MessageProtocol();
|
|
result = new MessageProtocol();
|
|
|
messageBuffers.put(p, result);
|
|
messageBuffers.put(p, result);
|
|
|
}
|
|
}
|