cvs commit: jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp ReplicationTransmitter.java

[pero]

pero        2005/04/16 00:22:41

  Modified:    modules/cluster/src/share/org/apache/catalina/cluster/tcp
                        ReplicationTransmitter.java
  Log:
  Change method names
  
  Revision  Changes    Path
  1.31      +6 -6      
jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java
  
  Index: ReplicationTransmitter.java
  ===================================================================
  RCS file: 
/home/cvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ReplicationTransmitter.java,v
  retrieving revision 1.30
  retrieving revision 1.31
  diff -u -r1.30 -r1.31
  --- ReplicationTransmitter.java       15 Apr 2005 20:14:14 -0000      1.30
  +++ ReplicationTransmitter.java       16 Apr 2005 07:22:41 -0000      1.31
  @@ -425,7 +425,7 @@
               time = System.currentTimeMillis();
           }
           try {
  -            byte[] data = createMessageData(message);
  +            byte[] data = serialze(message);
               String key = getKey(member);
               IDataSender sender = (IDataSender) map.get(key);
               sendMessageData(message.getUniqueId(), data, sender);
  @@ -447,7 +447,7 @@
               time = System.currentTimeMillis();
           }
           try {
  -            byte[] data = createMessageData(message);
  +            byte[] data = serialze(message);
               IDataSender[] senders = getSenders();
               for (int i = 0; i < senders.length; i++) {
   
  @@ -751,13 +751,13 @@
       }
   
       /**
  -     * Send Message create Timestamp and generate message bytes form msg
  -     * @see XByteBuffer#createDataPackage(byte[])
  +     * serialze message and add timestamp
  +     * @see GZIPOutputStream
        * @param msg cluster message
        * @return cluster message as byte array
        * @throws IOException
        */
  -    protected byte[] createMessageData(ClusterMessage msg) throws 
IOException {
  +    protected byte[] serialze(ClusterMessage msg) throws IOException {
           msg.setTimestamp(System.currentTimeMillis());
           ByteArrayOutputStream outs = new ByteArrayOutputStream();
           ObjectOutputStream out;
  
  
  

---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]