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]
