Add generic source_message header #2958
Comments
garyrussell
added a commit
to garyrussell/spring-integration
that referenced
this issue
Jun 10, 2019
garyrussell
added a commit
to garyrussell/spring-integration
that referenced
this issue
Jun 10, 2019
artembilan
pushed a commit
that referenced
this issue
Jun 10, 2019
artembilan
pushed a commit
that referenced
this issue
Jun 10, 2019
Resolves #2958 # Conflicts: # spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundChannelAdapter.java # spring-integration-amqp/src/main/java/org/springframework/integration/amqp/inbound/AmqpInboundGateway.java # spring-integration-amqp/src/test/java/org/springframework/integration/amqp/inbound/AmqpMessageSourceTests.java # spring-integration-amqp/src/test/java/org/springframework/integration/amqp/inbound/InboundEndpointTests.java # spring-integration-core/src/main/java/org/springframework/integration/IntegrationMessageHeaderAccessor.java
garyrussell
added a commit
to garyrussell/spring-integration
that referenced
this issue
Jun 11, 2019
Resolves spring-projects#2958 The previous commit added the raw source message to a common header `IntegrationMessageHeaderAccessor.SOURCE_DATA` so that the spring-cloud-stream can construct an error message containing the data when using functions. However, we also need to add it to the common header when the `ErrorMessage` is created by Spring Integration for the normal message channel binder. This allows the DLQ processing to be agnostic as to who created the error message.
artembilan
pushed a commit
that referenced
this issue
Jun 11, 2019
Resolves #2958 The previous commit added the raw source message to a common header `IntegrationMessageHeaderAccessor.SOURCE_DATA` so that the spring-cloud-stream can construct an error message containing the data when using functions. However, we also need to add it to the common header when the `ErrorMessage` is created by Spring Integration for the normal message channel binder. This allows the DLQ processing to be agnostic as to who created the error message.
artembilan
pushed a commit
that referenced
this issue
Jun 11, 2019
Resolves #2958 The previous commit added the raw source message to a common header `IntegrationMessageHeaderAccessor.SOURCE_DATA` so that the spring-cloud-stream can construct an error message containing the data when using functions. However, we also need to add it to the common header when the `ErrorMessage` is created by Spring Integration for the normal message channel binder. This allows the DLQ processing to be agnostic as to who created the error message. (cherry picked from commit 78a0ec7)
garyrussell
added a commit
to garyrussell/spring-integration-kafka
that referenced
this issue
Jun 11, 2019
Resolves spring-projects/spring-integration#2958 Enables applications to be agnostic regarding the source of a message. e.g Kafka Vs. AMQP.
artembilan
pushed a commit
to spring-attic/spring-integration-kafka
that referenced
this issue
Jun 11, 2019
Resolves spring-projects/spring-integration#2958 Enables applications to be agnostic regarding the source of a message. e.g Kafka Vs. AMQP.
artembilan
pushed a commit
to spring-attic/spring-integration-kafka
that referenced
this issue
Jun 11, 2019
Resolves spring-projects/spring-integration#2958 Enables applications to be agnostic regarding the source of a message. e.g Kafka Vs. AMQP. # Conflicts: # build.gradle
garyrussell
added a commit
to garyrussell/spring-integration
that referenced
this issue
Jun 24, 2020
Resolves spring-projects#2958 Enables applications to be agnostic regarding the source of a message. e.g Kafka Vs. AMQP.
artembilan
pushed a commit
that referenced
this issue
Jun 25, 2020
Resolves #2958 Enables applications to be agnostic regarding the source of a message. e.g Kafka Vs. AMQP.
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
To allow streams app to always have access to the raw message regardless of whether or not retry is enabled.
The text was updated successfully, but these errors were encountered: