Skip to content

Commit

Permalink
Moved OptionalHostnamePort to non-public package
Browse files Browse the repository at this point in the history
OptionalHostnamePort was declared as a public class in the public
org.neo4j.helpers public package. This is really an implementation
detail and doesn't need to be public.
The class has been moved to org.neo4j.kernel.impl.util which isn't
public.
  • Loading branch information
phughk committed Dec 6, 2017
1 parent 32c00e1 commit 3290ed6
Show file tree
Hide file tree
Showing 13 changed files with 18 additions and 17 deletions.
Expand Up @@ -29,9 +29,6 @@
import java.util.Optional;
import java.util.function.Function;

import org.neo4j.helpers.HostnamePort;
import org.neo4j.helpers.OptionalHostnamePort;

public class Converters
{
private Converters()
Expand Down
Expand Up @@ -17,11 +17,13 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package org.neo4j.helpers;
package org.neo4j.kernel.impl.util;

import java.util.Optional;
import javax.annotation.Nullable;

import org.neo4j.helpers.HostnamePort;

public class OptionalHostnamePort
{
private Optional<String> hostname;
Expand Down
Expand Up @@ -23,7 +23,7 @@
import org.neo4j.helpers.AdvertisedSocketAddress;
import org.neo4j.helpers.HostnamePort;
import org.neo4j.helpers.ListenSocketAddress;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.impl.enterprise.configuration.OnlineBackupSettings;

Expand All @@ -45,12 +45,12 @@ AdvertisedSocketAddress resolveCorrectCCAddress( Config config, OptionalHostname

private HostnamePort readDefaultConfigAddressHA( Config config )
{
return OnlineBackupSettings.online_backup_server.from( config );
return config.get( OnlineBackupSettings.online_backup_server );
}

private AdvertisedSocketAddress readDefaultConfigAddressCC( Config config )
{
return advertisedFromListenAddress( CausalClusteringSettings.transaction_listen_address.from( config ) );
return advertisedFromListenAddress( config.get( CausalClusteringSettings.transaction_listen_address ) );
}

private AdvertisedSocketAddress advertisedFromListenAddress( ListenSocketAddress listenSocketAddress )
Expand Down
Expand Up @@ -31,7 +31,7 @@
import org.neo4j.commandline.arguments.common.OptionalCanonicalPath;
import org.neo4j.consistency.ConsistencyCheckSettings;
import org.neo4j.consistency.checking.full.ConsistencyFlags;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.helpers.TimeUtil;
import org.neo4j.kernel.configuration.Config;

Expand Down
Expand Up @@ -21,7 +21,7 @@

import java.io.File;

import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.lifecycle.Lifecycle;

Expand Down
Expand Up @@ -22,7 +22,7 @@
import java.io.File;

import org.neo4j.commandline.admin.CommandFailed;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.io.pagecache.PageCache;
import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.lifecycle.LifeSupport;
Expand Down
Expand Up @@ -26,7 +26,7 @@
import org.neo4j.causalclustering.catchup.storecopy.StoreIdDownloadFailedException;
import org.neo4j.causalclustering.identity.StoreId;
import org.neo4j.helpers.AdvertisedSocketAddress;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.lifecycle.LifecycleAdapter;

Expand Down
Expand Up @@ -23,7 +23,7 @@

import org.neo4j.com.ComException;
import org.neo4j.helpers.HostnamePort;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.impl.store.MismatchingStoreIdException;
import org.neo4j.kernel.lifecycle.LifecycleAdapter;
Expand Down
Expand Up @@ -23,7 +23,7 @@
import java.nio.file.Path;
import java.util.Optional;

import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;

public class OnlineBackupRequiredArguments
{
Expand Down
Expand Up @@ -23,7 +23,7 @@
import org.junit.Test;

import org.neo4j.helpers.HostnamePort;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;

import static org.junit.Assert.assertEquals;
Expand All @@ -45,7 +45,9 @@ public void setup()
@Test
public void noPortResolvesToDefault_ha()
{
// given
Integer portIsNotSupplied = null;

// when
HostnamePort resolved = subject.resolveCorrectHAAddress( defaultConfig, new OptionalHostnamePort( "localhost", portIsNotSupplied, null ) );

Expand Down
Expand Up @@ -26,7 +26,7 @@

import org.neo4j.com.ComException;
import org.neo4j.helpers.HostnamePort;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;

import static org.junit.Assert.assertEquals;
Expand Down
Expand Up @@ -28,7 +28,7 @@

import org.neo4j.commandline.admin.CommandFailed;
import org.neo4j.commandline.admin.OutsideWorld;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.io.fs.FileSystemAbstraction;
import org.neo4j.io.pagecache.PageCache;
import org.neo4j.kernel.configuration.Config;
Expand Down
Expand Up @@ -31,7 +31,7 @@
import org.neo4j.causalclustering.catchup.storecopy.StoreIdDownloadFailedException;
import org.neo4j.causalclustering.identity.StoreId;
import org.neo4j.helpers.AdvertisedSocketAddress;
import org.neo4j.helpers.OptionalHostnamePort;
import org.neo4j.kernel.impl.util.OptionalHostnamePort;
import org.neo4j.kernel.configuration.Config;

import static org.junit.Assert.assertEquals;
Expand Down

0 comments on commit 3290ed6

Please sign in to comment.