X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fnetconf%2Fnetconf-client%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fnetconf%2Fclient%2FNetconfClientSession.java;h=31a7661b2c17ccb8fdff3688f7111a26b4fe3f97;hb=294e250fa1c11f36a6ddb9470f985df978039355;hp=9bafe9760ae202cd8c75adfd0aa8a27aafae42ae;hpb=dbd3524a5cdd27dd49fd09f1cf4ff0ff40e85c5e;p=controller.git diff --git a/opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/NetconfClientSession.java b/opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/NetconfClientSession.java index 9bafe9760a..31a7661b2c 100644 --- a/opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/NetconfClientSession.java +++ b/opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/NetconfClientSession.java @@ -9,11 +9,11 @@ package org.opendaylight.controller.netconf.client; import io.netty.channel.Channel; +import io.netty.handler.codec.ByteToMessageDecoder; +import io.netty.handler.codec.MessageToByteEncoder; import java.util.Collection; +import org.opendaylight.controller.netconf.api.NetconfMessage; import org.opendaylight.controller.netconf.nettyutil.AbstractNetconfSession; -import org.opendaylight.controller.netconf.nettyutil.handler.NetconfEXICodec; -import org.opendaylight.controller.netconf.nettyutil.handler.NetconfEXIToMessageDecoder; -import org.opendaylight.controller.netconf.nettyutil.handler.NetconfMessageToEXIEncoder; import org.opendaylight.controller.netconf.nettyutil.handler.NetconfMessageToXMLEncoder; import org.opendaylight.controller.netconf.nettyutil.handler.NetconfXMLToMessageDecoder; import org.slf4j.Logger; @@ -49,10 +49,10 @@ public class NetconfClientSession extends AbstractNetconfSession encoder) { // TODO used only in negotiator, client supports only auto start-exi - replaceMessageDecoder(new NetconfEXIToMessageDecoder(exiCodec)); - replaceMessageEncoder(new NetconfMessageToEXIEncoder(exiCodec)); + replaceMessageDecoder(decoder); + replaceMessageEncoder(encoder); } @Override