From b9e30adf2faca861bfad20a2ec2f92c25015a0cb Mon Sep 17 00:00:00 2001 From: Oleg Zhurakousky Date: Mon, 25 Jul 2022 09:57:29 +0200 Subject: [PATCH] Wrap PollableBean in try/catch to accomodate AOT --- .../cloud/stream/function/FunctionConfiguration.java | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java index 521427800..732f66232 100644 --- a/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java +++ b/core/spring-cloud-stream/src/main/java/org/springframework/cloud/stream/function/FunctionConfiguration.java @@ -232,9 +232,13 @@ public class FunctionConfiguration { if (!functionProperties.isComposeFrom() && !functionProperties.isComposeTo()) { String integrationFlowName = proxyFactory.getFunctionDefinition() + "_integrationflow"; - // Add back once https://github.com/spring-projects/spring-framework/issues/28748 is fixed - // PollableBean pollable = extractPollableAnnotation(functionProperties, context, proxyFactory); PollableBean pollable = null; + try { + pollable = extractPollableAnnotation(functionProperties, context, proxyFactory); + } + catch (Exception e) { + // Will fix itself once https://github.com/spring-projects/spring-framework/issues/28748 is fixed + } if (functionWrapper != null) { IntegrationFlow integrationFlow = integrationFlowFromProvidedSupplier(new PartitionAwareFunctionWrapper(functionWrapper, context, producerProperties),