Author: fhanik
Date: Thu Jun 29 03:46:56 2006
New Revision: 417998
URL: http://svn.apache.org/viewvc?rev=417998&view=rev
Log:
Added in the ability to set the domain both runtime and startup time
Modified:
tomcat/container/tc5.5.x/modules/groupcom/VERSION
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/MembershipService.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastService.java
Modified: tomcat/container/tc5.5.x/modules/groupcom/VERSION
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/VERSION?rev=417998&r1=417997&r2=417998&view=diff
==============================================================================
--- tomcat/container/tc5.5.x/modules/groupcom/VERSION (original)
+++ tomcat/container/tc5.5.x/modules/groupcom/VERSION Thu Jun 29 03:46:56 2006
@@ -1,7 +1,8 @@
-0.9.3.3
+0.9.4.0
- Added Member.getCommand, to separate out internal tribes logic from
application payload
- when setting payload, the update should get sent immediately
- domain name filter, using an interceptor if we wish
+ - major version bump since we are changing the protocol for member
0.9.3.2
- MemberImpl.toString has a limit on the size it prints out
0.9.3.1
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/MembershipService.java
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/MembershipService.java?rev=417998&r1=417997&r2=417998&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/MembershipService.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/MembershipService.java
Thu Jun 29 03:46:56 2006
@@ -128,5 +128,7 @@
* @param payload byte[]
*/
public void setPayload(byte[] payload);
+
+ public void setDomain(byte[] domain);
}
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastService.java
URL:
http://svn.apache.org/viewvc/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastService.java?rev=417998&r1=417997&r2=417998&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastService.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/membership/McastService.java
Thu Jun 29 03:46:56 2006
@@ -71,6 +71,8 @@
private int mcastTTL;
protected byte[] payload;
+
+ protected byte[] domain;
/**
* Create a membership service.
@@ -243,6 +245,7 @@
localMember.setMemberAliveTime(100);
}
if ( this.payload != null ) localMember.setPayload(payload);
+ if ( this.domain != null ) localMember.setDomain(domain);
localMember.setServiceStartTime(System.currentTimeMillis());
java.net.InetAddress bind = null;
if ( properties.getProperty("mcastBindAddress")!= null ) {
@@ -382,6 +385,10 @@
public byte[] getPayload() {
return payload;
}
+
+ public byte[] getDomain() {
+ return domain;
+ }
public void setMcastTTL(int mcastTTL) {
this.mcastTTL = mcastTTL;
@@ -397,6 +404,19 @@
if (impl != null) impl.send(false);
}catch ( Exception x ) {
log.error("Unable to send payload update.",x);
+ }
+ }
+ }
+
+ public void setDomain(byte[] domain) {
+ this.domain = domain;
+ if ( localMember != null ) {
+ localMember.setDomain(domain);
+ localMember.getData(true,true);
+ try {
+ if (impl != null) impl.send(false);
+ }catch ( Exception x ) {
+ log.error("Unable to send domain update.",x);
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
