Return-Path: X-Original-To: apmail-incubator-airavata-commits-archive@minotaur.apache.org Delivered-To: apmail-incubator-airavata-commits-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 4EED9928A for ; Tue, 12 Jun 2012 20:53:37 +0000 (UTC) Received: (qmail 63953 invoked by uid 500); 12 Jun 2012 20:53:36 -0000 Delivered-To: apmail-incubator-airavata-commits-archive@incubator.apache.org Received: (qmail 63914 invoked by uid 500); 12 Jun 2012 20:53:36 -0000 Mailing-List: contact airavata-commits-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: airavata-dev@incubator.apache.org Delivered-To: mailing list airavata-commits@incubator.apache.org Received: (qmail 63907 invoked by uid 99); 12 Jun 2012 20:53:36 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 12 Jun 2012 20:53:36 +0000 X-ASF-Spam-Status: No, hits=-2000.0 required=5.0 tests=ALL_TRUSTED X-Spam-Check-By: apache.org Received: from [140.211.11.4] (HELO eris.apache.org) (140.211.11.4) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 12 Jun 2012 20:53:29 +0000 Received: from eris.apache.org (localhost [127.0.0.1]) by eris.apache.org (Postfix) with ESMTP id 823A32388860; Tue, 12 Jun 2012 20:53:08 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit 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 -0000 To: airavata-commits@incubator.apache.org From: lahiru@apache.org X-Mailer: svnmailer-1.0.8-patched Message-Id: <20120612205308.823A32388860@eris.apache.org> 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() {