From e6af632f7d2e16cf9161393b1869d03f593ceab7 Mon Sep 17 00:00:00 2001 From: Mark Fisher Date: Wed, 15 Oct 2008 21:41:39 +0000 Subject: [PATCH] Added 'errorChannel' header. --- .../springframework/integration/core/MessageHeaders.java | 6 ++++++ .../integration/message/MessageBuilder.java | 8 ++++++++ 2 files changed, 14 insertions(+) diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/core/MessageHeaders.java b/org.springframework.integration/src/main/java/org/springframework/integration/core/MessageHeaders.java index 95e7acb759..e2ac8c19cf 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/core/MessageHeaders.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/core/MessageHeaders.java @@ -42,6 +42,8 @@ public final class MessageHeaders implements Map, Serializable { public static final String REPLY_CHANNEL = PREFIX + "replyChannel"; + public static final String ERROR_CHANNEL = PREFIX + "errorChannel"; + public static final String EXPIRATION_DATE = PREFIX + "expirationDate"; public static final String PRIORITY = PREFIX + "priority"; @@ -83,6 +85,10 @@ public final class MessageHeaders implements Map, Serializable { return this.get(REPLY_CHANNEL); } + public Object getErrorChannel() { + return this.get(ERROR_CHANNEL); + } + public Integer getSequenceNumber() { Integer sequenceNumber = this.get(SEQUENCE_NUMBER, Integer.class); return (sequenceNumber != null ? sequenceNumber : 0); diff --git a/org.springframework.integration/src/main/java/org/springframework/integration/message/MessageBuilder.java b/org.springframework.integration/src/main/java/org/springframework/integration/message/MessageBuilder.java index a2cdd74e8f..3cafeef44f 100644 --- a/org.springframework.integration/src/main/java/org/springframework/integration/message/MessageBuilder.java +++ b/org.springframework.integration/src/main/java/org/springframework/integration/message/MessageBuilder.java @@ -174,6 +174,14 @@ public final class MessageBuilder { return this.setHeader(MessageHeaders.REPLY_CHANNEL, replyChannelName); } + public MessageBuilder setErrorChannel(MessageChannel errorChannel) { + return this.setHeader(MessageHeaders.ERROR_CHANNEL, errorChannel); + } + + public MessageBuilder setErrorChannelName(String errorChannelName) { + return this.setHeader(MessageHeaders.ERROR_CHANNEL, errorChannelName); + } + public MessageBuilder setSequenceNumber(Integer sequenceNumber) { return this.setHeader(MessageHeaders.SEQUENCE_NUMBER, sequenceNumber); }