[jboss-svn-commits] JBL Code SVN: r27075 - labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP1_SOA-1377/product/rosetta/src/org/jboss/internal/soa/esb/couriers.
jboss-svn-commits at lists.jboss.org
jboss-svn-commits at lists.jboss.org
Tue Jun 23 02:30:45 EDT 2009
Author: mageshbk at jboss.com
Date: 2009-06-23 02:30:45 -0400 (Tue, 23 Jun 2009)
New Revision: 27075
Modified:
labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP1_SOA-1377/product/rosetta/src/org/jboss/internal/soa/esb/couriers/InVMCourier.java
Log:
[SOA-1377] Remove notify from pickup
Modified: labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP1_SOA-1377/product/rosetta/src/org/jboss/internal/soa/esb/couriers/InVMCourier.java
===================================================================
--- labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP1_SOA-1377/product/rosetta/src/org/jboss/internal/soa/esb/couriers/InVMCourier.java 2009-06-22 23:08:05 UTC (rev 27074)
+++ labs/jbossesb/workspace/platform/branches/SOA-4.3.0.GA_CP1_SOA-1377/product/rosetta/src/org/jboss/internal/soa/esb/couriers/InVMCourier.java 2009-06-23 06:30:45 UTC (rev 27075)
@@ -282,9 +282,6 @@
if (!messageQueue.isEmpty()) {
messageObj = messageQueue.remove();
}
-
- // Notify 1 waiting delivery thread of the pickup...
- messageQueue.notify();
}
if(messageObj instanceof byte[]) {
@@ -336,6 +333,11 @@
public void setActive(boolean active) {
isActive = active;
+
+ if(!active && !messageQueue.isEmpty()) {
+ logger.error("Deactivated non-empty InVM Queue. Undelivered messages will be lost.");
+ messageQueue.clear();
+ }
}
public void clean() {
More information about the jboss-svn-commits
mailing list