diff options
Diffstat (limited to 'plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/MessageServiceProviderImpl.java')
-rw-r--r-- | plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/MessageServiceProviderImpl.java | 76 |
1 files changed, 38 insertions, 38 deletions
diff --git a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/MessageServiceProviderImpl.java b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/MessageServiceProviderImpl.java index 037e1c5f468..642a5e62cd5 100644 --- a/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/MessageServiceProviderImpl.java +++ b/plugins/org.eclipse.osee.framework.messaging/src/org/eclipse/osee/framework/messaging/internal/MessageServiceProviderImpl.java @@ -8,41 +8,41 @@ * Contributors: * Boeing - initial API and implementation *******************************************************************************/ -package org.eclipse.osee.framework.messaging.internal;
-
-import java.util.concurrent.ExecutorService;
-import java.util.concurrent.Executors;
-import org.eclipse.osee.framework.core.exception.OseeCoreException;
-import org.eclipse.osee.framework.messaging.MessageService;
-import org.eclipse.osee.framework.messaging.MessageServiceProvider;
-import org.eclipse.osee.framework.messaging.internal.activemq.ConnectionNodeFactoryImpl;
-
-/**
- * @author Andrew M. Finkbeiner
- */
-public class MessageServiceProviderImpl implements MessageServiceProvider {
-
- private MessageServiceImpl messageService;
- private ExecutorService executor;
- private ClassLoader contextClassLoader;
-
- MessageServiceProviderImpl(ClassLoader contextClassLoader) {
- this.contextClassLoader = contextClassLoader;
- }
-
- public void start() throws Exception {
-// Thread.currentThread().setContextClassLoader(contextClassLoader);
- executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
- messageService = new MessageServiceImpl(new ConnectionNodeFactoryImpl("1.0", Integer.toString(hashCode()), executor));
- }
-
- public void stop() throws Exception {
- messageService.stop();
- executor.shutdown();
- }
-
- @Override
- public MessageService getMessageService() throws OseeCoreException {
- return messageService;
- }
-}
+package org.eclipse.osee.framework.messaging.internal; + +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; +import org.eclipse.osee.framework.core.exception.OseeCoreException; +import org.eclipse.osee.framework.messaging.MessageService; +import org.eclipse.osee.framework.messaging.MessageServiceProvider; +import org.eclipse.osee.framework.messaging.internal.activemq.ConnectionNodeFactoryImpl; + +/** + * @author Andrew M. Finkbeiner + */ +public class MessageServiceProviderImpl implements MessageServiceProvider { + + private MessageServiceImpl messageService; + private ExecutorService executor; + private ClassLoader contextClassLoader; + + MessageServiceProviderImpl(ClassLoader contextClassLoader) { + this.contextClassLoader = contextClassLoader; + } + + public void start() throws Exception { +// Thread.currentThread().setContextClassLoader(contextClassLoader); + executor = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); + messageService = new MessageServiceImpl(new ConnectionNodeFactoryImpl("1.0", Integer.toString(hashCode()), executor)); + } + + public void stop() throws Exception { + messageService.stop(); + executor.shutdown(); + } + + @Override + public MessageService getMessageService() throws OseeCoreException { + return messageService; + } +} |