Skip to content

Commit 6827476

Browse files
committed
* Rebase and fix conflicts
1 parent 7946870 commit 6827476

File tree

2 files changed

+2
-1
lines changed

2 files changed

+2
-1
lines changed

spring-integration-core/src/main/java/org/springframework/integration/endpoint/AbstractPollingEndpoint.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,8 @@ public abstract class AbstractPollingEndpoint extends AbstractEndpoint implement
7272

7373
private Executor taskExecutor = new SyncTaskExecutor();
7474

75+
private boolean syncExecutor = true;
76+
7577
private ClassLoader beanClassLoader = ClassUtils.getDefaultClassLoader();
7678

7779
private Trigger trigger = new PeriodicTrigger(10);

spring-integration-core/src/main/java/org/springframework/integration/endpoint/SourcePollingChannelAdapter.java

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,6 @@
3030
import org.springframework.integration.StaticMessageHeaderAccessor;
3131
import org.springframework.integration.acks.AckUtils;
3232
import org.springframework.integration.acks.AcknowledgmentCallback;
33-
import org.springframework.integration.aop.AbstractMessageSourceAdvice;
3433
import org.springframework.integration.aop.MessageSourceMutator;
3534
import org.springframework.integration.channel.ReactiveStreamsSubscribableChannel;
3635
import org.springframework.integration.context.ExpressionCapable;

0 commit comments

Comments
 (0)