You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by mm...@apache.org on 2019/05/28 18:48:41 UTC

[pulsar] branch master updated: resolve a null pointer ex (#4378)

This is an automated email from the ASF dual-hosted git repository.

mmerli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 28c5503  resolve a null pointer ex (#4378)
28c5503 is described below

commit 28c5503d7089ada198c271fc41664ee3d546f667
Author: Lay <10...@qq.com>
AuthorDate: Wed May 29 02:48:36 2019 +0800

    resolve a null pointer ex (#4378)
    
    * resolve a nullPointer ex
    
    *  renaming sinks and sources api to be consistent with the rest of Pulsar (#4363)
    
    * Rename sources and sinks CLI to be consistent with rest of Pulsar
    
    * renaming sinks and sources api to be consistent with the rest of Pulsar
    
    * use new interfaces in cmd
    
    * Fix install pip (#4387)
    
    ### Motivation
    There is a problem with the current installation of pip when running the integration tests.
    Therefore, install pip using the officially recommended method.
    
    ### Modifications
    
    Modify the pip installation method, refer to https://pip.pypa.io/en/stable/installing/
---
 .../src/main/java/org/apache/pulsar/client/impl/MessageImpl.java        | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
index 372fb23..aae4e61 100644
--- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
+++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/MessageImpl.java
@@ -330,7 +330,7 @@ public class MessageImpl<T> implements Message<T> {
 
     @Override
     public String getProperty(String name) {
-        return properties.get(name);
+        return this.getProperties().get(name);
     }
 
     public MessageMetadata.Builder getMessageBuilder() {