diff options
| author | Keith Wall <kwall@apache.org> | 2014-05-26 11:36:58 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2014-05-26 11:36:58 +0000 |
| commit | d089b63a71a18b9e3bc827d6d4582e89865638e5 (patch) | |
| tree | a47e0685405aca51d2898bf3a5f48969a0466973 /qpid/java/bdbstore | |
| parent | ccb006f25655d8daaad020e3a6270ea77bdb6ed1 (diff) | |
| download | qpid-python-d089b63a71a18b9e3bc827d6d4582e89865638e5.tar.gz | |
QPID-5715: [Java Broker] Address review comments from Alex Rudyy
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1597564 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/bdbstore')
| -rw-r--r-- | qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java | 8 |
1 files changed, 7 insertions, 1 deletions
diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java index 1f26a8cae7..ab81755f53 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java @@ -125,7 +125,7 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli public void removeExchange(final ExchangeImpl<?> exchange, final boolean force) throws ExchangeIsAlternateException, RequiredExchangeException { - + throwUnsupportedForReplica(); } @Override @@ -312,6 +312,7 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli @Override public int removeQueue(final AMQQueue<?> queue) { + throwUnsupportedForReplica(); return 0; } @@ -400,17 +401,20 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli @Override public ScheduledFuture<?> scheduleTask(final long delay, final Runnable timeoutTask) { + throwUnsupportedForReplica(); return null; } @Override public void block() { + throwUnsupportedForReplica(); } @Override public void unblock() { + throwUnsupportedForReplica(); } @Override @@ -428,11 +432,13 @@ public class BDBHAReplicaVirtualHost extends AbstractConfiguredObject<BDBHARepli @Override public void registerMessageReceived(final long messageSize, final long timestamp) { + throwUnsupportedForReplica(); } @Override public void registerMessageDelivered(final long messageSize) { + throwUnsupportedForReplica(); } @Override |