Commit 4ea6e783 authored by afreyssin's avatar afreyssin

Minor changes (JORAM-287).

parent 4f864a3e
/* /*
* Copyright (C) 2004 - 2017 ScalAgent Distributed Technologies * Copyright (C) 2004 - 2018 ScalAgent Distributed Technologies
* *
* This library is free software; you can redistribute it and/or * This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public * modify it under the terms of the GNU Lesser General Public
...@@ -120,9 +120,11 @@ public class TcpConnection implements TcpConnectionMBean, ProxyMessageSender { ...@@ -120,9 +120,11 @@ public class TcpConnection implements TcpConnectionMBean, ProxyMessageSender {
if (logger.isLoggable(BasicLevel.DEBUG)) if (logger.isLoggable(BasicLevel.DEBUG))
logger.log(BasicLevel.DEBUG, "TcpConnection.start()"); logger.log(BasicLevel.DEBUG, "TcpConnection.start()");
try { try {
// TODO (AF): Cleans this code, a part of the initialization below should be done
// in the constructor.
if (ctx.isNoAckedQueue()) { if (ctx.isNoAckedQueue()) {
ioctrl.setNoAckedQueue(ctx.isNoAckedQueue()); ioctrl.setNoAckedQueue(ctx.isNoAckedQueue()); // Always true!!
//ctx.getQueueWorker().ioctrl = ioctrl; // ctx.getQueueWorker().ioctrl = ioctrl;
// ctx.getQueueWorker().tcpConnection= this; // ctx.getQueueWorker().tcpConnection= this;
ctx.getQueueWorker().sender = this; ctx.getQueueWorker().sender = this;
} else { } else {
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment