You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by or...@apache.org on 2018/05/02 23:23:09 UTC
[1/3] qpid-broker-j git commit: QPID-8165: [Broker-J][WMC] Fix RegEx
to allow more characters in configured object names
Repository: qpid-broker-j
Updated Branches:
refs/heads/master 39bfa6a0c -> d2589bf40
QPID-8165: [Broker-J][WMC] Fix RegEx to allow more characters in configured object names
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/c8fae154
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/c8fae154
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/c8fae154
Branch: refs/heads/master
Commit: c8fae15492a09155039a61d11bf7d2dbdc280c65
Parents: 39bfa6a
Author: Alex Rudyy <or...@apache.org>
Authored: Wed May 2 16:40:51 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Thu May 3 00:19:28 2018 +0100
----------------------------------------------------------------------
.../virtualhostnode/bdb_ha/add/existinggroup/add.js | 2 +-
.../management/virtualhostnode/bdb_ha/add/newgroup/add.js | 2 +-
.../src/main/java/resources/js/qpid/common/util.js | 9 +++++++--
.../js/qpid/management/addVirtualHostNodeAndVirtualHost.js | 2 +-
.../qpid/management/virtualhostalias/hostnamealias/add.js | 2 +-
.../management/virtualhostalias/patternmatchingalias/add.js | 2 +-
6 files changed, 12 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c8fae154/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/existinggroup/add.js
----------------------------------------------------------------------
diff --git a/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/existinggroup/add.js b/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/existinggroup/add.js
index 529311a..767e417 100644
--- a/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/existinggroup/add.js
+++ b/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/existinggroup/add.js
@@ -36,7 +36,7 @@ define(["dojo/_base/xhr",
.then(function (instances)
{
registry.byId("addVirtualHostNode.groupName")
- .set("regExpGen", util.nameOrContextVarRegexp);
+ .set("regExpGen", util.virtualHostNameOrContextVarRegexp);
registry.byId("addVirtualHostNode.helperNodeName")
.set("regExpGen", util.nameOrContextVarRegexp);
registry.byId("addVirtualHostNode.helperAddress")
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c8fae154/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/newgroup/add.js
----------------------------------------------------------------------
diff --git a/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/newgroup/add.js b/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/newgroup/add.js
index cf74d75..60edc5f 100644
--- a/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/newgroup/add.js
+++ b/bdbstore/src/main/java/resources/js/qpid/management/virtualhostnode/bdb_ha/add/newgroup/add.js
@@ -96,7 +96,7 @@ define(["dojo/_base/xhr",
this.addVirtualHostNodePermittedNodes = registry.byId("addVirtualHostNode.permittedNodes");
registry.byId("addVirtualHostNode.groupName")
- .set("regExpGen", util.nameOrContextVarRegexp);
+ .set("regExpGen", util.virtualHostNameOrContextVarRegexp);
dom.byId("addVirtualHostNode.uploadFields").style.display = "block";
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c8fae154/broker-plugins/management-http/src/main/java/resources/js/qpid/common/util.js
----------------------------------------------------------------------
diff --git a/broker-plugins/management-http/src/main/java/resources/js/qpid/common/util.js b/broker-plugins/management-http/src/main/java/resources/js/qpid/common/util.js
index 91272b7..a214e35 100644
--- a/broker-plugins/management-http/src/main/java/resources/js/qpid/common/util.js
+++ b/broker-plugins/management-http/src/main/java/resources/js/qpid/common/util.js
@@ -812,13 +812,18 @@ define(["dojo/_base/xhr",
util.nameOrContextVarRegexp = function (constraints)
{
- return "^(\\w+)|" + singleContextVarRegexp + "$";
+ return "^([0-9a-zA-Z\\-_.:]+)|" + singleContextVarRegexp + "$";
+ };
+
+ util.virtualHostNameOrContextVarRegexp = function (constraints)
+ {
+ return "^([0-9a-zA-Z\\-_]+)|" + singleContextVarRegexp + "$";
};
util.jdbcUrlOrContextVarRegexp = function (constraints)
{
return "^(jdbc:.*:.*)|" + singleContextVarRegexp + "$";
- }
+ };
util.nodeAddressOrContextVarRegexp = function (constraints)
{
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c8fae154/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHostNodeAndVirtualHost.js
----------------------------------------------------------------------
diff --git a/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHostNodeAndVirtualHost.js b/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHostNodeAndVirtualHost.js
index f8b378e..811a1dc 100644
--- a/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHostNodeAndVirtualHost.js
+++ b/broker-plugins/management-http/src/main/java/resources/js/qpid/management/addVirtualHostNodeAndVirtualHost.js
@@ -81,7 +81,7 @@ define(["dojo/_base/event",
{
var that = this;
var virtualHostNodeName = registry.byId("addVirtualHostNode.nodeName");
- virtualHostNodeName.set("regExpGen", util.nameOrContextVarRegexp);
+ virtualHostNodeName.set("regExpGen", util.virtualHostNameOrContextVarRegexp);
// Readers are HTML5
this.reader = window.FileReader ? new FileReader() : undefined;
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c8fae154/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/hostnamealias/add.js
----------------------------------------------------------------------
diff --git a/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/hostnamealias/add.js b/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/hostnamealias/add.js
index 982ebd7..258e959 100644
--- a/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/hostnamealias/add.js
+++ b/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/hostnamealias/add.js
@@ -38,7 +38,7 @@ define(["dojo/dom",
.then(function (instances)
{
var virtualHostNodeNameWidget = registry.byId("addVirtualHostAlias.virtualHostNodeName");
- virtualHostNodeNameWidget.set("regExpGen", util.nameOrContextVarRegexp);
+ virtualHostNodeNameWidget.set("regExpGen", util.virtualHostNameOrContextVarRegexp);
});
}
};
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/c8fae154/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/patternmatchingalias/add.js
----------------------------------------------------------------------
diff --git a/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/patternmatchingalias/add.js b/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/patternmatchingalias/add.js
index c31a050..62d20d1 100644
--- a/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/patternmatchingalias/add.js
+++ b/broker-plugins/management-http/src/main/java/resources/js/qpid/management/virtualhostalias/patternmatchingalias/add.js
@@ -38,7 +38,7 @@ define(["dojo/dom",
.then(function (instances)
{
var virtualHostNodeNameWidget = registry.byId("addVirtualHostAlias.virtualHostNodeName");
- virtualHostNodeNameWidget.set("regExpGen", util.nameOrContextVarRegexp);
+ virtualHostNodeNameWidget.set("regExpGen", util.virtualHostNameOrContextVarRegexp);
});
}
};
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org
[3/3] qpid-broker-j git commit: QPID-8172: [Broker-J] Fix failing test
Posted by or...@apache.org.
QPID-8172: [Broker-J] Fix failing test
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/d2589bf4
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/d2589bf4
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/d2589bf4
Branch: refs/heads/master
Commit: d2589bf40a1bf352ddced315a4fd93c3560c0396
Parents: b14319e
Author: Alex Rudyy <or...@apache.org>
Authored: Thu May 3 00:17:46 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Thu May 3 00:22:00 2018 +0100
----------------------------------------------------------------------
.../auth/manager/oauth2/OAuth2AuthenticationProviderImplTest.java | 1 -
1 file changed, 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/d2589bf4/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/oauth2/OAuth2AuthenticationProviderImplTest.java
----------------------------------------------------------------------
diff --git a/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/oauth2/OAuth2AuthenticationProviderImplTest.java b/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/oauth2/OAuth2AuthenticationProviderImplTest.java
index 1de8242..02d3dbb 100644
--- a/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/oauth2/OAuth2AuthenticationProviderImplTest.java
+++ b/broker-core/src/test/java/org/apache/qpid/server/security/auth/manager/oauth2/OAuth2AuthenticationProviderImplTest.java
@@ -280,7 +280,6 @@ public class OAuth2AuthenticationProviderImplTest extends UnitTestBase
tokenEndpoint.putExpectedParameter("code", TEST_VALID_AUTHORIZATION_CODE);
tokenEndpoint.putExpectedParameter("redirect_uri", TEST_REDIRECT_URI);
tokenEndpoint.putExpectedParameter("client_id", TEST_CLIENT_ID);
- tokenEndpoint.putExpectedParameter("client_secret", TEST_CLIENT_SECRET);
tokenEndpoint.setExpectedMethod("POST");
tokenEndpoint.setNeedsAuth(true);
tokenEndpoint.setResponse(200, String.format("{\"access_token\":\"%s\","
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org
[2/3] qpid-broker-j git commit: QPID-8167: [Broker-J] Fix quiescing
virtualhosts in management mode
Posted by or...@apache.org.
QPID-8167: [Broker-J] Fix quiescing virtualhosts in management mode
Project: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/commit/b14319e3
Tree: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/tree/b14319e3
Diff: http://git-wip-us.apache.org/repos/asf/qpid-broker-j/diff/b14319e3
Branch: refs/heads/master
Commit: b14319e30a0a09f8ce12a8d4e98e19a686c0c1ed
Parents: c8fae15
Author: Alex Rudyy <or...@apache.org>
Authored: Wed May 2 19:07:28 2018 +0100
Committer: Alex Rudyy <or...@apache.org>
Committed: Thu May 3 00:22:00 2018 +0100
----------------------------------------------------------------------
.../store/ManagementModeStoreHandler.java | 21 +++++++++---------
.../AbstractVirtualHostNode.java | 7 ++++++
.../store/ManagementModeStoreHandlerTest.java | 23 ++++++++++----------
3 files changed, 30 insertions(+), 21 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/b14319e3/broker-core/src/main/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandler.java
----------------------------------------------------------------------
diff --git a/broker-core/src/main/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandler.java b/broker-core/src/main/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandler.java
index b3e962d..0d0cf85 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandler.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandler.java
@@ -34,6 +34,7 @@ import org.slf4j.LoggerFactory;
import org.apache.qpid.server.configuration.IllegalConfigurationException;
import org.apache.qpid.server.model.Broker;
+import org.apache.qpid.server.model.BrokerImpl;
import org.apache.qpid.server.model.ConfiguredObject;
import org.apache.qpid.server.model.ConfiguredObjectAttribute;
import org.apache.qpid.server.model.ConfiguredObjectTypeRegistry;
@@ -44,7 +45,7 @@ import org.apache.qpid.server.model.Protocol;
import org.apache.qpid.server.model.State;
import org.apache.qpid.server.model.SystemConfig;
import org.apache.qpid.server.model.VirtualHost;
-import org.apache.qpid.server.model.BrokerImpl;
+import org.apache.qpid.server.model.VirtualHostNode;
import org.apache.qpid.server.store.ConfiguredObjectRecord;
import org.apache.qpid.server.store.ConfiguredObjectRecordImpl;
import org.apache.qpid.server.store.DurableConfigurationStore;
@@ -57,8 +58,8 @@ public class ManagementModeStoreHandler implements DurableConfigurationStore
private static final String MANAGEMENT_MODE_PORT_PREFIX = "MANAGEMENT-MODE-PORT-";
private static final String PORT_TYPE = Port.class.getSimpleName();
- private static final String VIRTUAL_HOST_TYPE = VirtualHost.class.getSimpleName();
- private static final String ATTRIBUTE_STATE = VirtualHost.STATE;
+ private static final String VIRTUAL_HOST_NODE_TYPE = VirtualHostNode.class.getSimpleName();
+ private static final String ATTRIBUTE_DESIRED_STATE = ConfiguredObject.DESIRED_STATE;
private static final Object MANAGEMENT_MODE_AUTH_PROVIDER = "mm-auth";
private enum StoreState { CLOSED, CONFIGURED, OPEN };
@@ -282,7 +283,7 @@ public class ManagementModeStoreHandler implements DurableConfigurationStore
String entryType = entry.getType();
Map<String, Object> attributes = entry.getAttributes();
boolean quiesce = false;
- if (VIRTUAL_HOST_TYPE.equals(entryType) && options.isManagementModeQuiesceVirtualHosts())
+ if (VIRTUAL_HOST_NODE_TYPE.equals(entryType) && options.isManagementModeQuiesceVirtualHosts())
{
quiesce = true;
}
@@ -317,7 +318,7 @@ public class ManagementModeStoreHandler implements DurableConfigurationStore
LOGGER.debug("Management mode quiescing entry {}", entry);
// save original state
- quiescedEntries.put(entry.getId(), attributes.get(ATTRIBUTE_STATE));
+ quiescedEntries.put(entry.getId(), attributes.get(ATTRIBUTE_DESIRED_STATE));
}
}
@@ -347,11 +348,11 @@ public class ManagementModeStoreHandler implements DurableConfigurationStore
Map<String, Object> attributes = new HashMap<String, Object>(entry.getAttributes());
if (state == null)
{
- attributes.remove(ATTRIBUTE_STATE);
+ attributes.remove(ATTRIBUTE_DESIRED_STATE);
}
else
{
- attributes.put(ATTRIBUTE_STATE, state);
+ attributes.put(ATTRIBUTE_DESIRED_STATE, state);
}
return new ConfiguredObjectRecordImpl(entry.getId(), entry.getType(), attributes, entry.getParents());
}
@@ -382,7 +383,7 @@ public class ManagementModeStoreHandler implements DurableConfigurationStore
String entryType = object.getType();
Map<String, Object> attributes = object.getAttributes();
boolean quiesce = false;
- if (VIRTUAL_HOST_TYPE.equals(entryType) && _systemConfig.isManagementModeQuiesceVirtualHosts())
+ if (VIRTUAL_HOST_NODE_TYPE.equals(entryType) && _systemConfig.isManagementModeQuiesceVirtualHosts())
{
quiesce = true;
}
@@ -417,9 +418,9 @@ public class ManagementModeStoreHandler implements DurableConfigurationStore
LOGGER.debug("Management mode quiescing entry {}", object);
// save original state
- _quiescedEntriesOriginalState.put(object.getId(), attributes.get(ATTRIBUTE_STATE));
+ _quiescedEntriesOriginalState.put(object.getId(), attributes.get(ATTRIBUTE_DESIRED_STATE));
Map<String, Object> modifiedAttributes = new HashMap<String, Object>(attributes);
- modifiedAttributes.put(ATTRIBUTE_STATE, State.QUIESCED);
+ modifiedAttributes.put(ATTRIBUTE_DESIRED_STATE, State.QUIESCED);
ConfiguredObjectRecord record = new ConfiguredObjectRecordImpl(object.getId(),
object.getType(),
modifiedAttributes,
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/b14319e3/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
----------------------------------------------------------------------
diff --git a/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java b/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
index fb58433..b17b998 100644
--- a/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
+++ b/broker-core/src/main/java/org/apache/qpid/server/virtualhostnode/AbstractVirtualHostNode.java
@@ -152,6 +152,13 @@ public abstract class AbstractVirtualHostNode<X extends AbstractVirtualHostNode<
super.onCreate();
}
+ @StateTransition(currentState = State.UNINITIALIZED, desiredState = State.QUIESCED)
+ protected ListenableFuture<Void> startQuiesced()
+ {
+ setState(State.QUIESCED);
+ return Futures.immediateFuture(null);
+ }
+
@StateTransition( currentState = {State.UNINITIALIZED, State.STOPPED, State.ERRORED }, desiredState = State.ACTIVE )
protected ListenableFuture<Void> doActivate()
{
http://git-wip-us.apache.org/repos/asf/qpid-broker-j/blob/b14319e3/broker-core/src/test/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandlerTest.java
----------------------------------------------------------------------
diff --git a/broker-core/src/test/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandlerTest.java b/broker-core/src/test/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandlerTest.java
index 33e04a4..cfe7aba 100644
--- a/broker-core/src/test/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandlerTest.java
+++ b/broker-core/src/test/java/org/apache/qpid/server/configuration/store/ManagementModeStoreHandlerTest.java
@@ -62,6 +62,7 @@ import org.apache.qpid.server.model.State;
import org.apache.qpid.server.model.StateTransition;
import org.apache.qpid.server.model.SystemConfig;
import org.apache.qpid.server.model.VirtualHost;
+import org.apache.qpid.server.model.VirtualHostNode;
import org.apache.qpid.server.store.ConfiguredObjectRecord;
import org.apache.qpid.server.store.ConfiguredObjectRecordImpl;
import org.apache.qpid.server.store.DurableConfigurationStore;
@@ -291,7 +292,7 @@ public class ManagementModeStoreHandlerTest extends UnitTestBase
ConfiguredObjectRecord portEntry = getEntry(records, _portEntryId);
assertEquals("Unexpected entry id", _portEntryId, portEntry.getId());
assertTrue("Unexpected children", getChildrenIds(records, portEntry).isEmpty());
- assertEquals("Unexpected state", State.QUIESCED, portEntry.getAttributes().get(Port.STATE));
+ assertEquals("Unexpected state", State.QUIESCED, portEntry.getAttributes().get(Port.DESIRED_STATE));
}
@Test
@@ -321,7 +322,7 @@ public class ManagementModeStoreHandlerTest extends UnitTestBase
Collection<ConfiguredObjectRecord> records = openAndGetRecords();
ConfiguredObjectRecord portEntry = getEntry(records, _portEntryId);
- assertEquals("Unexpected state", State.QUIESCED, portEntry.getAttributes().get(Port.STATE));
+ assertEquals("Unexpected state", State.QUIESCED, portEntry.getAttributes().get(Port.DESIRED_STATE));
}
@Test
@@ -338,11 +339,11 @@ public class ManagementModeStoreHandlerTest extends UnitTestBase
private void virtualHostEntryQuiescedStatusTestImpl(boolean mmQuiesceVhosts)
{
- UUID virtualHostId = UUID.randomUUID();
+ UUID virtualHostNodeId = UUID.randomUUID();
Map<String, Object> attributes = new HashMap<String, Object>();
- attributes.put(VirtualHost.TYPE, "STANDARD");
+ attributes.put(VirtualHostNode.TYPE, "JSON");
- final ConfiguredObjectRecord virtualHost = new ConfiguredObjectRecordImpl(virtualHostId, VirtualHost.class.getSimpleName(), attributes, Collections.singletonMap(Broker.class.getSimpleName(), _root.getId()));
+ final ConfiguredObjectRecord virtualHostNodeRecord = new ConfiguredObjectRecordImpl(virtualHostNodeId, VirtualHostNode.class.getSimpleName(), attributes, Collections.singletonMap(Broker.class.getSimpleName(), _root.getId()));
final ArgumentCaptor<ConfiguredObjectRecordHandler> recovererArgumentCaptor = ArgumentCaptor.forClass(ConfiguredObjectRecordHandler.class);
doAnswer(
new Answer()
@@ -353,7 +354,7 @@ public class ManagementModeStoreHandlerTest extends UnitTestBase
ConfiguredObjectRecordHandler recoverer = recovererArgumentCaptor.getValue();
recoverer.handle(_root);
recoverer.handle(_portEntry);
- recoverer.handle(virtualHost);
+ recoverer.handle(virtualHostNodeRecord);
return false;
}
}
@@ -369,11 +370,11 @@ public class ManagementModeStoreHandlerTest extends UnitTestBase
_handler.init(_systemConfig);
Collection<ConfiguredObjectRecord> records = openAndGetRecords();
- ConfiguredObjectRecord hostEntry = getEntry(records, virtualHostId);
- Map<String, Object> hostAttributes = new HashMap<String, Object>(hostEntry.getAttributes());
- assertEquals("Unexpected state", expectedState, hostAttributes.get(VirtualHost.STATE));
- hostAttributes.remove(VirtualHost.STATE);
- assertEquals("Unexpected attributes", attributes, hostAttributes);
+ ConfiguredObjectRecord nodeEntry = getEntry(records, virtualHostNodeId);
+ Map<String, Object> nodeAttributes = new HashMap<String, Object>(nodeEntry.getAttributes());
+ assertEquals("Unexpected state", expectedState, nodeAttributes.get(VirtualHostNode.DESIRED_STATE));
+ nodeAttributes.remove(VirtualHostNode.DESIRED_STATE);
+ assertEquals("Unexpected attributes", attributes, nodeAttributes);
}
@SuppressWarnings("unchecked")
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org