parent
9d818be73d
commit
93be86260d
|
@ -19,7 +19,6 @@ public class StreamConnector implements LinkConnector {
|
||||||
|
|
||||||
private final PortHolder portHolder;
|
private final PortHolder portHolder;
|
||||||
private final LinkManager linkManager;
|
private final LinkManager linkManager;
|
||||||
private BinaryProtocol.Arguments arguments;
|
|
||||||
|
|
||||||
public StreamConnector(LinkManager linkManager, Callable<IoStream> ioStreamCallable) {
|
public StreamConnector(LinkManager linkManager, Callable<IoStream> ioStreamCallable) {
|
||||||
this.linkManager = linkManager;
|
this.linkManager = linkManager;
|
||||||
|
@ -29,7 +28,6 @@ public class StreamConnector implements LinkConnector {
|
||||||
|
|
||||||
@Override
|
@Override
|
||||||
public void connectAndReadConfiguration(BinaryProtocol.Arguments arguments, ConnectionStateListener listener) {
|
public void connectAndReadConfiguration(BinaryProtocol.Arguments arguments, ConnectionStateListener listener) {
|
||||||
this.arguments = arguments;
|
|
||||||
log.info("StreamConnector: connecting");
|
log.info("StreamConnector: connecting");
|
||||||
portHolder.listener = listener;
|
portHolder.listener = listener;
|
||||||
log.info("scheduleOpening");
|
log.info("scheduleOpening");
|
||||||
|
|
Loading…
Reference in New Issue