spring-integration

Clone Tools
  • last updated a few seconds ago
Constraints
Constraints: committers
 
Constraints: files
Constraints: dates

INT-3753: Expose More Metrics via IMBE

JIRA: https://jira.spring.io/browse/INT-3753

INT-3753: Add Channel Send Count to IMBE

Missing accessor for channel send counts.

Expose Full Metrics Objects

INT-3753: Expose More Metrics via IMBE

JIRA: https://jira.spring.io/browse/INT-3753

INT-3753: Add Channel Send Count to IMBE

Missing accessor for channel send counts.

Expose Full Metrics Objects

INT-3753: Expose More Metrics via IMBE

JIRA: https://jira.spring.io/browse/INT-3753

INT-3753: Add Channel Send Count to IMBE

Missing accessor for channel send counts.

Expose Full Metrics Objects

INT-3615: `@MessagingGateway` Long Properties

JIRA: https://jira.spring.io/browse/INT-3615

Change timeout properties from long to String to allow

property placeholder/SpEL configuration.

    • -2
    • +9
    /src/reference/asciidoc/whats-new.adoc

INT-2507: File: Fix HeadDirectoryScanner

JIRA: https://jira.spring.io/browse/INT-2507

When using a `HeadDirectoryScanner`, the use of any filter removed the

size limitation passed into the contstructor (or `queue-size` attribute

of a file inbound channel adapter.

The `HeadFilter` was overwritten.

Combine the head filter into a `CompositeFileListFilter` (creating one

if necessary).

    • -0
    • +2
    /src/reference/asciidoc/whats-new.adoc

INT-3749: Revert setters for `EC`

JIRA: https://jira.spring.io/browse/INT-3749

Since some target application could inject there is `EvaluationContext` before, removal of

`setIntegrationEvaluationContext()` is breaking change.

This fix reverts all those setters.

INT-3583: Allow MessageGroupProcessor in Agg, XML

JIRA: https://jira.spring.io/browse/INT-3583

Previously, the `ref` or inner bean for an aggregator was wrapped

in a `MethodInvokingMessageGroupProcessor` for POJO aggregation logic.

Now, if the ref'd bean is a `MessageGroupProcessor`, it is used as the

output processor directly.

Also, the `SimpleMessageGroupProcessor` is added which simply returns the

collection of messages.

INT-3583: Polishing; PR Comments

Fix AsciiDoc

Revert `CorrelationMessageBarrier` deprecation

Fix Docs for wrong chapter link

    • -0
    • +17
    /src/reference/asciidoc/aggregator.adoc
    • -3
    • +13
    /src/reference/asciidoc/whats-new.adoc

Zookeeper: fix JavaDocs errors

https://build.spring.io/browse/INT-B41-314

INT-3749: Get rid of `IECA` logic

JIRA: https://jira.spring.io/browse/INT-3749

Since `IntegrationEvaluationContextAware` isn't so "context-free" resource like `BeanFactory`

and `ApplicationContext`, but just a specific bean in the context, we can't follow with `BeanPostProcessor` logic - bad architecture by level of responsibility.

Therefore we should follow with standard Dependency Injection mechanism to retrieve `evaluationContext` for the particular component.

Since we can't rely on the `@Autowired` because SI can be used from the raw XML configuration,

we use utility method instead. The pattern to get the proper `integrationEvaluationContext` is:

```

@Override

protected void onInit() throws Exception

{ super.onInit(); this.evaluationContext = ExpressionUtils.createStandardEvaluationContext(getBeanFactory()); }

```

  1. … 11 more files in changeset.

Fix minor typo in Docs

INT-3751: Fix Python Scripting

JIRA: https://jira.spring.io/browse/INT-3751

Result was null when `executeScript()` was invoked with non-null variables.

When variable are provided, the result variable is stored in the provided bindings.

INT-3751: Fix Python Scripting

JIRA: https://jira.spring.io/browse/INT-3751

Result was null when `executeScript()` was invoked with non-null variables.

When variable are provided, the result variable is stored in the provided bindings.

INT-3751: Fix Python Scripting

JIRA: https://jira.spring.io/browse/INT-3751

Result was null when `executeScript()` was invoked with non-null variables.

When variable are provided, the result variable is stored in the provided bindings.

INT-3751: Fix Python Scripting

JIRA: https://jira.spring.io/browse/INT-3751

Result was null when `executeScript()` was invoked with non-null variables.

When variable are provided, the result variable is stored in the provided bindings.

Zookeeper: use a single ZK instance in tests

INT-3748: BridgeHandler: don't copy headers

JIRA: https://jira.spring.io/browse/INT-3748

  • override `shouldCopyRequestHeaders` to return false;
  • modify existing tests (not specific to `BridgeHandler`) that rely on the fact that `BridgeHandler` copies headers and creates a new message instance to use a custom test handler with the expected behaviour;

INT-3748 Polishing

  • moved test RequestHeaderCopyingMessageHandler
  • updated author tags and copyrights

INT-3748: BridgeHandler: don't copy headers

JIRA: https://jira.spring.io/browse/INT-3748

  • override `shouldCopyRequestHeaders` to return false;
  • modify existing tests (not specific to `BridgeHandler`) that rely on the fact that `BridgeHandler` copies headers and creates a new message instance to use a custom test handler with the expected behaviour;

INT-3748 Polishing

  • moved test RequestHeaderCopyingMessageHandler
  • updated author tags and copyrights

INT-3659: InputStream support in FileWritingMH

https://jira.spring.io/browse/INT-3659

Add `InputStream` `payload` handling to the `FileWritingMessageHandler`

    • -0
    • +2
    /src/reference/asciidoc/whats-new.adoc

INT-3616: Zookeeper LockRegistry

JIRA: https://jira.spring.io/browse/INT-3616

Zookeeper implementation of `LockRegistry`, for example to support

clustered aggregators (when using external message group stores).

INT-3616: Polishing; PR Comments

INT-3745: More TCP Events (Failed Correlation)

JIRA: https://jira.spring.io/browse/INT-3745

Emit events whenever a message is received that can't be correlated to

a connection (or request in the case of an outbound gateway).

Also, when sending messages, wrap the exception in a `MessagingException` so that

the `TcpConnectionExceptionEvent` provides access to the failed message.

INT-3745: Polishing - PR Comments

Fix JavaDocs errors

    • -10
    • +12
    /src/reference/asciidoc/whats-new.adoc

INT-3691 Add ZookeeperMetadataStore

JIRA: https://jira.spring.io/browse/INT-3691

  • create new core interfaces `ListenableMetadataStore` and `MessageStoreListener`;
  • create new module `spring-integration-zookeeper`;
  • add `ZookeeperMetadataStore` implementation

Polishing

Polishing

  • moved classes into core/test where necessary, including conversion methods
  • properly renamed `MetadataStoreListenerAdapter`

INT-3654: Rework TCP Connection Close

JIRA: https://jira.spring.io/browse/INT-3654

Previously, single-use `TcpConnections` self-closed when their use was complete.

This is unnatural and caused issues such as INT-3722.

Remove the self-closing behavior; connection close is now (properly) the responsibility

of the client using the connection:

  • Client Side:
    • `TcpOutboundGateway` after the reply is received
    • `TcpSendingMessageHandler` after the send, when there is no collaborating inbound adapter
    • `TcpReceivingChannelAdapter` when it is collaborating (after receiving the reply)

  • Server Side:
    • `TcpInboundGateway` after the reply is sent
    • `TcpReceivingChannelAdapter` after the receive, when there is no collaborating outbound adapter
    • `TcpSendingMessageHandler` when it is colllaborating (after sending the reply)

As before, the `CachingClientConnectionFactory` always sets single use on the target factory

to force it to create new connections on demand. It is always a single-use factory itself

so the clients return the connections to the pool (via `close()`).

_Needs a migration guide entry_

INT-3654: Fix Late Listener Registration

Timing failures in `TcpOutboundGatewayTests.testFailoverCached()` (null listener).

The `FailoverClientConnectionFactory` registers its listener with the actual

connections it retrieves from a delegate.

When nesting failover and cached connection factories, we need to propagate the

`enableManualListenerRegistration` to the delegate factories so the connection

will wait for its listener to be registered.

  1. … 9 more files in changeset.

INT-3744: Fix IMAPMessage receivedDate

JIRA: https://jira.spring.io/browse/INT-3744

MimeMessages are copied to eagerly fetch IMAP messages, this process loses

the `receivedDate` property.

Keep a reference to the source Message and delegate to its `receiveDate()`.

Cover more "void" getters

(cherry picked from commit 58e99b0)

INT-3744: Fix IMAPMessage receivedDate

JIRA: https://jira.spring.io/browse/INT-3744

MimeMessages are copied to eagerly fetch IMAP messages, this process loses

the `receivedDate` property.

Keep a reference to the source Message and delegate to its `receiveDate()`.

Cover more "void" getters

INT-3744: Fix IMAPMessage receivedDate

JIRA: https://jira.spring.io/browse/INT-3744

MimeMessages are copied to eagerly fetch IMAP messages, this process loses

the `receivedDate` property.

Keep a reference to the source Message and delegate to its `receiveDate()`.

Cover more "void" getters

INT-3744: Fix IMAPMessage receivedDate

JIRA: https://jira.spring.io/browse/INT-3744

MimeMessages are copied to eagerly fetch IMAP messages, this process loses

the `receivedDate` property.

Keep a reference to the source Message and delegate to its `receiveDate()`.

Cover more "void" getters

INT-3642: Improve MessageGroupStore Removal

JIRA: https://jira.spring.io/browse/INT-3642

Currently, `removeMessageFromGroup` rebuilds the group on every removal.

In every case where this method is used in the framework, the result is not used.

Add `removeMessagesFromGroup` that removes a collection of messages and returns no result.

INT-3642: Polishing - PR Comments

INT-3642: Polishing and Fix Group Metadata Size

  1. … 8 more files in changeset.

INT-3742: spring-data-gemfire 1.7 Compatibility

JIRA: https://jira.spring.io/browse/INT-3742

Deprecate the message store ctor that takes a `Cache` argument.

INT-4740: FileSplitter - Add Headers

JIRA: https://jira.spring.io/browse/INT-3740

For `File` and `String` payloads add `FileHeaders.ORIGINAL_FILE` and `FileHeaders.FILENAME` headers.

Reworked to create headers once only.

Fix typos and Java > 6 API usage