[CAMEL-18187] slack: inconsistent message payload when batch ends

• Type: Bug
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 3.14.3
• Fix Version/s: 3.14.4, 3.18.0
• Component/s: camel-slack
• Estimated Complexity: Unknown
• Assignee: Claus Ibsen
• Reporter: Luca Burgazzoli
• Created: 11/Jun/22 08:52
• Updated: 20/Jun/22 16:34
• Resolved: 20/Jun/22 16:34

Description

When polling multiple events from slack, there is an inconsistent of the payload generated for the exchange that complete the batch:

• This is an exchange part of the batch (CamelBatchComplete=false) and as it can be observed, the bodyType is com.slack.api.model.Message

10:47:28.470 INFO  [raw] (Camel (camel-1) thread #1 - slack://demo) Exchange[
  Id: B2F6BECBBE1B6C2-0000000000000001
  ExchangePattern: InOnly
  Properties: {camel.route.route1.B2F6BECBBE1B6C2-0000000000000001=io.smallrye.metrics.app.TimerImpl$Context@1bcda3c3, CamelBatchComplete=false, CamelBatchIndex=0, CamelBatchSize=2, CamelToEndpoint=log://raw?multiline=true&showAll=true, eventTimer:camel.exchange=io.smallrye.metrics.app.TimerImpl@7d791b4c, eventTimerContext:camel.exchange=io.smallrye.metrics.app.TimerImpl$Context@53f8d078}
  Headers: {}
  BodyType: com.slack.api.model.Message
  Body: Message(...)
]

• This is the exchange that closes the batch (CamelBatchComplete=true) and as it can be observed, the bodyType is byte[]:

10:47:28.477 INFO  [raw] (Camel (camel-1) thread #1 - slack://demo) Exchange[
  Id: B2F6BECBBE1B6C2-0000000000000001
  ExchangePattern: InOnly
  Properties: {camel.route.route1.B2F6BECBBE1B6C2-0000000000000001=io.smallrye.metrics.app.TimerImpl$Context@328e8fdf, CamelBatchComplete=true, CamelBatchIndex=1, CamelBatchSize=2, CamelToEndpoint=log://raw?multiline=true&showAll=true, eventTimer:camel.exchange=io.smallrye.metrics.app.TimerImpl@7d791b4c, eventTimerContext:camel.exchange=io.smallrye.metrics.app.TimerImpl$Context@53f8d078}
  Headers: {Content-Type=application/json, org.apache.kafka.clients.producer.RecordMetadata=[]}
  BodyType: byte[]
  Body: {"type":"message","subtype":"bot_message", ... }
]

Issue Links

• is broken by: CAMEL-18210 camel-core - Pooled exchanges in batch consumer may use an exchange concurrently