auto-sync
This commit is contained in:
parent
8652ca02aa
commit
19fd16ae4d
|
@ -48,7 +48,7 @@ public class LinkManager {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String unpackConfirmation(String message) {
|
public String unpackConfirmation(String message) {
|
||||||
return TcpConnector.doUnpackConfirmation(message);
|
return message;
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
public static final LinkedBlockingQueue<Runnable> COMMUNICATION_QUEUE = new LinkedBlockingQueue<>();
|
public static final LinkedBlockingQueue<Runnable> COMMUNICATION_QUEUE = new LinkedBlockingQueue<>();
|
||||||
|
|
|
@ -154,7 +154,9 @@ public class TcpConnector implements LinkConnector {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public String unpackConfirmation(String message) {
|
public String unpackConfirmation(String message) {
|
||||||
return doUnpackConfirmation(message);
|
if (message.startsWith(CommandQueue.CONFIRMATION_PREFIX))
|
||||||
|
return message.substring(CommandQueue.CONFIRMATION_PREFIX.length());
|
||||||
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static Collection<String> getAvailablePorts() {
|
public static Collection<String> getAvailablePorts() {
|
||||||
|
|
Loading…
Reference in New Issue