You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2013/01/17 19:27:52 UTC
svn commit: r1434849 - in
/activemq/trunk/activemq-broker/src/main/java/org/apache/activemq/broker/region:
BaseDestination.java Destination.java DestinationFilter.java
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);
}