Fix InvocationContext reuse in scheduled async and add missing license headers

Replace ctx.proceed() with direct Method.invoke() in scheduled async
re-executions. InvocationContext's interceptor iterator is single-use,
so re-calling proceed() would bypass TX/security interceptors after
the first scheduled execution. Context propagation is handled by
ContextService.enter/exit.

Also add Apache License headers to TCK resource files to fix RAT check.

Author: rzo1

container/openejb-core/src/main/java/org/apache/openejb/cdi/concurrency/AsynchronousInterceptor.java

@@ -147,8 +147,15 @@ private Object aroundInvokeScheduled(final InvocationContext ctx, final Asynchro
         final AtomicReference<ScheduledFuture<?>> scheduledRef = new AtomicReference<>();
         final AtomicReference<LastExecution> lastExecutionRef = new AtomicReference<>();
 
+        // Extract method and target from InvocationContext for direct invocation.
+        // We must NOT reuse ctx.proceed() — InvocationContext's interceptor iterator
+        // is single-use, so subsequent proceed() calls would bypass TX/security interceptors.
+        final Method beanMethod = ctx.getMethod();
+        final Object target = ctx.getTarget();
+        final Object[] params = ctx.getParameters();
+
         scheduleNextExecution(triggerDelegate, snapshot, ctxService, trigger, outerFuture,
-                ctx, isVoid, scheduledRef, lastExecutionRef);
+                beanMethod, target, params, isVoid, scheduledRef, lastExecutionRef);
 
         // Cancel the underlying scheduled task when the future completes externally
         // (e.g. Asynchronous.Result.complete() or cancel())
@@ -182,7 +189,8 @@ private ManagedScheduledExecutorServiceImpl resolveMses(final String executorNam
 
     private void scheduleNextExecution(final ScheduledExecutorService delegate, final ContextServiceImpl.Snapshot snapshot,
                                        final ContextServiceImpl ctxService, final ZonedTrigger trigger,
-                                       final CompletableFuture<Object> future, final InvocationContext ctx,
+                                       final CompletableFuture<Object> future, final Method beanMethod,
+                                       final Object target, final Object[] params,
                                        final boolean isVoid, final AtomicReference<ScheduledFuture<?>> scheduledRef,
                                        final AtomicReference<LastExecution> lastExecutionRef) {
         final ZonedDateTime taskScheduledTime = ZonedDateTime.now();
@@ -203,13 +211,18 @@ private void scheduleNextExecution(final ScheduledExecutorService delegate, fina
                 if (trigger.skipRun(lastExecutionRef.get(), nextRun)) {
                     // Skipped — reschedule for the next run
                     scheduleNextExecution(delegate, snapshot, ctxService, trigger, future,
-                            ctx, isVoid, scheduledRef, lastExecutionRef);
+                            beanMethod, target, params, isVoid, scheduledRef, lastExecutionRef);
                     return;
                 }
 
                 final ZonedDateTime runStart = ZonedDateTime.now();
                 Asynchronous.Result.setFuture(future);
-                final Object result = ctx.proceed();
+
+                // Invoke the bean method directly instead of ctx.proceed() —
+                // InvocationContext's interceptor iterator is single-use, so re-calling
+                // proceed() would bypass other interceptors (TX, security).
+                // Context propagation is handled by ContextService.enter/exit above.
+                final Object result = beanMethod.invoke(target, params);
                 final ZonedDateTime runEnd = ZonedDateTime.now();
 
                 // Track last execution for trigger computation
@@ -218,7 +231,7 @@ private void scheduleNextExecution(final ScheduledExecutorService delegate, fina
                 if (isVoid) {
                     Asynchronous.Result.setFuture(null);
                     scheduleNextExecution(delegate, snapshot, ctxService, trigger, future,
-                            ctx, isVoid, scheduledRef, lastExecutionRef);
+                            beanMethod, target, params, isVoid, scheduledRef, lastExecutionRef);
                     return;
                 }
 
@@ -241,7 +254,10 @@ private void scheduleNextExecution(final ScheduledExecutorService delegate, fina
                 Asynchronous.Result.setFuture(null);
                 // null return: schedule continues
                 scheduleNextExecution(delegate, snapshot, ctxService, trigger, future,
-                        ctx, isVoid, scheduledRef, lastExecutionRef);
+                        beanMethod, target, params, isVoid, scheduledRef, lastExecutionRef);
+            } catch (final java.lang.reflect.InvocationTargetException e) {
+                future.completeExceptionally(e.getCause() != null ? e.getCause() : e);
+                Asynchronous.Result.setFuture(null);
             } catch (final Exception e) {
                 future.completeExceptionally(e);
                 Asynchronous.Result.setFuture(null);

tck/concurrency-standalone/src/test/resources/META-INF/services/org.jboss.arquillian.core.spi.LoadableExtension

@@ -1 +1,15 @@
+# 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.
 org.apache.tomee.tck.concurrency.ConcurrencyTCKExtension

tck/concurrency-standalone/src/test/resources/logging.properties

@@ -1,3 +1,18 @@
+# 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.
+
 ## Logging configuration for Concurrency TCK
 
 handlers = java.util.logging.FileHandler, java.util.logging.ConsoleHandler