spring-integration

spring-integration copied to clipboard

Spring Integration - Can not store SQS message in Redis

2

**In what version(s) of Spring Integration are you seeing this issue?** springBootVersion=2.5.3 springCloudVersion=2020.0.3 springCloudAWSVersion=2.2.6.RELEASE springSessionCoreVersion=2.5.1 springIntegrationVersion=5.2.2 **Describe the bug** I'm not sure if this is a bug for the Spring...

DPetrunov

Currently: ``` if (replyTopic == null) { if (this.replyTopicsAndPartitions.size() == 1) { replyTopic = getSingleReplyTopic(); } else { throw new IllegalStateException("No reply topic header and no default reply topic can...

garyrussell

[DO NOT MERGE YET] GH-3103: Introduce CloudEvents transformers

3

Fixes https://github.com/spring-projects/spring-integration/issues/3103 * Add an `io.cloudevents:cloudevents-api` optional dependency * Introduce a `HeaderMapper` and `Marshallers` in the `support.cloudevents` to marshal `CloudEvent` instances * Introduce a `ToCloudEventTransformer` to build a `CloudEvent` instance...

artembilan

Reconsider a default `order` value for default `LoggingHandler` subscribed into a default `errorChannel` by the framework

7

**In what version(s) of Spring Integration are you seeing this issue?** 5.4.3 **Describe the bug** There is no consistency between DSL and XML config for the order of subscribers on...

nikhilvasaikar

Custom TTL per LOCK in LockRegistry

10

Current default (and only) implementation of `LockRepository` based on JDBC (`DefaultLockRepository`) allows to set static TTL for all locks, controlled by this repository. But not all locks are equal. Some...

xak2000

See more info here: https://github.com/spring-projects/spring-integration/pull/3514#discussion_r595198712

artembilan

Documentation Enhancement: Describe point to point vs Centralized ESB

2

Document Enhancement I am new in spring integration and enterprise integration concept. After some search I found that: Spring Integration is **point to point** integration not a **centralized Enterprise Service...

afattahi54

Provide access to stored messages from the ChannelMessageStore API

1

It should be possible to use the public API of `ChannelMessageStore` to get access to stored messages without consuming those messages. The current implementation always yields an empty message group:...

mrnst

artembilan

Add recursive list support for remote file sessions

3

Something like `list(String path, boolean recurse)` to `Session` would be a good API delegated from the `AbstractInboundFileSynchronizer.transferFilesFromRemoteToLocal()` when we would like to deal not only with the top-level files in...

artembilan