You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@servicemix.apache.org by gn...@apache.org on 2010/07/21 08:59:45 UTC
svn commit: r966104 - in /servicemix/smx4/nmr/trunk/jbi:
itests/src/test/java/org/apache/servicemix/jbi/itests/IntegrationTest.java
runtime/src/main/java/org/apache/servicemix/jbi/runtime/impl/EnvironmentImpl.java
Author: gnodet
Date: Wed Jul 21 06:59:44 2010
New Revision: 966104
URL: http://svn.apache.org/viewvc?rev=966104&view=rev
Log:
SMX4NMR-216: Shutdown issues with the NMR/JBI management layer
Modified:
servicemix/smx4/nmr/trunk/jbi/itests/src/test/java/org/apache/servicemix/jbi/itests/IntegrationTest.java
servicemix/smx4/nmr/trunk/jbi/runtime/src/main/java/org/apache/servicemix/jbi/runtime/impl/EnvironmentImpl.java
Modified: servicemix/smx4/nmr/trunk/jbi/itests/src/test/java/org/apache/servicemix/jbi/itests/IntegrationTest.java
URL: http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/jbi/itests/src/test/java/org/apache/servicemix/jbi/itests/IntegrationTest.java?rev=966104&r1=966103&r2=966104&view=diff
==============================================================================
--- servicemix/smx4/nmr/trunk/jbi/itests/src/test/java/org/apache/servicemix/jbi/itests/IntegrationTest.java (original)
+++ servicemix/smx4/nmr/trunk/jbi/itests/src/test/java/org/apache/servicemix/jbi/itests/IntegrationTest.java Wed Jul 21 06:59:44 2010
@@ -107,11 +107,9 @@ public class IntegrationTest extends Abs
ServiceAssembly sa = getOsgiService(ServiceAssembly.class);
assertNotNull(sa);
- Thread.sleep(500);
-
final List<Throwable> errors = new CopyOnWriteArrayList<Throwable>();
final int nbThreads = 2;
- final int nbMessagesPerThread = 10;
+ final int nbMessagesPerThread = 2;
final CountDownLatch latch = new CountDownLatch(nbThreads * nbMessagesPerThread);
for (int i = 0; i < nbThreads; i++) {
new Thread() {
Modified: servicemix/smx4/nmr/trunk/jbi/runtime/src/main/java/org/apache/servicemix/jbi/runtime/impl/EnvironmentImpl.java
URL: http://svn.apache.org/viewvc/servicemix/smx4/nmr/trunk/jbi/runtime/src/main/java/org/apache/servicemix/jbi/runtime/impl/EnvironmentImpl.java?rev=966104&r1=966103&r2=966104&view=diff
==============================================================================
--- servicemix/smx4/nmr/trunk/jbi/runtime/src/main/java/org/apache/servicemix/jbi/runtime/impl/EnvironmentImpl.java (original)
+++ servicemix/smx4/nmr/trunk/jbi/runtime/src/main/java/org/apache/servicemix/jbi/runtime/impl/EnvironmentImpl.java Wed Jul 21 06:59:44 2010
@@ -122,7 +122,9 @@ public class EnvironmentImpl implements
}
public void unmanageObject(Object managedObject) throws Exception {
- getManagementStrategy().unmanageObject(managedObject);
+ if (getManagementStrategy().isManaged(managedObject, null)) {
+ getManagementStrategy().unmanageObject(managedObject);
+ }
}
public void unmanageNamedObject(ObjectName name) throws Exception {