java - 同じ BlockingConnection オブジェクトを使用して公開および購読する方法

Question

以下のコードを使用して、MQTT にデータを公開およびサブスクライブしようとしています。

try{
    ObjectMapper mapper = new ObjectMapper();
    MqttMessage message2 = new MqttMessage();
    MQTT mqtt_connect = new MQTT();
    mqtt_connect.setHost(Host_Address, Integer.parseInt(port));

    String topic = "/call/publishcall";
    mqtt_connect.setClientId("publishcall");
    mqtt_connect.setWillRetain(false);
    mqtt_connect.isWillRetain();
    mqtt_connect.setWillTopic(topic);                   
    BlockingConnection m_publisher = mqtt_connect.blockingConnection();

    m_publisher.connect();                   
    if(m_publisher.isConnected()){
        System.out.println("connected");                    
        message2.setPayload();

        Object o2 = message2;
        String s2 = o2.toString();
        mqtt_connect.setWillMessage(o2.toString());
        m_publisher.publish(topic, s2.getBytes(), QoS.AT_MOST_ONCE, false);

        Topic [] topics = {new Topic("/call/subscribecall", QoS.AT_MOST_ONCE)};                  
        m_publisher.subscribe(topics);                    
        Message message = m_publisher.receive(20000, TimeUnit.MILLISECONDS);
        byte[] payload = message.getPayload();
        String messageContent = new String(payload);
        System.out.println("Received message from topic: " + message.getTopic() + " Message content: " + messageContent);
        message.ack();
        if(messageContent =="0"){
            //i want to do something based on result 0
        }
        else if(messageContent =="1"){
                    //i want to do something based on result 1
        }
        else
        {
            //i want to do something based on result except 0 or 1
        }

        m_publisher.disconnect();
    }
    else
    {
        System.out.println("not connected");
    }

} catch (Exception e) {
    e.printStackTrace();
    return "failure";
}

しかし、MQTT には問題なくデータを公開できます。トピック名が /call/subscribecall のデータを公開すると、null ポインター例外が発生しますmessage.getPayload();が、サブスクライバーはデータを正しく送信します。

サブスクライバーがデータを送信する代わりに null を取得するのはなぜですか? 購読コードがデータを取得していないようです。

私はどこで間違いをしていますか？