From 2213475ef93df60dcaf3a4345a0dc300b652579e Mon Sep 17 00:00:00 2001
From: rfeng
Date: Tue, 9 Dec 2008 18:56:13 +0000
Subject: Adjust the package names and move test cases around
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@724826 13f79535-47bb-0310-9956-ffa450edef68
---
.../sca/core/work/DefaultWorkScheduler.java | 191 ----------------
.../sca/core/work/ThreadPoolWorkManager.java | 229 -------------------
.../org/apache/tuscany/sca/core/work/Work.java | 65 ------
.../apache/tuscany/sca/core/work/WorkEvent.java | 80 -------
.../org/apache/tuscany/sca/core/work/WorkItem.java | 167 --------------
.../apache/tuscany/sca/core/work/WorkListener.java | 32 ---
.../sca/core/work/impl/DefaultWorkScheduler.java | 191 ++++++++++++++++
.../sca/core/work/impl/ThreadPoolWorkManager.java | 229 +++++++++++++++++++
.../apache/tuscany/sca/core/work/impl/Work.java | 65 ++++++
.../tuscany/sca/core/work/impl/WorkEvent.java | 80 +++++++
.../tuscany/sca/core/work/impl/WorkItem.java | 167 ++++++++++++++
.../tuscany/sca/core/work/impl/WorkListener.java | 32 +++
.../org.apache.tuscany.sca.work.WorkScheduler | 2 +-
.../DefaultExtensionPointRegistryTestCase.java | 56 -----
...CallbackInterfaceInterceptorTestCase.java.fixme | 62 ++++++
.../impl/InvocationChainImplTestCase.java | 96 ++++++++
.../impl/NonBlockingInterceptorTestCase.java.fixme | 74 +++++++
...CallbackInterfaceInterceptorTestCase.java.fixme | 62 ------
.../sca/core/wire/InvocationChainImplTestCase.java | 96 --------
.../wire/NonBlockingInterceptorTestCase.java.fixme | 74 -------
.../apache/tuscany/sca/core/work/FailingWork.java | 53 -----
.../sca/core/work/JSR237MyFailingRunnable.java | 43 ----
.../tuscany/sca/core/work/JSR237MyRunnable.java | 71 ------
.../sca/core/work/JSR237MyRunnerListener.java | 154 -------------
.../sca/core/work/Jsr237WorkSchedulerTestCase.java | 240 --------------------
.../tuscany/sca/core/work/TestWorkListener.java | 153 -------------
.../core/work/ThreadPoolWorkManagerTestCase.java | 243 --------------------
.../tuscany/sca/core/work/TimeDelayWork.java | 86 --------
.../tuscany/sca/core/work/impl/FailingWork.java | 55 +++++
.../core/work/impl/JSR237MyFailingRunnable.java | 43 ++++
.../sca/core/work/impl/JSR237MyRunnable.java | 71 ++++++
.../sca/core/work/impl/JSR237MyRunnerListener.java | 154 +++++++++++++
.../work/impl/Jsr237WorkSchedulerTestCase.java | 241 ++++++++++++++++++++
.../sca/core/work/impl/TestWorkListener.java | 155 +++++++++++++
.../work/impl/ThreadPoolWorkManagerTestCase.java | 244 +++++++++++++++++++++
.../tuscany/sca/core/work/impl/TimeDelayWork.java | 88 ++++++++
36 files changed, 2048 insertions(+), 2096 deletions(-)
delete mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/DefaultWorkScheduler.java
delete mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/ThreadPoolWorkManager.java
delete mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/Work.java
delete mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/WorkEvent.java
delete mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/WorkItem.java
delete mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/WorkListener.java
create mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/impl/DefaultWorkScheduler.java
create mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/impl/ThreadPoolWorkManager.java
create mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/impl/Work.java
create mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/impl/WorkEvent.java
create mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/impl/WorkItem.java
create mode 100644 java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/impl/WorkListener.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/DefaultExtensionPointRegistryTestCase.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/invocation/impl/CallbackInterfaceInterceptorTestCase.java.fixme
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/invocation/impl/InvocationChainImplTestCase.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/invocation/impl/NonBlockingInterceptorTestCase.java.fixme
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/wire/CallbackInterfaceInterceptorTestCase.java.fixme
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/wire/InvocationChainImplTestCase.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/wire/NonBlockingInterceptorTestCase.java.fixme
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/FailingWork.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/JSR237MyFailingRunnable.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/JSR237MyRunnable.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/JSR237MyRunnerListener.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/Jsr237WorkSchedulerTestCase.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/TestWorkListener.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/ThreadPoolWorkManagerTestCase.java
delete mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/TimeDelayWork.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/FailingWork.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/JSR237MyFailingRunnable.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/JSR237MyRunnable.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/JSR237MyRunnerListener.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/Jsr237WorkSchedulerTestCase.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/TestWorkListener.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/ThreadPoolWorkManagerTestCase.java
create mode 100644 java/sca/modules/core/src/test/java/org/apache/tuscany/sca/core/work/impl/TimeDelayWork.java
(limited to 'java/sca/modules/core/src')
diff --git a/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/DefaultWorkScheduler.java b/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/DefaultWorkScheduler.java
deleted file mode 100644
index 2085a796ab..0000000000
--- a/java/sca/modules/core/src/main/java/org/apache/tuscany/sca/core/work/DefaultWorkScheduler.java
+++ /dev/null
@@ -1,191 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing,
- * software distributed under the License is distributed on an
- * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
- * KIND, either express or implied. See the License for the
- * specific language governing permissions and limitations
- * under the License.
- */
-package org.apache.tuscany.sca.core.work;
-
-import java.security.AccessController;
-import java.security.PrivilegedAction;
-
-import org.apache.tuscany.sca.work.NotificationListener;
-import org.apache.tuscany.sca.work.WorkScheduler;
-import org.apache.tuscany.sca.work.WorkSchedulerException;
-
-/**
- * A work scheduler implementation based on a JSR 237 work manager.
- *
- *
- * This needs a JSR 237 work manager implementation available for scheduling work. Instances can be configured with a
- * work manager implementation that is injected in. It is the responsibility of the runtime environment to make a work
- * manager implementation available. For example, if the managed environment supports work manager the runtime can use
- * the appropriate lookup mechanism to inject the work manager implementation.
- *
- * @version $Rev$ $Date$
- */
-public class DefaultWorkScheduler implements WorkScheduler {
-
- /**
- * Underlying JSR-237 work manager
- */
- private ThreadPoolWorkManager jsr237WorkManager;
-
- /**
- * Initializes the JSR 237 work manager.
- *
- * @param jsr237WorkManager JSR 237 work manager.
- */
- public DefaultWorkScheduler() {
- }
-
- private synchronized ThreadPoolWorkManager getWorkManager() {
- if (jsr237WorkManager != null) {
- return jsr237WorkManager;
- }
-// try {
-// InitialContext ctx = new InitialContext();
-// jsr237WorkManager = (ThreadPoolWorkManager)ctx.lookup("java:comp/env/wm/TuscanyWorkManager");
-// } catch (Throwable e) {
-// // ignore
-// }
- if (jsr237WorkManager == null) {
- jsr237WorkManager = new ThreadPoolWorkManager(10);
- }
- return jsr237WorkManager;
- }
-
- /**
- * Schedules a unit of work for future execution. The notification listener is used to register interest in
- * callbacks regarding the status of the work.
- *
- * @param work The unit of work that needs to be asynchronously executed.
- */
- public void scheduleWork(T work) {
- scheduleWork(work, null);
- }
-
- /**
- * Schedules a unit of work for future execution. The notification listener is used to register interest in
- * callbacks regarding the status of the work.
- *
- * @param work The unit of work that needs to be asynchronously executed.
- * @param listener Notification listener for callbacks.
- */
- public void scheduleWork(T work, NotificationListener listener) {
-
- if (work == null) {
- throw new IllegalArgumentException("Work cannot be null");
- }
-
- Work jsr237Work = new Work(work);
- try {
- if (listener == null) {
- getWorkManager().schedule(jsr237Work);
- } else {
- Jsr237WorkListener jsr237WorkListener = new Jsr237WorkListener(listener, work);
- getWorkManager().schedule(jsr237Work, jsr237WorkListener);
- }
- } catch (IllegalArgumentException ex) {
- if (listener != null) {
- listener.workRejected(work);
- } else {
- throw new WorkSchedulerException(ex);
- }
- } catch (Exception ex) {
- throw new WorkSchedulerException(ex);
- }
-
- }
-
- public void destroy() {
- if (jsr237WorkManager instanceof ThreadPoolWorkManager) {
- // Allow privileged access to modify threads. Requires RuntimePermission in security
- // policy.
- AccessController.doPrivileged(new PrivilegedAction