BrokerConnection implements Connection { public synchronized void close() { try { stop(); log.debug("Closing connection to {}/{}", getSocket().getRemoteHostName(), getSocket().getRemoteHostAddress()); getSocket().close(); } catch (IOException e) { e.printStackTrace(); } catch (RpcException rpcError) { rpcError.printStackTrace(); } } BrokerConnection(RpcHost host, Socket socket, RpcProtocol protocol); RpcHost getHost(); SystemInfo getSystemInfo(); ConnectionUserDetails getUserDetails(); boolean isAuthenticated(); synchronized void stop(); RpcResponse send(RpcRequest request); synchronized RpcResponse sendInternal(RpcRequest request); synchronized void close(); boolean isClosed(); boolean isStale(); @Override ConnectionMetrics getMetrics(); @Override long getElapsedMillis(); void setElapsedMillis(long millis); SystemInfo fetchSystemInfo(); void pulse(); void authenticate(AccessVerifyConnectionSpec av); void authenticate(AppHandleConnectionSpec appHandleConnectionSpec); String getCurrentRpcContext();  }
@Ignore @Test public void close() { }