+/*
+ * Copyright (c) 2014, 2015 Cisco Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
+
package org.opendaylight.controller.md.sal.dom.xsql.jdbc;
import java.io.BufferedInputStream;
}
private void init() throws Exception {
- if (addr.startsWith("http://"))
+ if (addr.startsWith("http://")) {
addr = addr.substring(7);
+ }
System.err.print("Address is:" + addr);
socket = new Socket(addr, 40004);
try {
public JDBCConnection(boolean server) {
try {
- ServerSocket s = new ServerSocket(50003);
- socket = s.accept();
- try {
- in = new DataInputStream(new BufferedInputStream(
- socket.getInputStream()));
- out = new DataOutputStream(new BufferedOutputStream(
- socket.getOutputStream()));
- new JDBCObjectReader();
- new Thread(this).start();
- } catch (Exception err) {
- err.printStackTrace();
+ try (ServerSocket s = new ServerSocket(50003)) {
+ socket = s.accept();
+ try {
+ in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));
+ out = new DataOutputStream(new BufferedOutputStream(socket.getOutputStream()));
+ new JDBCObjectReader();
+ new Thread(this).start();
+ } catch (Exception err) {
+ err.printStackTrace();
+ }
}
} catch (Exception err) {
err.printStackTrace();