diff options
| author | Robert Godfrey <rgodfrey@apache.org> | 2014-04-29 10:50:27 +0000 |
|---|---|---|
| committer | Robert Godfrey <rgodfrey@apache.org> | 2014-04-29 10:50:27 +0000 |
| commit | adcecf75d67969485f4e61e76b89caf239d63a39 (patch) | |
| tree | 4bf3c59fd22c72b4ee793da10ead88c3260e00e7 /qpid/java/bdbstore/src | |
| parent | 7f4570b9a410081c12920da2ee483d42e3169f9e (diff) | |
| download | qpid-python-adcecf75d67969485f4e61e76b89caf239d63a39.tar.gz | |
QPID-5730 : [Java Broker] allow configured object attributes to be maked as not to be persisted
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1590945 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/bdbstore/src')
2 files changed, 5 insertions, 43 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNode.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNode.java index 0e92ac83de..c135803717 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNode.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNode.java @@ -63,7 +63,7 @@ public interface BDBHAVirtualHostNode<X extends BDBHAVirtualHostNode<X>> extends @ManagedAttribute(automate = true, defaultValue = "0") int getQuorumOverride(); - @ManagedAttribute(automate = true) + @ManagedAttribute(automate = true, persist = false) String getRole(); @ManagedAttribute(automate = true) diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java index 8b2dce4168..9b72440280 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhostnode/berkeleydb/BDBHAVirtualHostNodeImpl.java @@ -23,7 +23,6 @@ package org.apache.qpid.server.virtualhostnode.berkeleydb; import java.security.PrivilegedAction; import java.util.HashMap; import java.util.Map; -import java.util.UUID; import java.util.concurrent.ExecutionException; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; @@ -31,7 +30,11 @@ import java.util.concurrent.atomic.AtomicReference; import javax.security.auth.Subject; +import com.sleepycat.je.rep.ReplicatedEnvironment; +import com.sleepycat.je.rep.StateChangeEvent; +import com.sleepycat.je.rep.StateChangeListener; import org.apache.log4j.Logger; + import org.apache.qpid.server.configuration.IllegalConfigurationException; import org.apache.qpid.server.logging.messages.ConfigStoreMessages; import org.apache.qpid.server.model.Broker; @@ -45,7 +48,6 @@ import org.apache.qpid.server.model.VirtualHost; import org.apache.qpid.server.model.VirtualHostNode; import org.apache.qpid.server.plugin.ConfiguredObjectTypeFactory; import org.apache.qpid.server.security.SecurityManager; -import org.apache.qpid.server.store.ConfiguredObjectRecord; import org.apache.qpid.server.store.DurableConfigurationStore; import org.apache.qpid.server.store.VirtualHostStoreUpgraderAndRecoverer; import org.apache.qpid.server.store.berkeleydb.BDBHAVirtualHost; @@ -56,10 +58,6 @@ import org.apache.qpid.server.util.ServerScopedRuntimeException; import org.apache.qpid.server.virtualhost.VirtualHostState; import org.apache.qpid.server.virtualhostnode.AbstractVirtualHostNode; -import com.sleepycat.je.rep.ReplicatedEnvironment; -import com.sleepycat.je.rep.StateChangeEvent; -import com.sleepycat.je.rep.StateChangeListener; - @ManagedObject( category = false, type = "BDB_HA" ) public class BDBHAVirtualHostNodeImpl extends AbstractVirtualHostNode<BDBHAVirtualHostNodeImpl> implements BDBHAVirtualHostNode<BDBHAVirtualHostNodeImpl> { @@ -563,42 +561,6 @@ public class BDBHAVirtualHostNodeImpl extends AbstractVirtualHostNode<BDBHAVirtu } } - // TODO - need a better way of suppressing the persistence of the role field. - @Override - public ConfiguredObjectRecord asObjectRecord() - { - final ConfiguredObjectRecord underlying = super.asObjectRecord(); - return new ConfiguredObjectRecord() - { - - @Override - public String getType() - { - return underlying.getType(); - } - - @Override - public Map<String, ConfiguredObjectRecord> getParents() - { - return underlying.getParents(); - } - - @Override - public UUID getId() - { - return underlying.getId(); - } - - @Override - public Map<String, Object> getAttributes() - { - Map<String, Object> copy = new HashMap<String, Object>(underlying.getAttributes()); - copy.remove(BDBHAVirtualHostNode.ROLE); - return copy; - } - }; - } - private class ReplicaVirtualHost extends BDBHAVirtualHost { ReplicaVirtualHost(Map<String, Object> attributes, VirtualHostNode<?> virtualHostNode) |
