You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by or...@apache.org on 2022/03/07 12:54:51 UTC
[camel] 06/23: CAMEL-15520: fixed deprecations in camel-syslog
This is an automated email from the ASF dual-hosted git repository.
orpiske pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 96164ab835313b23c3d8c3a336a9df1964689477
Author: Otavio Rodolfo Piske <an...@gmail.com>
AuthorDate: Mon Mar 7 11:09:30 2022 +0100
CAMEL-15520: fixed deprecations in camel-syslog
---
.../apache/camel/component/syslog/SyslogDataFormat.java | 16 ++++++++--------
1 file changed, 8 insertions(+), 8 deletions(-)
diff --git a/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogDataFormat.java b/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogDataFormat.java
index f629f2a..0af4a87 100644
--- a/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogDataFormat.java
+++ b/components/camel-syslog/src/main/java/org/apache/camel/component/syslog/SyslogDataFormat.java
@@ -46,13 +46,13 @@ public class SyslogDataFormat extends ServiceSupport implements DataFormat, Data
String body = ExchangeHelper.convertToMandatoryType(exchange, String.class, inputStream);
SyslogMessage message = SyslogConverter.parseMessage(body.getBytes());
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_FACILITY, message.getFacility());
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_SEVERITY, message.getSeverity());
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_HOSTNAME, message.getHostname());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_FACILITY, message.getFacility());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_SEVERITY, message.getSeverity());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_HOSTNAME, message.getHostname());
// use java.util.Date as timestamp
Date time = message.getTimestamp() != null ? message.getTimestamp().getTime() : null;
if (time != null) {
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_TIMESTAMP, time);
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_TIMESTAMP, time);
}
// Since we are behind the fact of being in an Endpoint...
@@ -60,22 +60,22 @@ public class SyslogDataFormat extends ServiceSupport implements DataFormat, Data
if (exchange.getIn().getHeader("CamelMinaLocalAddress") != null) {
message.setLocalAddress(exchange.getIn().getHeader("CamelMinaLocalAddress", String.class));
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_LOCAL_ADDRESS, message.getLocalAddress());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_LOCAL_ADDRESS, message.getLocalAddress());
}
if (exchange.getIn().getHeader("CamelMinaRemoteAddress") != null) {
message.setRemoteAddress(exchange.getIn().getHeader("CamelMinaRemoteAddress", String.class));
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_REMOTE_ADDRESS, message.getRemoteAddress());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_REMOTE_ADDRESS, message.getRemoteAddress());
}
if (exchange.getIn().getHeader("CamelNettyLocalAddress") != null) {
message.setLocalAddress(exchange.getIn().getHeader("CamelNettyLocalAddress", String.class));
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_LOCAL_ADDRESS, message.getLocalAddress());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_LOCAL_ADDRESS, message.getLocalAddress());
}
if (exchange.getIn().getHeader("CamelNettyRemoteAddress") != null) {
message.setRemoteAddress(exchange.getIn().getHeader("CamelNettyRemoteAddress", String.class));
- exchange.getOut().setHeader(SyslogConstants.SYSLOG_REMOTE_ADDRESS, message.getRemoteAddress());
+ exchange.getMessage().setHeader(SyslogConstants.SYSLOG_REMOTE_ADDRESS, message.getRemoteAddress());
}
return message;