Commit 51ba7512 authored by neelesh thakur's avatar neelesh thakur
Browse files

rollback whitespace changes

parent 5f4ee1f7
Pipeline #9234 failed
...@@ -44,11 +44,11 @@ public class CrossTenantInfoServiceImpl implements ITenantInfoService, ICrossTen ...@@ -44,11 +44,11 @@ public class CrossTenantInfoServiceImpl implements ITenantInfoService, ICrossTen
return tenantInfo; return tenantInfo;
} }
public String getPartitionId() { public String getPartitionId(){
return dpsHeaders.getPartitionId(); return dpsHeaders.getPartitionId();
} }
public TenantInfo getTenantInfo(String accountId) { public TenantInfo getTenantInfo(String accountId){
return tenantFactory.getTenantInfo(accountId); return tenantFactory.getTenantInfo(accountId);
} }
...@@ -64,4 +64,5 @@ public class CrossTenantInfoServiceImpl implements ITenantInfoService, ICrossTen ...@@ -64,4 +64,5 @@ public class CrossTenantInfoServiceImpl implements ITenantInfoService, ICrossTen
} }
return tenantInfos; return tenantInfos;
} }
} }
...@@ -89,6 +89,7 @@ public class ScrollQueryServiceImpl extends QueryBase implements IScrollQuerySer ...@@ -89,6 +89,7 @@ public class ScrollQueryServiceImpl extends QueryBase implements IScrollQuerySer
if (results != null) { if (results != null) {
queryResponse.setResults(results); queryResponse.setResults(results);
queryResponse.setCursor(this.refreshCursorCache(searchScrollResponse.getScrollId(), dpsHeaders.getUserEmail())); queryResponse.setCursor(this.refreshCursorCache(searchScrollResponse.getScrollId(), dpsHeaders.getUserEmail()));
this.querySuccessAuditLogger(searchRequest); this.querySuccessAuditLogger(searchRequest);
} }
} else { } else {
...@@ -163,5 +164,4 @@ public class ScrollQueryServiceImpl extends QueryBase implements IScrollQuerySer ...@@ -163,5 +164,4 @@ public class ScrollQueryServiceImpl extends QueryBase implements IScrollQuerySer
void queryFailedAuditLogger(Query request) { void queryFailedAuditLogger(Query request) {
this.auditLogger.queryIndexWithCursorFailed(Lists.newArrayList(request.toString())); this.auditLogger.queryIndexWithCursorFailed(Lists.newArrayList(request.toString()));
} }
} }
...@@ -109,7 +109,6 @@ public class AttributesTest { ...@@ -109,7 +109,6 @@ public class AttributesTest {
attribute.setName("Operataor"); attribute.setName("Operataor");
attribute.setSchemaMapping(schemaMapping); attribute.setSchemaMapping(schemaMapping);
ls.add(attribute); ls.add(attribute);
when(dpsHeaders.getPartitionId()).thenReturn("tenant1"); when(dpsHeaders.getPartitionId()).thenReturn("tenant1");
when(elasticClientHandler.createRestClient()).thenReturn(restHighLevelClient); when(elasticClientHandler.createRestClient()).thenReturn(restHighLevelClient);
doReturn(this.indicesClient).when(this.restHighLevelClient).indices(); doReturn(this.indicesClient).when(this.restHighLevelClient).indices();
......
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment