svn commit: r732175 - /activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java

[djencks]

Author: djencks
Date: Tue Jan  6 15:39:27 2009
New Revision: 732175

URL: http://svn.apache.org/viewvc?rev=732175&view=rev
Log:
make use of 'this' more consistent and fix a couple warnings

Modified:
    
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java

Modified: 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
URL: 
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java?rev=732175&r1=732174&r2=732175&view=diff
==============================================================================
--- 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
 (original)
+++ 
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/cursors/AbstractPendingMessageCursor.java
 Tue Jan  6 15:39:27 2009
@@ -153,7 +153,7 @@
      * @return the memoryUsageHighWaterMark
      */
     public int getMemoryUsageHighWaterMark() {
-        return this.memoryUsageHighWaterMark;
+        return memoryUsageHighWaterMark;
     }
 
     /**
@@ -182,10 +182,10 @@
     /**
      * Page in a restricted number of messages
      * 
-     * @param maxItems
+     * @param maxItems maximum number of messages to return
      * @return a list of paged in messages
      */
-    public LinkedList pageInList(int maxItems) {
+    public LinkedList<MessageReference> pageInList(int maxItems) {
         throw new RuntimeException("Not supported");
     }
 
@@ -202,7 +202,7 @@
     public synchronized void setMaxProducersToAudit(int maxProducersToAudit) {
         this.maxProducersToAudit = maxProducersToAudit;
         if (audit != null) {
-            this.audit.setMaximumNumberOfProducersToTrack(maxProducersToAudit);
+            audit.setMaximumNumberOfProducersToTrack(maxProducersToAudit);
         }
     }
 
@@ -210,7 +210,7 @@
      * @return the maxAuditDepth
      */
     public int getMaxAuditDepth() {
-        return this.maxAuditDepth;
+        return maxAuditDepth;
     }
     
 
@@ -220,7 +220,7 @@
     public synchronized void setMaxAuditDepth(int maxAuditDepth) {
         this.maxAuditDepth = maxAuditDepth;
         if (audit != null) {
-            this.audit.setAuditDepth(maxAuditDepth);
+            audit.setAuditDepth(maxAuditDepth);
         }
     }
     
@@ -229,7 +229,7 @@
      * @return the enableAudit
      */
     public boolean isEnableAudit() {
-        return this.enableAudit;
+        return enableAudit;
     }
 
     /**
@@ -237,7 +237,7 @@
      */
     public synchronized void setEnableAudit(boolean enableAudit) {
         this.enableAudit = enableAudit;
-        if (this.enableAudit && started && audit==null) {
+        if (enableAudit && started && audit==null) {
             audit= new ActiveMQMessageAudit(maxAuditDepth,maxProducersToAudit);
         }
     }
@@ -249,7 +249,7 @@
        
     /**
      * set the audit
-     * @param audit
+     * @param audit new audit component
      */
     public void setMessageAudit(ActiveMQMessageAudit audit) {
        this.audit=audit;
@@ -272,14 +272,14 @@
     }
 
     protected synchronized boolean  isDuplicate(MessageId messageId) {
-        if (!this.enableAudit || this.audit==null) {
+        if (!enableAudit || audit==null) {
             return false;
         }
-        return this.audit.isDuplicate(messageId);
+        return audit.isDuplicate(messageId);
     }
     
     public synchronized void rollback(MessageId id) {
-        if (this.audit != null) {
+        if (audit != null) {
             audit.rollback(id);
         }
     }