You are viewing a plain text version of this content. The canonical link for it is here.
Posted to sandesha-dev@ws.apache.org by ja...@apache.org on 2006/06/01 18:57:28 UTC
svn commit: r410888 - in /webservices/sandesha/branches/sandesha_1_0:
config/ src/org/apache/sandesha/ src/org/apache/sandesha/server/
src/org/apache/sandesha/storage/queue/
Author: jaliya
Date: Thu Jun 1 09:57:28 2006
New Revision: 410888
URL: http://svn.apache.org/viewvc?rev=410888&view=rev
Log:
Fixed a timing issue
Modified:
webservices/sandesha/branches/sandesha_1_0/config/WSRMPolicy.xml
webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/Constants.java
webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java
webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/server/SenderWorker.java
webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/storage/queue/SandeshaQueue.java
Modified: webservices/sandesha/branches/sandesha_1_0/config/WSRMPolicy.xml
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha_1_0/config/WSRMPolicy.xml?rev=410888&r1=410887&r2=410888&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha_1_0/config/WSRMPolicy.xml (original)
+++ webservices/sandesha/branches/sandesha_1_0/config/WSRMPolicy.xml Thu Jun 1 09:57:28 2006
@@ -10,9 +10,9 @@
<wsrm:RMAssertion>
<!-- <wsrm:InactivityTimeout Milliseconds="600000" /> -->
<wsrm:InactivityTimeout Milliseconds="240000"/>
- <wsrm:BaseRetransmissionInterval Milliseconds="3000"/>
+ <wsrm:BaseRetransmissionInterval Milliseconds="1000"/>
<wsrm:ExponentialBackoff/>
- <wsrm:AcknowledgementInterval Milliseconds="200"/>
+ <wsrm:AcknowledgementInterval Milliseconds="50"/>
</wsrm:RMAssertion>
<!-- omitted assertions -->
</wsp:Policy>
Modified: webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/Constants.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/Constants.java?rev=410888&r1=410887&r2=410888&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/Constants.java (original)
+++ webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/Constants.java Thu Jun 1 09:57:28 2006
@@ -49,12 +49,12 @@
String THREAD_POOL_SIZE = "threadPoolSize";
long RETRANSMISSION_INTERVAL = 4000L;
- long ACKNOWLEDGEMENT_INTERVAL = 200L;
+ long ACKNOWLEDGEMENT_INTERVAL = 400L;
long INACTIVITY_TIMEOUT = 600000L;
- long RMINVOKER_SLEEP_TIME = 2000L;
- long SENDER_SLEEP_TIME = 2000L;
- long CLIENT_RESPONSE_CHECKING_INTERVAL = 500L;
- long CLIENT_WAIT_PERIOD_FOR_COMPLETE = 1000L;
+ long RMINVOKER_SLEEP_TIME =5L;
+ long SENDER_SLEEP_TIME =5L;
+ long CLIENT_RESPONSE_CHECKING_INTERVAL = 5L;
+ long CLIENT_WAIT_PERIOD_FOR_COMPLETE = 5L;
int SERVER_QUEUE_ACCESSOR = 1;
int SERVER_DATABASE_ACCESSOR = 2;
Modified: webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java?rev=410888&r1=410887&r2=410888&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java (original)
+++ webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/SandeshaContext.java Thu Jun 1 09:57:28 2006
@@ -262,7 +262,6 @@
if (log.isDebugEnabled()) {
log.debug(Constants.InfomationMessage.SENDER_STARTED);
}
- System.out.println("How can i come to this");
if (!cleintSenderStarted) {
cleintSender = new Sender(storageManager);
SimpleChain reqChain = null;
Modified: webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/server/SenderWorker.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/server/SenderWorker.java?rev=410888&r1=410887&r2=410888&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/server/SenderWorker.java (original)
+++ webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/server/SenderWorker.java Thu Jun 1 09:57:28 2006
@@ -135,7 +135,7 @@
long newRtTime = ((long) Math.pow(retransmissionInterval / 1000,
rmMessageContext.getReTransmissionCount())) * 1000;
rmMessageContext.setRetransmissionTime(newRtTime);
-
+ //System.out.println("retrans time"+rmMessageContext.getRetransmissionTime()+ " retrans count "+rmMessageContext.getReTransmissionCount());
} else {
//Let's do Binary Back Off
long rtTime = rmMessageContext.getRetransmissionTime();
Modified: webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/storage/queue/SandeshaQueue.java
URL: http://svn.apache.org/viewvc/webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/storage/queue/SandeshaQueue.java?rev=410888&r1=410887&r2=410888&view=diff
==============================================================================
--- webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/storage/queue/SandeshaQueue.java (original)
+++ webservices/sandesha/branches/sandesha_1_0/src/org/apache/sandesha/storage/queue/SandeshaQueue.java Thu Jun 1 09:57:28 2006
@@ -254,7 +254,7 @@
Date d = new Date();
long currentTime = d.getTime();
if (currentTime >=
- lastSentTime + Constants.RETRANSMISSION_INTERVAL) {
+ lastSentTime + PolicyLoader.getInstance().getBaseRetransmissionInterval()) {
String newCreateSeqId = Constants.UUID + uuidGen.nextUUID();
tempMsg.setMessageID(newCreateSeqId);
---------------------------------------------------------------------
To unsubscribe, e-mail: sandesha-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: sandesha-dev-help@ws.apache.org