[JBoss-dev] CVS update: jbossmq/src/main/org/jboss/mq/cluster/jms ClusterTopicSession.java

[Hiram Chirino]

  User: chirino 
  Date: 01/10/27 21:07:34

  Modified:    src/main/org/jboss/mq/cluster/jms ClusterTopicSession.java
  Log:
  Reorganized the JMS message headers into a Header object so that the MessageCahe can
  drop the message body from memory, but keep the headers.
  Also fixed a bug witht he Browse() that was introduced with the message cache.
  
  Revision  Changes    Path
  1.4       +9 -9      
jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSession.java
  
  Index: ClusterTopicSession.java
  ===================================================================
  RCS file: 
/cvsroot/jboss/jbossmq/src/main/org/jboss/mq/cluster/jms/ClusterTopicSession.java,v
  retrieving revision 1.3
  retrieving revision 1.4
  diff -u -r1.3 -r1.4
  --- ClusterTopicSession.java  2001/08/21 23:16:18     1.3
  +++ ClusterTopicSession.java  2001/10/28 04:07:34     1.4
  @@ -42,7 +42,7 @@
    *
    * @author     Hiram Chirino ([EMAIL PROTECTED])
    * @created    August 16, 2001
  - * @version    $Revision: 1.3 $
  + * @version    $Revision: 1.4 $
    */
   public class ClusterTopicSession
      implements TopicSession
  @@ -193,7 +193,7 @@
         }
   
         SpyBytesMessage message = new SpyBytesMessage();
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -204,7 +204,7 @@
         }
   
         SpyMapMessage message = new SpyMapMessage();
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -215,7 +215,7 @@
         }
   
         SpyMessage message = new SpyMessage();
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -226,7 +226,7 @@
         }
   
         SpyObjectMessage message = new SpyObjectMessage();
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -238,7 +238,7 @@
   
         SpyObjectMessage message = new SpyObjectMessage();
         message.setObject( object );
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -249,7 +249,7 @@
         }
   
         SpyStreamMessage message = new SpyStreamMessage();
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -260,7 +260,7 @@
         }
   
         SpyTextMessage message = new SpyTextMessage();
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  @@ -272,7 +272,7 @@
   
         SpyTextMessage message = new SpyTextMessage();
         message.setText( string );
  -      message.producerClientId = connection.getClientID();
  +      message.header.producerClientId = connection.getClientID();
         return message;
      }
   
  
  
  

_______________________________________________
Jboss-development mailing list
[EMAIL PROTECTED]
https://lists.sourceforge.net/lists/listinfo/jboss-development