@Test public void testResetCallbackClient() { GatewayServer server = new GatewayServer(null, 0); server.start(true); try { Thread.sleep(250); } catch (Exception e) { } server.resetCallbackClient(server.getAddress(), GatewayServer.DEFAULT_PYTHON_PORT + 1); try { Thread.sleep(250); } catch (Exception e) { } int pythonPort = server.getPythonPort(); InetAddress pythonAddress = server.getPythonAddress(); assertEquals(pythonPort, GatewayServer.DEFAULT_PYTHON_PORT + 1); assertEquals(pythonAddress, server.getAddress()); server.shutdown(true); }
public void resetCallbackClient(InetAddress pythonAddress, int pythonPort) { gateway.resetCallbackClient(pythonAddress, pythonPort); this.pythonPort = pythonPort; this.pythonAddress = pythonAddress; }
GatewayServer extends DefaultGatewayServerListener implements Py4JJavaServer, Runnable { public void resetCallbackClient(InetAddress pythonAddress, int pythonPort) { gateway.resetCallbackClient(pythonAddress, pythonPort); this.pythonPort = pythonPort; this.pythonAddress = pythonAddress; } }
GatewayServer extends DefaultGatewayServerListener implements Py4JJavaServer, Runnable { public void resetCallbackClient(InetAddress pythonAddress, int pythonPort) { gateway.resetCallbackClient(pythonAddress, pythonPort); this.pythonPort = pythonPort; this.pythonAddress = pythonAddress; } GatewayServer();  GatewayServer(Object entryPoint);  GatewayServer(Object entryPoint, int port);  GatewayServer(Object entryPoint, int port, int pythonPort, InetAddress address, InetAddress pythonAddress,
			int connectTimeout, int readTimeout, List<Class<? extends Command>> customCommands);  GatewayServer(Object entryPoint, int port, int connectTimeout, int readTimeout);  GatewayServer(Object entryPoint, int port, int pythonPort, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands);  GatewayServer(Object entryPoint, int port, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient);  GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient);  GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient,
			ServerSocketFactory sSocketFactory);   GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient,
			ServerSocketFactory sSocketFactory, String authToken);  GatewayServer(Gateway gateway, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, ServerSocketFactory sSocketFactory); private  GatewayServer(Gateway gateway, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, ServerSocketFactory sSocketFactory, String authToken); }
GatewayServer extends DefaultGatewayServerListener implements Py4JJavaServer, Runnable { public void resetCallbackClient(InetAddress pythonAddress, int pythonPort) { gateway.resetCallbackClient(pythonAddress, pythonPort); this.pythonPort = pythonPort; this.pythonAddress = pythonAddress; } GatewayServer();  GatewayServer(Object entryPoint);  GatewayServer(Object entryPoint, int port);  GatewayServer(Object entryPoint, int port, int pythonPort, InetAddress address, InetAddress pythonAddress,
			int connectTimeout, int readTimeout, List<Class<? extends Command>> customCommands);  GatewayServer(Object entryPoint, int port, int connectTimeout, int readTimeout);  GatewayServer(Object entryPoint, int port, int pythonPort, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands);  GatewayServer(Object entryPoint, int port, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient);  GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient);  GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient,
			ServerSocketFactory sSocketFactory);   GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient,
			ServerSocketFactory sSocketFactory, String authToken);  GatewayServer(Gateway gateway, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, ServerSocketFactory sSocketFactory); private  GatewayServer(Gateway gateway, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, ServerSocketFactory sSocketFactory, String authToken); static void turnAllLoggingOn(); static void turnLoggingOff(); static void turnLoggingOn(); static InetAddress defaultAddress(); static InetAddress defaultIPv6Address(); void resetCallbackClient(InetAddress pythonAddress, int pythonPort); void addListener(GatewayServerListener listener); void connectionStopped(Py4JServerConnection gatewayConnection); @Override InetAddress getAddress(); Py4JPythonClient getCallbackClient(); int getConnectTimeout(); Gateway getGateway(); @Override int getListeningPort(); @Override int getPort(); @Override InetAddress getPythonAddress(); @Override int getPythonPort(); int getReadTimeout(); @Override void removeListener(GatewayServerListener listener); @Override void run(); void shutdown(); void shutdown(boolean shutdownCallbackClient); void start(); void start(boolean fork); Object getPythonServerEntryPoint(@SuppressWarnings("rawtypes") Class[] interfacesToImplement); static void main(String[] args); List<Class<? extends Command>> getCustomCommands(); List<GatewayServerListener> getListeners(); }
GatewayServer extends DefaultGatewayServerListener implements Py4JJavaServer, Runnable { public void resetCallbackClient(InetAddress pythonAddress, int pythonPort) { gateway.resetCallbackClient(pythonAddress, pythonPort); this.pythonPort = pythonPort; this.pythonAddress = pythonAddress; } GatewayServer();  GatewayServer(Object entryPoint);  GatewayServer(Object entryPoint, int port);  GatewayServer(Object entryPoint, int port, int pythonPort, InetAddress address, InetAddress pythonAddress,
			int connectTimeout, int readTimeout, List<Class<? extends Command>> customCommands);  GatewayServer(Object entryPoint, int port, int connectTimeout, int readTimeout);  GatewayServer(Object entryPoint, int port, int pythonPort, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands);  GatewayServer(Object entryPoint, int port, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient);  GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient);  GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient,
			ServerSocketFactory sSocketFactory);   GatewayServer(Object entryPoint, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, Py4JPythonClient cbClient,
			ServerSocketFactory sSocketFactory, String authToken);  GatewayServer(Gateway gateway, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, ServerSocketFactory sSocketFactory); private  GatewayServer(Gateway gateway, int port, InetAddress address, int connectTimeout, int readTimeout,
			List<Class<? extends Command>> customCommands, ServerSocketFactory sSocketFactory, String authToken); static void turnAllLoggingOn(); static void turnLoggingOff(); static void turnLoggingOn(); static InetAddress defaultAddress(); static InetAddress defaultIPv6Address(); void resetCallbackClient(InetAddress pythonAddress, int pythonPort); void addListener(GatewayServerListener listener); void connectionStopped(Py4JServerConnection gatewayConnection); @Override InetAddress getAddress(); Py4JPythonClient getCallbackClient(); int getConnectTimeout(); Gateway getGateway(); @Override int getListeningPort(); @Override int getPort(); @Override InetAddress getPythonAddress(); @Override int getPythonPort(); int getReadTimeout(); @Override void removeListener(GatewayServerListener listener); @Override void run(); void shutdown(); void shutdown(boolean shutdownCallbackClient); void start(); void start(boolean fork); Object getPythonServerEntryPoint(@SuppressWarnings("rawtypes") Class[] interfacesToImplement); static void main(String[] args); List<Class<? extends Command>> getCustomCommands(); List<GatewayServerListener> getListeners(); static final String DEFAULT_ADDRESS; static final String DEFAULT_IPv6_ADDRESS; static final int DEFAULT_PORT; static final int DEFAULT_PYTHON_PORT; static final int DEFAULT_CONNECT_TIMEOUT; static final int DEFAULT_READ_TIMEOUT; static final String GATEWAY_SERVER_ID; static final Logger PY4J_LOGGER; }