summaryrefslogtreecommitdiffstats
path: root/sca-java-2.x/trunk
diff options
context:
space:
mode:
Diffstat (limited to 'sca-java-2.x/trunk')
-rw-r--r--sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/CompositeActivatorImpl.java46
-rw-r--r--sca-java-2.x/trunk/modules/core/src/main/resources/core-messages.properties3
2 files changed, 33 insertions, 16 deletions
diff --git a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/CompositeActivatorImpl.java b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/CompositeActivatorImpl.java
index 362849f28b..367c082839 100644
--- a/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/CompositeActivatorImpl.java
+++ b/sca-java-2.x/trunk/modules/core/src/main/java/org/apache/tuscany/sca/core/assembly/impl/CompositeActivatorImpl.java
@@ -524,7 +524,11 @@ public class CompositeActivatorImpl implements CompositeActivator {
// registered before any @EagerInit takes place
public void start(CompositeContext compositeContext, ScopedRuntimeComponent scopedRuntimeComponent) {
if (scopedRuntimeComponent.getScopeContainer() != null) {
- scopedRuntimeComponent.getScopeContainer().start();
+ try {
+ scopedRuntimeComponent.getScopeContainer().start();
+ } catch (Throwable ex){
+ Monitor.error(monitor, this, "core-messages", "StartException", ex);
+ }
}
}
@@ -539,24 +543,32 @@ public class CompositeActivatorImpl implements CompositeActivator {
for (PolicyProvider policyProvider : ep.getPolicyProviders()) {
policyProvider.start();
if (providers != null) {
- providers.add(policyProvider);
+ try {
+ providers.add(policyProvider);
+ } catch (Throwable ex){
+ Monitor.error(monitor, this, "core-messages", "StartException", ex);
+ }
}
}
final ServiceBindingProvider bindingProvider = ep.getBindingProvider();
if (bindingProvider != null) {
- // bindingProvider.start();
- // Allow bindings to add shutdown hooks. Requires RuntimePermission shutdownHooks in policy.
- AccessController.doPrivileged(new PrivilegedAction<Object>() {
- public Object run() {
- bindingProvider.start();
- if (providers != null) {
- providers.add(bindingProvider);
- }
- return null;
- }
- });
- compositeContext.getEndpointRegistry().addEndpoint(ep);
+ try {
+ // bindingProvider.start();
+ // Allow bindings to add shutdown hooks. Requires RuntimePermission shutdownHooks in policy.
+ AccessController.doPrivileged(new PrivilegedAction<Object>() {
+ public Object run() {
+ bindingProvider.start();
+ if (providers != null) {
+ providers.add(bindingProvider);
+ }
+ return null;
+ }
+ });
+ compositeContext.getEndpointRegistry().addEndpoint(ep);
+ } catch (Throwable ex){
+ Monitor.error(monitor, this, "core-messages", "StartException", ex);
+ }
}
}
@@ -611,7 +623,11 @@ public class CompositeActivatorImpl implements CompositeActivator {
((EndpointReferenceAsyncProvider)bindingProvider).supportsNativeAsync() &&
epr.isAsyncInvocation()){
// it's resolved so start it now
- start(compositeContext, epr);
+ try {
+ start(compositeContext, epr);
+ } catch (Throwable ex){
+ Monitor.error(monitor, this, "core-messages", "StartException", ex);
+ }
}
}
}
diff --git a/sca-java-2.x/trunk/modules/core/src/main/resources/core-messages.properties b/sca-java-2.x/trunk/modules/core/src/main/resources/core-messages.properties
index 83eafc1278..f6346b885f 100644
--- a/sca-java-2.x/trunk/modules/core/src/main/resources/core-messages.properties
+++ b/sca-java-2.x/trunk/modules/core/src/main/resources/core-messages.properties
@@ -17,4 +17,5 @@
# under the License.
#
#
-StopException = Exception during stop processing \ No newline at end of file
+StopException = Exception during stop processing
+StartException = Exception during start processing \ No newline at end of file