public static RpcService createRpcService(
			final Configuration configuration,
			final HighAvailabilityServices haServices) throws Exception {

		checkNotNull(configuration);
		checkNotNull(haServices);

		final String taskManagerAddress = determineTaskManagerBindAddress(configuration, haServices);
		final String portRangeDefinition = configuration.getString(TaskManagerOptions.RPC_PORT);

		return AkkaRpcServiceUtils.createRpcService(taskManagerAddress, portRangeDefinition, configuration);
	}
public static RpcService createRpcService ( final Configuration configuration , final HighAvailabilityServices haServices ) throws Exception { checkNotNull ( configuration ) ; checkNotNull ( haServices ) ; final String taskManagerAddress = determineTaskManagerBindAddress ( configuration , haServices ) ; final String portRangeDefinition = configuration . getString ( TaskManagerOptions . RPC_PORT ) ; return AkkaRpcServiceUtils . createRpcService ( taskManagerAddress , portRangeDefinition , configuration ) ; }
Create a RPC service for the task manager.

@param configuration The configuration for the TaskManager.
@param haServices to use for the task manager hostname retrieval