Cluster cluster = Cluster.build()
        .addContactPoints(janusGraphHosts)
        .port(janusGraphPort)
        .credentials(janusGraphUserName, janusGraphPassword)
        .serializer(new GryoMessageSerializerV1d0(GryoMapper.build().addRegistry(JanusGraphIoRegistry.getInstance())))
        .maxConnectionPoolSize(8)
        .create();
return AnonymousTraversalSource.traversal().withRemote(DriverRemoteConnection.using(cluster, janusGraphSourceName));