2 * ============LICENSE_START=======================================================
4 * ================================================================================
5 * Copyright (C) 2017 AT&T Intellectual Property. All rights
7 * ================================================================================
8 * Licensed under the Apache License, Version 2.0 (the "License");
9 * you may not use this file except in compliance with the License.
10 * You may obtain a copy of the License at
12 * http://www.apache.org/licenses/LICENSE-2.0
14 * Unless required by applicable law or agreed to in writing, software
15 * distributed under the License is distributed on an "AS IS" BASIS,
16 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17 * See the License for the specific language governing permissions and
18 * limitations under the License.
19 * ============LICENSE_END=========================================================
22 package org.openecomp.appc.adapter.netconf.internal;
24 import org.slf4j.Logger;
25 import org.slf4j.LoggerFactory;
30 * Provides basic methods for exchanging netconf messages.
32 public class NetconfAdapter2 {
34 private static final Logger LOG = LoggerFactory.getLogger(NetconfAdapter2.class);
37 private final PipedOutputStream pipedOutIn = new PipedOutputStream();
38 private PipedInputStream in;
40 private final PipedInputStream pipedInOut = new PipedInputStream();
41 private PipedOutputStream out;
48 public NetconfAdapter2() throws IOException {
49 in = new PipedInputStream(pipedOutIn);
50 out = new PipedOutputStream(pipedInOut);
54 * @return InputStream this instance will read netconf messages from.
56 public InputStream getIn() {
61 * @return OutputStream this instance will write netconf messages to.
63 public OutputStream getOut() {
68 * Receives netconf message from InputStream and return it's text (without netconf frame characters).
70 * @return text of message received from netconf device
73 public String receiveMessage() throws IOException {
74 NetconfMessage message = new NetconfMessage();
75 byte[] buf = new byte[1024];
77 while((c = pipedInOut.read(buf)) > 0) {
78 message.append(buf, 0, c);
79 if (message.isCompleted()) {
83 String text = message.getText();
84 if(LOG.isDebugEnabled()) {
85 LOG.debug("Received message from netconf device:\n" + text);
91 * Sends netconf message with provided text (adds netconf frame characters and sends the message).
93 * @param text text of message to be sent to netconf device
96 public void sendMessage(final String text) throws IOException {
97 if(LOG.isDebugEnabled()) {
98 LOG.debug("Sending message to netconf device:\n" + text);
100 pipedOutIn.write(new NetconfMessage(text).getFrame());