|
Change Variable Type msg : Message<byte[]> to msg : Message<String> in method public testMessageRedelivery() : void in class org.apache.pulsar.broker.service.PersistentTopicE2ETest |
From |
To |
|
Change Variable Type producer : Producer<byte[]> to producer : Producer<String> in method public testMessageRedelivery() : void in class org.apache.pulsar.broker.service.PersistentTopicE2ETest |
From |
To |
|
Change Variable Type consumer : Consumer<byte[]> to consumer : Consumer<String> in method public testMessageRedelivery() : void in class org.apache.pulsar.broker.service.PersistentTopicE2ETest |
From |
To |
|
Change Variable Type unAckedMsg : Message<byte[]> to unAckedMsg : Message<String> in method public testMessageRedelivery() : void in class org.apache.pulsar.broker.service.PersistentTopicE2ETest |
From |
To |