File tree Expand file tree Collapse file tree 2 files changed +9
-0
lines changed
main/java/com/rabbitmq/stream Expand file tree Collapse file tree 2 files changed +9
-0
lines changed Original file line number Diff line number Diff line change @@ -328,6 +328,13 @@ include::{test-examples}/ProducerUsage.java[tag=producer-creation]
328328Consider a `Producer` instance like a long-lived object, do not create one
329329to send just one message.
330330
331+
332+ [NOTE]
333+ .Producer thread safety
334+ ====
335+ Producer instances are thread-safe.
336+ ====
337+
331338Internally, the `Environment` will query the broker to find out about
332339the topology of the stream and will create or re-use a connection to
333340publish to the leader node of the stream.
Original file line number Diff line number Diff line change 1818 *
1919 * <p>Instances are created and configured with a {@link ProducerBuilder}.
2020 *
21+ * Implementations are expected to be thread-safe, RabbitMQ Streams' are.
22+ *
2123 * @see ProducerBuilder
2224 * @see Environment#producerBuilder()
2325 */
You can’t perform that action at this time.
0 commit comments