public void setNodeAttributes(int localNodePort, int remoteNodePort, Map<String, Object> attributeMap)
throws Exception
{
RestTestHelper restHelper = createRestTestHelper(localNodePort);
String url = getNodeRestUrl(localNodePort, remoteNodePort);
int status = restHelper.submitRequest(url, "PUT", attributeMap);
if (status != 200)
{
throw new Exception("Unexpected http status when updating " + getNodeNameForBrokerPort(remoteNodePort) + " attribute(s) : " + status);
}
}