[jboss-cvs] JBoss Messaging SVN: r5508 - in trunk/src/main/org/jboss/messaging/core/client: impl and 1 other directory.

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2008-12-10 13:46:23 -0500 (Wed, 10 Dec 2008)
New Revision: 5508

Modified:
   trunk/src/main/org/jboss/messaging/core/client/ClientMessage.java
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
   trunk/src/main/org/jboss/messaging/core/client/impl/ClientMessageInternal.java
Log:
Moved some more methods to ClientMessageInternal


Modified: trunk/src/main/org/jboss/messaging/core/client/ClientMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/ClientMessage.java	2008-12-10 18:12:09 UTC (rev 5507)
+++ trunk/src/main/org/jboss/messaging/core/client/ClientMessage.java	2008-12-10 18:46:23 UTC (rev 5508)
@@ -18,11 +18,10 @@
  * License along with this software; if not, write to the Free
  * Software Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA
  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
- */ 
+ */
 
 package org.jboss.messaging.core.client;
 
-import org.jboss.messaging.core.client.impl.ClientConsumerInternal;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.message.Message;
 
@@ -36,14 +35,10 @@
 public interface ClientMessage extends Message
 {
    long getMessageID();
-   
+
    int getDeliveryCount();
    
    void setDeliveryCount(int deliveryCount);
-   
-   void onReceipt(ClientConsumerInternal consumer);
-   
+
    void acknowledge() throws MessagingException;
-   
-   boolean isLargeMessage();
 }

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java	2008-12-10 18:12:09 UTC (rev 5507)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java	2008-12-10 18:46:23 UTC (rev 5508)
@@ -622,7 +622,7 @@
       session.acknowledge(id, message.getMessageID());
    }
 
-   private ClientFileMessage cloneAsFileMessage(final ClientMessage message) throws Exception
+   private ClientFileMessage cloneAsFileMessage(final ClientMessageInternal message) throws Exception
    {
       if (message instanceof ClientFileMessageImpl)
       {

Modified: trunk/src/main/org/jboss/messaging/core/client/impl/ClientMessageInternal.java
===================================================================
--- trunk/src/main/org/jboss/messaging/core/client/impl/ClientMessageInternal.java	2008-12-10 18:12:09 UTC (rev 5507)
+++ trunk/src/main/org/jboss/messaging/core/client/impl/ClientMessageInternal.java	2008-12-10 18:46:23 UTC (rev 5508)
@@ -20,7 +20,6 @@
  * 02110-1301 USA, or see the FSF site: http://www.fsf.org.
  */
 
-
 package org.jboss.messaging.core.client.impl;
 
 import org.jboss.messaging.core.client.ClientMessage;
@@ -35,10 +34,14 @@
  *
  */
 public interface ClientMessageInternal extends ClientMessage
-{   
+{
    /** Size used for FlowControl */
    int getFlowControlSize();
-   
+
    /** Size used for FlowControl */
    void setFlowControlSize(int flowControlSize);
+
+   void onReceipt(ClientConsumerInternal consumer);
+
+   boolean isLargeMessage();
 }