svn commit: r1597564 - /qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java

[kwall]

Author: kwall
Date: Mon May 26 11:36:58 2014
New Revision: 1597564

URL: http://svn.apache.org/r1597564
Log:
QPID-5715: [Java Broker] Address review comments from Alex Rudyy

Modified:
    
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java

Modified: 
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
URL: 
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java?rev=1597564&r1=1597563&r2=1597564&view=diff
==============================================================================
--- 
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
 (original)
+++ 
qpid/trunk/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/virtualhost/berkeleydb/BDBHAReplicaVirtualHost.java
 Mon May 26 11:36:58 2014
@@ -125,7 +125,7 @@ public class BDBHAReplicaVirtualHost ext
     public void removeExchange(final ExchangeImpl<?> exchange, final boolean 
force)
             throws ExchangeIsAlternateException, RequiredExchangeException
     {
-
+        throwUnsupportedForReplica();
     }
 
     @Override
@@ -312,6 +312,7 @@ public class BDBHAReplicaVirtualHost ext
     @Override
     public int removeQueue(final AMQQueue<?> queue)
     {
+        throwUnsupportedForReplica();
         return 0;
     }
 
@@ -400,17 +401,20 @@ public class BDBHAReplicaVirtualHost ext
     @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 ext
     @Override
     public void registerMessageReceived(final long messageSize, final long 
timestamp)
     {
+        throwUnsupportedForReplica();
     }
 
     @Override
     public void registerMessageDelivered(final long messageSize)
     {
+        throwUnsupportedForReplica();
     }
 
     @Override



---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@qpid.apache.org
For additional commands, e-mail: commits-h...@qpid.apache.org