[GitHub] [pulsar] ConcurrencyPractitioner commented on a change in pull request #4127: [Issue#4110] [component/functions] Adding getActualMessage() method

[GitBox <gi...@apache.org>]

ConcurrencyPractitioner commented on a change in pull request #4127: [Issue#4110] [component/functions] Adding getActualMessage() method
URL: https://github.com/apache/pulsar/pull/4127#discussion_r279135715
 
 

 ##########
 File path: pulsar-functions/instance/src/main/java/org/apache/pulsar/functions/instance/ContextImpl.java
 ##########
 @@ -160,6 +161,11 @@ public void setCurrentMessageContext(Record<?> record) {
         this.record = record;
     }
 
+    @Override
+    public Object getCurrentMessage() {
+        return ((PulsarRecord<?>) record).getActualMessage();
 
 Review comment:
   Oh, well, it was ```getActualMessage()``` for PulsarRecord, but in ContextImpl, I think ```getCurrentMessage()``` was proposed to be used instead. I just took the name from what was proposed in the issue, 

----------------------------------------------------------------
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.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


With regards,
Apache Git Services