activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tab...@apache.org
Subject svn commit: r1434849 - in /activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region: BaseDestination.java Destination.java DestinationFilter.java
Date Thu, 17 Jan 2013 18:27:52 GMT
Author: tabish
Date: Thu Jan 17 18:27:51 2013
New Revision: 1434849

URL: http://svn.apache.org/viewvc?rev=1434849&view=rev
Log:
apply patch for: https://issues.apache.org/jira/browse/AMQ-4121

Allows for more user customization of MemoryUsage if desired.  

Modified:
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Destination.java
    activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java?rev=1434849&r1=1434848&r2=1434849&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/BaseDestination.java
Thu Jan 17 18:27:51 2013
@@ -248,6 +248,10 @@ public abstract class BaseDestination im
         return memoryUsage;
     }
 
+	public void setMemoryUsage(MemoryUsage memoryUsage) {
+    	this.memoryUsage = memoryUsage;
+    }
+
     public DestinationStatistics getDestinationStatistics() {
         return destinationStatistics;
     }

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Destination.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Destination.java?rev=1434849&r1=1434848&r2=1434849&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Destination.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/Destination.java
Thu Jan 17 18:27:51 2013
@@ -66,6 +66,8 @@ public interface Destination extends Ser
 
     MemoryUsage getMemoryUsage();
 
+    void setMemoryUsage(MemoryUsage memoryUsage);
+
     void dispose(ConnectionContext context) throws IOException;
 
     boolean isDisposed();

Modified: activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java?rev=1434849&r1=1434848&r2=1434849&view=diff
==============================================================================
--- activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
(original)
+++ activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region/DestinationFilter.java
Thu Jan 17 18:27:51 2013
@@ -101,6 +101,11 @@ public class DestinationFilter implement
         return next.getMemoryUsage();
     }
 
+	@Override
+	public void setMemoryUsage(MemoryUsage memoryUsage) {
+		next.setMemoryUsage(memoryUsage);
+	}
+
     public void removeSubscription(ConnectionContext context, Subscription sub, long lastDeliveredSequenceId)
throws Exception {
         next.removeSubscription(context, sub, lastDeliveredSequenceId);
     }



Mime
View raw message