davsclaus commented on code in PR #28275:
URL: https://github.com/apache/camel/pull/28275#discussion_r4346937550
##########
components/camel-azure/camel-azure-eventhubs/src/main/java/org/apache/camel/component/azure/eventhubs/EventHubsEndpoint.java:
##########
@@ -36,6 +39,14 @@
syntax = "azure-eventhubs:namespace/eventHubName", category = {
Category.CLOUD, Category.MESSAGING },
headersClass = EventHubsConstants.class)
+@BodyTypes(consumerOut = @BodyType(value = Carrier.BYTES, javaType = "byte[]",
+ description = "The body of the event, one
message per event"),
+ producerIn = @BodyType(value = { Carrier.TEXT, Carrier.BYTES,
Carrier.STREAM, Carrier.FILE, Carrier.LIST },
+ description = "What converts to a byte
array: text, bytes, a stream or a file, sent as one"
+ + " event; a Map, a number or
a POJO fails: marshal it first. A List is sent"
+ + " as one event per element,
in one batch, and an element that is an Exchange"
+ + " or a Message is sent with
its headers"),
+ producerOut = @BodyType(Carrier.UNCHANGED))
Review Comment:
Done in 0f439b6b95fd: the producerOut of azure-eventhubs now has a
description, "Unchanged: a send gives no result, and no header is set", since
the producer sets no header either. Merged forward into #28276.
_Claude Code on behalf of davsclaus_
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
