airavata-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From lah...@apache.org
Subject svn commit: r1349520 - in /incubator/airavata/branches/0.3-incubating-snapshot/modules: commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/subscription/ ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/m...
Date Tue, 12 Jun 2012 20:53:08 GMT
Author: lahiru
Date: Tue Jun 12 20:53:07 2012
New Revision: 1349520

URL: http://svn.apache.org/viewvc?rev=1349520&view=rev
Log:
increasing the message pulling timeout.

Modified:
    incubator/airavata/branches/0.3-incubating-snapshot/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/subscription/MessageBoxNotificationHandler.java
    incubator/airavata/branches/0.3-incubating-snapshot/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MessagePuller.java

Modified: incubator/airavata/branches/0.3-incubating-snapshot/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/subscription/MessageBoxNotificationHandler.java
URL: http://svn.apache.org/viewvc/incubator/airavata/branches/0.3-incubating-snapshot/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/subscription/MessageBoxNotificationHandler.java?rev=1349520&r1=1349519&r2=1349520&view=diff
==============================================================================
--- incubator/airavata/branches/0.3-incubating-snapshot/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/subscription/MessageBoxNotificationHandler.java
(original)
+++ incubator/airavata/branches/0.3-incubating-snapshot/modules/commons/workflow-tracking/src/main/java/org/apache/airavata/workflow/tracking/impl/subscription/MessageBoxNotificationHandler.java
Tue Jun 12 20:53:07 2012
@@ -232,7 +232,7 @@ public class MessageBoxNotificationHandl
             logger.debug("\n\nCreated Messagebox at address :" + messageBoxAddress);
 
         subscriptionId = subToBrokerWithMsgBoxSink(msgBoxAddr, topic, xpath, wseClient, subscribePermananly);
-        messagePuller = msgboxHandler.startPullingEventsFromMsgBox(msgBoxAddr, this, 1500L,
1000l);
+        messagePuller = msgboxHandler.startPullingEventsFromMsgBox(msgBoxAddr, this, 1500L,
30000l);
         if (logger.isDebugEnabled())
             logger.debug("\n\nCreate Subscription for topic" + topic + " [Messagebox]\n\n");
 
@@ -255,7 +255,7 @@ public class MessageBoxNotificationHandl
             logger.info("\n\nCreated Messagebox at address :" + msgBoxAddr.getAddress());
 
         subscriptionId = subToBrokerWithMsgBoxSink(msgBoxAddr, topic, xpath, wseClient, subscribePermanatly);
-        messagePuller = msgboxHandler.startPullingEventsFromMsgBox(msgBoxAddr, this, 500L,
1000l);
+        messagePuller = msgboxHandler.startPullingEventsFromMsgBox(msgBoxAddr, this, 500L,
30000l);
         if (logger.isDebugEnabled())
             logger.info("\n\nCreate Subscription for topic" + topic + " [Messagebox]\n\n");
         Subscription subscription = new Subscription(this, subscriptionId, topic, callback,
this.brokerURL);

Modified: incubator/airavata/branches/0.3-incubating-snapshot/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MessagePuller.java
URL: http://svn.apache.org/viewvc/incubator/airavata/branches/0.3-incubating-snapshot/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MessagePuller.java?rev=1349520&r1=1349519&r2=1349520&view=diff
==============================================================================
--- incubator/airavata/branches/0.3-incubating-snapshot/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MessagePuller.java
(original)
+++ incubator/airavata/branches/0.3-incubating-snapshot/modules/ws-messenger/client/src/main/java/org/apache/airavata/wsmg/client/msgbox/MessagePuller.java
Tue Jun 12 20:53:07 2012
@@ -45,7 +45,7 @@ public class MessagePuller {
 
     long unavailableInterval = 300000;
 
-    long timeout = 2000L;
+    long timeout = 30000L;
 
     boolean stopPulling = false;
 
@@ -62,7 +62,7 @@ public class MessagePuller {
     }
 
     public MessagePuller(MsgBoxClient msgBoxUser, EndpointReference msgBoxId, NotificationHandler
handler) {
-        this(msgBoxUser, msgBoxId, handler, 1000, 2000);
+        this(msgBoxUser, msgBoxId, handler, 1000, 30000);
     }
 
     public void startPulling() {



Mime
View raw message