cvs commit: jakarta-tomcat-connectors/util/java/org/apache/tomcat/util IntrospectionUtils.java
pero2005/06/26 14:19:28
Modified:util/java/org/apache/tomcat/util IntrospectionUtils.java
Log:
add boolean isporperty support to getProperty
Revision ChangesPath
1.15 +4 -0
jakarta-tomcat-connectors/util/java/org/apache/tomcat/util/IntrospectionUtils.java
Index: IntrospectionUtils.java
===
RCS file:
/home/cvs/jakarta-tomcat-connectors/util/java/org/apache/tomcat/util/IntrospectionUtils.java,v
retrieving revision 1.14
retrieving revision 1.15
diff -u -r1.14 -r1.15
--- IntrospectionUtils.java 16 Dec 2004 03:51:41 - 1.14
+++ IntrospectionUtils.java 26 Jun 2005 21:19:28 - 1.15
@@ -370,6 +370,7 @@
public static Object getProperty(Object o, String name) {
String getter = get + capitalize(name);
+String isGetter = is + capitalize(name);
try {
Method methods[] = findMethods(o.getClass());
@@ -381,6 +382,9 @@
if (getter.equals(methods[i].getName()) paramT.length ==
0) {
return methods[i].invoke(o, (Object[]) null);
}
+if (isGetter.equals(methods[i].getName()) paramT.length
== 0) {
+return methods[i].invoke(o, (Object[]) null);
+}
if (getProperty.equals(methods[i].getName())) {
getPropertyMethod = methods[i];
-
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
cvs commit: jakarta-tomcat-catalina/modules/cluster to-do.txt
pero2005/06/26 14:21:50 Modified:modules/cluster/src/share/org/apache/catalina/cluster ClusterMessage.java MembershipService.java modules/cluster/src/share/org/apache/catalina/cluster/deploy FileMessage.java UndeployMessage.java modules/cluster/src/share/org/apache/catalina/cluster/io ListenCallback.java ObjectReader.java SocketObjectReader.java XByteBuffer.java modules/cluster/src/share/org/apache/catalina/cluster/mcast McastService.java modules/cluster/src/share/org/apache/catalina/cluster/session DeltaManager.java DeltaSession.java JvmRouteBinderValve.java JvmRouteSessionIDBinderLifecycleListener.java LocalStrings.properties SessionIDMessage.java SessionMessageImpl.java SimpleTcpReplicationManager.java modules/cluster/src/share/org/apache/catalina/cluster/tcp AsyncSocketSender.java ClusterReceiverBase.java DataSender.java FastAsyncSocketSender.java IDataSender.java LocalStrings.properties PooledSocketSender.java ReplicationTransmitter.java SimpleTcpCluster.java SocketReplicationListener.java mbeans-descriptors.xml modules/cluster/test/src/share/org/apache/catalina/cluster/io XByteBufferTest.java modules/cluster/test/src/share/org/apache/catalina/cluster/tcp DataSenderTest.java ReplicationTransmitterTest.java modules/cluster to-do.txt Log: add standalone cluster config support better GET_ALLSESSION support config resend and compress from message creator Revision ChangesPath 1.2 +36 -0 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/ClusterMessage.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/ClusterMessage.java.diff?r1=1.1r2=1.2 1.7 +11 -1 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/MembershipService.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/MembershipService.java.diff?r1=1.6r2=1.7 1.3 +30 -1 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/deploy/FileMessage.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/deploy/FileMessage.java.diff?r1=1.2r2=1.3 1.2 +32 -1 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/deploy/UndeployMessage.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/deploy/UndeployMessage.java.diff?r1=1.1r2=1.2 1.3 +6 -2 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/ListenCallback.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/ListenCallback.java.diff?r1=1.2r2=1.3 1.9 +6 -4 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/ObjectReader.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/ObjectReader.java.diff?r1=1.8r2=1.9 1.3 +8 -6 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/SocketObjectReader.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/SocketObjectReader.java.diff?r1=1.2r2=1.3 1.15 +29 -18 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/XByteBuffer.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/io/XByteBuffer.java.diff?r1=1.14r2=1.15 1.15 +13 -1 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/mcast/McastService.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/mcast/McastService.java.diff?r1=1.14r2=1.15 1.48 +103 -74 jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/session/DeltaManager.java http://cvs.apache.org/viewcvs/jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/session/DeltaManager.java.diff?r1=1.47r2=1.48 1.35 +9 -1
cvs commit: jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp ClusterData.java
pero2005/06/26 14:22:45
Added: modules/cluster/src/share/org/apache/catalina/cluster/tcp
ClusterData.java
Log:
config resend and compress from message creator
Revision ChangesPath
1.1
jakarta-tomcat-catalina/modules/cluster/src/share/org/apache/catalina/cluster/tcp/ClusterData.java
Index: ClusterData.java
===
/*
* Copyright 1999,2005 The Apache Software Foundation.
*
* Licensed under the Apache License, Version 2.0 (the License);
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an AS IS BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.apache.catalina.cluster.tcp;
import org.apache.catalina.cluster.ClusterMessage;
/**
* @author Peter Rossbach
* @version $Revision: 1.1 $ $Date: 2005/06/26 21:22:45 $
* @since 5.5.10
*/
public class ClusterData {
private int resend = ClusterMessage.FLAG_DEFAULT ;
private int compress = ClusterMessage.FLAG_DEFAULT ;
private byte[] message ;
private long timestamp ;
private String uniqueId ;
private String type ;
public ClusterData() {}
/**
* @param type message type (class)
* @param uniqueId unique message id
* @param message message data
* @param timestamp message creation date
*/
public ClusterData(String type, String uniqueId, byte[] message, long
timestamp
) {
this.uniqueId = uniqueId;
this.message = message;
this.timestamp = timestamp;
}
/**
* @return Returns the type.
*/
public String getType() {
return type;
}
/**
* @param type The type to set.
*/
public void setType(String type) {
this.type = type;
}
/**
* @return Returns the message.
*/
public byte[] getMessage() {
return message;
}
/**
* @param message The message to set.
*/
public void setMessage(byte[] message) {
this.message = message;
}
/**
* @return Returns the timestamp.
*/
public long getTimestamp() {
return timestamp;
}
/**
* @param timestamp The timestamp to set.
*/
public void setTimestamp(long timestamp) {
this.timestamp = timestamp;
}
/**
* @return Returns the uniqueId.
*/
public String getUniqueId() {
return uniqueId;
}
/**
* @param uniqueId The uniqueId to set.
*/
public void setUniqueId(String uniqueId) {
this.uniqueId = uniqueId;
}
/**
* @return Returns the compress.
*/
public int getCompress() {
return compress;
}
/**
* @param compress The compress to set.
*/
public void setCompress(int compress) {
this.compress = compress;
}
/**
* @return Returns the resend.
*/
public int getResend() {
return resend;
}
/**
* @param resend The resend to set.
*/
public void setResend(int resend) {
this.resend = resend;
}
}
-
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
cvs commit: jakarta-tomcat-catalina/webapps/docs changelog.xml cluster-howto.xml
pero2005/06/26 14:23:36 Modified:webapps/docs changelog.xml cluster-howto.xml Log: add standalone cluster config support better GET_ALLSESSION support config resend and compress from message creator update cluster howto Revision ChangesPath 1.317 +25 -4 jakarta-tomcat-catalina/webapps/docs/changelog.xml Index: changelog.xml === RCS file: /home/cvs/jakarta-tomcat-catalina/webapps/docs/changelog.xml,v retrieving revision 1.316 retrieving revision 1.317 diff -u -r1.316 -r1.317 --- changelog.xml 24 Jun 2005 11:55:02 - 1.316 +++ changelog.xml 26 Jun 2005 21:23:35 - 1.317 @@ -62,12 +62,13 @@ - Optimized performance and reduce memory usage - Better JMX support - add a lot of JMX stats attribute for better monitoring + - add a single element default cluster configuration - more config options LifecycleListener ClusterListener - more than one Cluster Valves + more than one cluster valves - better subclass support - - change a lot of existing Cluster API's (pero) + - change a lot of existing cluster API's (pero) /update add Add Apache Portable Runtime JNI wrapper and helper API (mturk) @@ -230,6 +231,26 @@ subsection name=Cluster changelog add +Add single cluster default configuration element - discussed at JAX 2005 conference Cluster Workshop (pero) + /add + fix +Fix resend GET_ALL_SESSIONS when wait ACK failed at receiver side (pero) + /fix + fix +ClusterValve now remove from container element when cluster stops and added with next start again. (pero) + /fix + add +Set timestamp only at first time inside SessionMessageImpl (pero) + /add + add + Set timestamp from findsessions method call, when handling GET_ALL_SESSION + to all SEND_SESSION_DATA and TRANSFER complete messages. (pero + /add + add + Drop all received message inside GET_ALL_SESSION message queue before state + transfer message timestamp. (pero) + /add + add Cluster ping now transfer cluster domain information and DeltaManager only send and receive message from same domain members (pero) /add @@ -321,7 +342,7 @@ Also extract ClusterReceiverBase superclass for SocketReplicationListener and ReplicationListener (pero) /add update -Add and update some API documentation (pero) +Add and update some API and the a href=cluster-howto.htmlcluster howto documentation/a (pero) /update update Refactor ReplicationValve for better understanding and small optimization (pero) @@ -333,7 +354,7 @@ Fix ant build.xml to direct compile at cluster module directory (pero) /fix fix -Fix some I18N messages (pero) +Fix some I18N messages, but a lot of work is waiting for fix (pero) /fix add Add ReplicationValve Mbeans stats attribute getter and resetStatistics operation (pero) 1.9 +210 -26 jakarta-tomcat-catalina/webapps/docs/cluster-howto.xml Index: cluster-howto.xml === RCS file: /home/cvs/jakarta-tomcat-catalina/webapps/docs/cluster-howto.xml,v retrieving revision 1.8 retrieving revision 1.9 diff -u -r1.8 -r1.9 --- cluster-howto.xml 9 Jun 2005 20:42:55 - 1.8 +++ cluster-howto.xml 26 Jun 2005 21:23:36 - 1.9 @@ -17,7 +17,7 @@ section name=Quick Start -pTo run session replication in your Tomcat 5 container, the following steps +pTo run session replication in your Tomcat 5.5 container, the following steps should be completed:/p ul liAll your session attributes must implement codejava.io.Serializable/code/li @@ -28,6 +28,7 @@ liMake sure your codeweb.xml/code has the codelt;distributable/gt;/code element or set at your codelt;Context distributable=true /gt;/code/li liMake sure that jvmRoute attribute is set at your Engine codelt;Engine name=Catalina jvmRoute=node1 gt;/code/li +liMake sure that all nodes have the same time and sync with NTP service!/li /ul pLoad balancing can be achieved through many techniques, as seen in the a href=balancer-howto.htmlLoad Balancing/a chapter./p @@ -51,7 +52,7 @@ This is an algorithm that is only efficient when the clusters are small. For large clusters, the next release will support a primary-secondary session replication where the session will only be stored at one or maybe two backup servers.
Michael Bünermann/HBF/Minden/kampa/DE ist außer Haus .
Ich werde ab 25.06.2005 nicht im Büro sein. Ich kehre zurück am 11.07.2005. Ich werde Ihre Nachricht nach meiner Rückkehr beantworten. In dringenden Fällen wenden Sie sich bitte Herrn Bagehorn ([EMAIL PROTECTED]). Herr Bagehorn hat die Rufnummer 0571/93425-80) Alternativ erreichen Sie mich auch über die Funk-Rufnummer: 0171/99 33 525.
