X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fnetconf%2Fnetconf-util%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Futil%2FAbstractNetconfSessionNegotiator.java;h=71f08339c803774d3d3b50a701b2d55454e9081e;hp=7f2d8c30f045fb6830458aa7fd461cc7885e8349;hb=fe9d7d25e75f9ebf84daf8f87419f9b6a45a916d;hpb=df2aabb0c61b9be04623c2a660c5a1592ff051f7 diff --git a/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/AbstractNetconfSessionNegotiator.java b/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/AbstractNetconfSessionNegotiator.java index 7f2d8c30f0..71f08339c8 100644 --- a/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/AbstractNetconfSessionNegotiator.java +++ b/opendaylight/netconf/netconf-util/src/main/java/org/opendaylight/controller/netconf/util/AbstractNetconfSessionNegotiator.java @@ -123,7 +123,8 @@ extends AbstractSessionNegotiator { } }, connectionTimeoutMillis, TimeUnit.MILLISECONDS); - sendMessage(helloMessage); + // FIXME, make sessionPreferences return HelloMessage, move NetconfHelloMessage to API + sendMessage((NetconfHelloMessage)helloMessage); changeState(State.OPEN_WAIT); } @@ -133,10 +134,6 @@ extends AbstractSessionNegotiator { } } - private void sendMessage(NetconfMessage message) { - this.channel.writeAndFlush(message); - } - @Override protected void handleMessage(NetconfHelloMessage netconfMessage) { Preconditions.checkNotNull(netconfMessage != null, "netconfMessage");