aop
aop copied to clipboard
streamnative
[BUG]
Describe the bug Send fails on Pulsar 2.10.1 server as AOP/RabbitMQ libraries don't set a producer.
To Reproduce
send a message
https://github.com/tspannhw/airquality/blob/main/src/main/java/dev/datainmotion/airquality/service/AMQPService.java
Expected behavior
messages sends to topic no error
Screenshots
amqp send at java.lang.Thread.run(Thread.java:833) [?:?] Caused by: java.lang.NullPointerException: Cannot invoke "String.startsWith(String)" because "producerName" is null at org.apache.pulsar.broker.service.persistent.MessageDeduplication.isDuplicate(MessageDeduplication.java:327) ~[org.apache.pulsar-pulsar-broker-2.10.1.jar:2.10.1] at org.apache.pulsar.broker.service.persistent.PersistentTopic.publishMessage(PersistentTopic.java:428) ~[org.apache.pulsar-pulsar-broker-2.10.1.jar:2.10.1] at io.streamnative.pulsar.handlers.amqp.MessagePublishContext.publishMessages(MessagePublishContext.java:103) ~[?:?] at io.streamnative.pulsar.handlers.amqp.impl.PersistentExchange.writeMessageAsync(PersistentExchange.java:112) ~[?:?] at io.streamnative.pulsar.handlers.amqp.AmqpChannel.lambda$deliverCurrentMessageIfComplete$8(AmqpChannel.java:552) ~[?:?]
