Skip to content

Commit

Permalink
DATAGO-67107 Added support for mapping/forwarding Solace message user…
Browse files Browse the repository at this point in the history
… properties to Kafka record headers

- Added two new configuration parameters: sol.message_processor.map_user_properties and
sol.message_processor.map_solace_standard_properties
- Updated tests, sample configuration and docs
  • Loading branch information
mayur-solace committed Feb 2, 2024
1 parent 208673c commit 7de1f3c
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 2 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,6 @@ public SolMessageProcessorIF process(String skey, BytesXMLMessage msg) {

this.sdestination = msg.getDestination().getName();
if (log.isDebugEnabled()) {
log.debug("Message Dump:{}", msg.dump());
log.debug("processing data for destination: {}; with message {}, with Kafka topic key of: {}",
(String) this.sdestination, msg, this.skey);
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -91,7 +91,6 @@ public SolMessageProcessorIF process(String skey, BytesXMLMessage msg) {
}

if (log.isDebugEnabled()) {
log.debug("Message Dump:{}", msg.dump());
log.debug("processing data for Kafka topic Key: {}; with message {}", skey, msg);
}

Expand Down

0 comments on commit 7de1f3c

Please sign in to comment.