From: Maros Marsalek Date: Tue, 18 Feb 2014 11:58:47 +0000 (+0100) Subject: Make use of new sendMessage method in AbstractNegotiator X-Git-Tag: autorelease-tag-v20140601202136_82eb3f9~400 X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=commitdiff_plain;h=fe9d7d25e75f9ebf84daf8f87419f9b6a45a916d;hp=-c Make use of new sendMessage method in AbstractNegotiator Change-Id: Ieeb104aa34b8140936a1daf8011ba3b0effc79d5 Signed-off-by: Maros Marsalek --- fe9d7d25e75f9ebf84daf8f87419f9b6a45a916d 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");