honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Updating with ES-side abstract method addition 

Original commit: elastic/x-pack-elasticsearch@0d075b433b
This commit is contained in:
Chris Earle 2016-05-05 19:01:03 -04:00
parent 080000a595
commit fd62b2308e
3 changed files with 7 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
elasticsearch/x-pack/shield/src/main/java/org/elasticsearch/shield/action/realm/ClearRealmCacheResponse.java
View File

@ -32,14 +32,12 @@ public class ClearRealmCacheResponse extends BaseNodesResponse<ClearRealmCacheRe
}
@Override
public void readFrom(StreamInput in) throws IOException {
super.readFrom(in);
nodes = in.readList(Node::readNodeResponse);
protected List<ClearRealmCacheResponse.Node> readNodesFrom(StreamInput in) throws IOException {
return in.readList(Node::readNodeResponse);
}
@Override
public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out);
protected void writeNodesTo(StreamOutput out, List<ClearRealmCacheResponse.Node> nodes) throws IOException {
out.writeStreamableList(nodes);
}

8
elasticsearch/x-pack/shield/src/main/java/org/elasticsearch/shield/action/role/ClearRolesCacheResponse.java
View File

@ -32,14 +32,12 @@ public class ClearRolesCacheResponse extends BaseNodesResponse<ClearRolesCacheRe
}
@Override
public void readFrom(StreamInput in) throws IOException {
super.readFrom(in);
nodes = in.readList(Node::readNodeResponse);
protected List<ClearRolesCacheResponse.Node> readNodesFrom(StreamInput in) throws IOException {
return in.readList(Node::readNodeResponse);
}
@Override
public void writeTo(StreamOutput out) throws IOException {
super.writeTo(out);
protected void writeNodesTo(StreamOutput out, List<ClearRolesCacheResponse.Node> nodes) throws IOException {
out.writeStreamableList(nodes);
}

2
elasticsearch/x-pack/shield/src/test/java/org/elasticsearch/shield/audit/index/IndexAuditTrailTests.java
View File

@ -146,7 +146,7 @@ public class IndexAuditTrailTests extends ShieldIntegTestCase {
remoteCluster.beforeTest(random(), 0.5);
NodesInfoResponse response = remoteCluster.client().admin().cluster().prepareNodesInfo().execute().actionGet();
TransportInfo info = response.getNodes()[0].getTransport();
TransportInfo info = response.getNodes().get(0).getTransport();
InetSocketTransportAddress inet = (InetSocketTransportAddress) info.address().publishAddress();
Settings.Builder builder = Settings.builder()