[SEARCH-1643]

Code style fixes
This commit is contained in:
eliaporciani
2019-06-04 09:47:07 +02:00
parent b97d15b678
commit f89af0e6ea
2 changed files with 61 additions and 54 deletions

View File

@@ -28,25 +28,30 @@ import org.slf4j.LoggerFactory;
* *
* @author Elia * @author Elia
*/ */
public class LastRegisteredShardRouter implements DocRouter { public class LastRegisteredShardRouter implements DocRouter
{
protected final static Logger log = LoggerFactory.getLogger(ExplicitRouter.class); protected final static Logger log = LoggerFactory.getLogger(ExplicitRouter.class);
public LastRegisteredShardRouter() { public LastRegisteredShardRouter()
{
} }
@Override @Override
public boolean routeAcl(int shardCount, int shardInstance, Acl acl) { public boolean routeAcl(int shardCount, int shardInstance, Acl acl)
{
//all acls go to all shards. //all acls go to all shards.
return true; return true;
} }
@Override @Override
public boolean routeNode(int shardCount, int shardInstance, Node node) { public boolean routeNode(int shardCount, int shardInstance, Node node)
{
Integer explicitShardId = node.getExplicitShardId(); Integer explicitShardId = node.getExplicitShardId();
if (explicitShardId == null) { if (explicitShardId == null)
{
log.error("explicitShardId is not set for node " + node.getNodeRef()); log.error("explicitShardId is not set for node " + node.getNodeRef());
return false; return false;
} }

View File

@@ -158,11 +158,13 @@ public class GetNodesParameters
this.shardProperty = shardProperty; this.shardProperty = shardProperty;
} }
public String getCoreName() { public String getCoreName()
{
return this.coreName; return this.coreName;
} }
public void setCoreName(String coreName){ public void setCoreName(String coreName)
{
this.coreName = coreName; this.coreName = coreName;
} }