[jboss-cvs] JBoss Messaging SVN: r4526 - trunk/src/main/org/jboss/messaging/jms/client.

jboss-cvs-commits at lists.jboss.org jboss-cvs-commits at lists.jboss.org
Thu Jun 19 11:32:54 EDT 2008


Author: jmesnil
Date: 2008-06-19 11:32:54 -0400 (Thu, 19 Jun 2008)
New Revision: 4526

Modified:
   trunk/src/main/org/jboss/messaging/jms/client/JBossMessage.java
   trunk/src/main/org/jboss/messaging/jms/client/JBossMessageConsumer.java
   trunk/src/main/org/jboss/messaging/jms/client/JBossMessageProducer.java
   trunk/src/main/org/jboss/messaging/jms/client/JBossQueueBrowser.java
   trunk/src/main/org/jboss/messaging/jms/client/JBossSession.java
Log:
renamed methods getDelegate() in JBossXXX classes which return ClientXXX object
removed unused methods

Modified: trunk/src/main/org/jboss/messaging/jms/client/JBossMessage.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/client/JBossMessage.java	2008-06-19 15:32:20 UTC (rev 4525)
+++ trunk/src/main/org/jboss/messaging/jms/client/JBossMessage.java	2008-06-19 15:32:54 UTC (rev 4526)
@@ -862,7 +862,7 @@
     
    // Public --------------------------------------------------------
    
-   public ClientMessage getCoreMessage()
+   public ClientMessage getDelegate()
    {
       return message;
    }

Modified: trunk/src/main/org/jboss/messaging/jms/client/JBossMessageConsumer.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/client/JBossMessageConsumer.java	2008-06-19 15:32:20 UTC (rev 4525)
+++ trunk/src/main/org/jboss/messaging/jms/client/JBossMessageConsumer.java	2008-06-19 15:32:54 UTC (rev 4526)
@@ -168,11 +168,6 @@
       return noLocal;
    }
 
-   public ClientConsumer getConsumer()
-   {
-       return consumer;
-   }
-
    // Public --------------------------------------------------------
 
    public String toString()
@@ -188,7 +183,7 @@
    
    private void checkClosed() throws JMSException
    {
-      if (session.getCoreSession().isClosed())
+      if (session.getDelegate().isClosed())
       {
          throw new IllegalStateException("Consumer is closed");
       }
@@ -204,9 +199,9 @@
          
          if (message != null)
          {         
-            session.getCoreSession().acknowledge();
+            session.getDelegate().acknowledge();
                      
-            jbm = JBossMessage.createMessage(message, session.getCoreSession());
+            jbm = JBossMessage.createMessage(message, session.getDelegate());
             
             try
             {

Modified: trunk/src/main/org/jboss/messaging/jms/client/JBossMessageProducer.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/client/JBossMessageProducer.java	2008-06-19 15:32:20 UTC (rev 4525)
+++ trunk/src/main/org/jboss/messaging/jms/client/JBossMessageProducer.java	2008-06-19 15:32:54 UTC (rev 4526)
@@ -306,11 +306,6 @@
    
    // Public --------------------------------------------------------
 
-   public ClientProducer getDelegate()
-   {
-      return producer;
-   }
-
    public String toString()
    {
       return "JBossMessageProducer->" + producer;
@@ -444,7 +439,7 @@
 
       try
       {      	
-      	producer.send(address, jbm.getCoreMessage());      		      	
+      	producer.send(address, jbm.getDelegate());      		      	
       }
       catch (MessagingException e)
       {

Modified: trunk/src/main/org/jboss/messaging/jms/client/JBossQueueBrowser.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/client/JBossQueueBrowser.java	2008-06-19 15:32:20 UTC (rev 4525)
+++ trunk/src/main/org/jboss/messaging/jms/client/JBossQueueBrowser.java	2008-06-19 15:32:54 UTC (rev 4526)
@@ -105,11 +105,6 @@
       return "JBossQueueBrowser->" + browser;
    }
 
-   public ClientBrowser getBrowser()
-   {
-      return browser;
-   }
-
    // Package protected ----------------------------------------------------------------------------
 
    // Protected ------------------------------------------------------------------------------------

Modified: trunk/src/main/org/jboss/messaging/jms/client/JBossSession.java
===================================================================
--- trunk/src/main/org/jboss/messaging/jms/client/JBossSession.java	2008-06-19 15:32:20 UTC (rev 4525)
+++ trunk/src/main/org/jboss/messaging/jms/client/JBossSession.java	2008-06-19 15:32:54 UTC (rev 4526)
@@ -791,7 +791,7 @@
       return "JBossSession->" + session;
    }
    
-   public ClientSession getCoreSession()
+   public ClientSession getDelegate()
    {
       return session;
    }   




More information about the jboss-cvs-commits mailing list