Author: fhanik
Date: Fri Mar 3 04:51:42 2006
New Revision: 382792
URL: http://svn.apache.org/viewcvs?rev=382792&view=rev
Log:
Added in the ability to send a message to a member that has not yet made itself
visible but that has sent messages out.
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java?rev=382792&r1=382791&r2=382792&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/Channel.java
Fri Mar 3 04:51:42 2006
@@ -102,6 +102,13 @@
* @return Member
*/
public Member getLocalMember() ;
+
+ /**
+ *
+ * @param mbr Member
+ * @return Member
+ */
+ public Member getMember(Member mbr);
}
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java?rev=382792&r1=382791&r2=382792&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/group/GroupChannel.java
Fri Mar 3 04:51:42 2006
@@ -238,6 +238,16 @@
public Member[] getMembers() {
return coordinator.getMembershipService().getMembers();
}
+
+ /**
+ *
+ * @param mbr Member
+ * @return Member
+ */
+ public Member getMember(Member mbr){
+ return coordinator.getMembershipService().getMember(mbr);
+ }
+
/**
* Return the member that represents this node.
Modified:
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
URL:
http://svn.apache.org/viewcvs/tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java?rev=382792&r1=382791&r2=382792&view=diff
==============================================================================
---
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
(original)
+++
tomcat/container/tc5.5.x/modules/groupcom/src/share/org/apache/catalina/tribes/tcp/ReplicationTransmitter.java
Fri Mar 3 04:51:42 2006
@@ -285,11 +285,12 @@
}
}
+ /**
+ * @todo FIX THIS TO BE IN THE FACTORY
+ */
PooledParallelSender parallelsender = null;
public MultiPointSender getParallelSender() {
if ( parallelsender == null ) {
-
-
PooledParallelSender sender = new PooledParallelSender();
sender.setMaxRetryAttempts(2);
sender.setRxBufSize(getRxBufSize());
@@ -305,6 +306,10 @@
public void sendMessage(ChannelMessage message, Member destination) throws
ChannelException {
Object key = getKey(destination);
SinglePointSender sender = (SinglePointSender) map.get(key);
+ if ( sender == null ) {
+ add(destination);
+ sender = (SinglePointSender) map.get(key);
+ }
sendMessageData(message, sender);
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [EMAIL PROTECTED]
For additional commands, e-mail: [EMAIL PROTECTED]
