File tree Expand file tree Collapse file tree 4 files changed +10
-10
lines changed
temporal-kotlin/src/main/kotlin/io/temporal/worker
temporal-sdk/src/main/java/io/temporal/common/interceptors
temporal-serviceclient/src/main/java/io/temporal/internal Expand file tree Collapse file tree 4 files changed +10
-10
lines changed Original file line number Diff line number Diff line change @@ -72,6 +72,7 @@ inline fun <reified T : Any> Worker.registerWorkflowImplementationType(
7272 " Use registerWorkflowImplementationFactory instead" ,
7373 ReplaceWith (" this.registerWorkflowImplementationFactory(options, factory)" )
7474)
75+ @Suppress(" Deprecation" )
7576inline fun <reified T : Any > Worker.addWorkflowImplementationFactory (
7677 options : WorkflowImplementationOptions ,
7778 noinline factory : () -> T
@@ -116,6 +117,7 @@ inline fun <reified T : Any> Worker.registerWorkflowImplementationFactory(
116117 * @see Worker.addWorkflowImplementationFactory
117118 */
118119@Deprecated(" Use registerWorkflowImplementationFactory instead" , ReplaceWith (" this.registerWorkflowImplementationFactory(factory)" ))
120+ @Suppress(" Deprecation" )
119121inline fun <reified T : Any > Worker.addWorkflowImplementationFactory (
120122 noinline factory : () -> T
121123) {
Original file line number Diff line number Diff line change 3131 *
3232 * <p>You may want to start your implementation with this initial structure:
3333 *
34- * <pre>{@ code
34+ * <pre>< code>
3535 * public class CustomWorkerInterceptor extends WorkerInterceptorBase {
3636 * // remove if you don't need to have a custom WorkflowInboundCallsInterceptor or
3737 * // WorkflowOutboundCallsInterceptor
38- * {@literal @}Override
38+ * {@literal @}Override
3939 * public WorkflowInboundCallsInterceptor interceptWorkflow(WorkflowInboundCallsInterceptor next) {
4040 * return new CustomWorkflowInboundCallsInterceptor(next) {
4141 * // remove if you don't need to have a custom WorkflowOutboundCallsInterceptor
4747 * }
4848 *
4949 * // remove if you don't need to have a custom ActivityInboundCallsInterceptor
50- * {@literal @}Override
50+ * {@literal @}Override
5151 * public ActivityInboundCallsInterceptor interceptActivity(ActivityInboundCallsInterceptor next) {
5252 * return new CustomActivityInboundCallsInterceptor(next);
5353 * }
7979 * // override only the methods you need
8080 * }
8181 * }
82- * } </pre>
82+ * </code> </pre>
8383 */
8484@ Experimental
8585public interface WorkerInterceptor {
Original file line number Diff line number Diff line change 3737 *
3838 * <p>Example usage:
3939 *
40- * <p>
41- *
42- * <pre>
40+ * <pre><code>
4341 * BackoffThrottler throttler = new BackoffThrottler(1000, 60000, 2);
4442 * while(!stopped) {
4543 * try {
4644 * long throttleMs = throttler.getSleepTime();
47- * if (throttleMs > 0) {
45+ * if (throttleMs > 0) {
4846 * Thread.sleep(throttleMs);
4947 * }
5048 * // some code that can fail and should be throttled
5553 * throttler.failure();
5654 * }
5755 * }
58- * </pre>
56+ * </code></ pre>
5957 *
6058 * @author fateev
6159 */
Original file line number Diff line number Diff line change @@ -113,7 +113,7 @@ graal {
113113 outputName " temporal-test-server"
114114 mainClass application. getMainClass(). get()
115115 javaVersion ' 17'
116- graalVersion ' 22.2 .0'
116+ graalVersion ' 22.3 .0'
117117
118118 // Don't fallback to running a JVM
119119 option " --no-fallback"
You can’t perform that action at this time.
0 commit comments