Subscription working over LAN but not internet

[CJure]

Expected behavior

I am trying to connect and subscribe to our broker over internet.

Actual behavior

Connection is successful but when new value is sent to broker from another device, subscription callback is not being called. But this works normally if I am in same LAN as broker. I tried different devices and different networks, even cellphone hotspot but if client and broker are not in same LAN, subscription doesn't work. If use other client like Paho it works even outside LAN, so it's not problem in the broker.

Reproducer code

private void openConnection()
    {
        logger.info("openConnection() start");
        try
        {
            client.connectWith()
                    .simpleAuth()
                    .username(ServerConfig.getUser())
                    .password(ServerConfig.getPassword().getBytes())
                    .applySimpleAuth()
                    .send()
                    .whenComplete((connAck, throwable) ->
                    {
                        logger.info("connAck={}" ,connAck);
                        if (throwable != null)
                        {
                            logger.error("connect error");
                            logger.error("couldn't connect to broker={}", throwable);
                        } else
                        {
                            logger.info("mqtt client connected");
                            subscribe();
                        }
                    });
        }
        catch (Exception e)
        {
            logger.error("Exception on openConnection={}", e);
        }
        logger.info("openConnection() end");
    }

private void subscribeToTopic(String topic)
    {
        client.subscribeWith()
                .topicFilter(topic)
                .qos(MqttQos.AT_LEAST_ONCE)
                .noLocal(true)
                .callback(publish ->
                {
                    logger.info("callback messageArrived topic={}", publish.getTopic());
                    float floatValue = Float.parseFloat(new String(publish.getPayloadAsBytes(), StandardCharsets.UTF_8));
                    logger.info("messageArrived topic: {}, value: {}", publish.getTopic(), floatValue);
                    main.onCommandFromScada(topic, floatValue);
                })
                .send()
                .whenComplete((subAck, throwable) ->
                {
                    if (throwable != null)
                    {
                        logger.error("error on subscribe to topic={} error={}", topic, throwable);
                    }
                    else
                    {
                        logger.info("subscribed to topic={}", topic);
                        if(topic.equals(lastSubTopic))
                        {
                            isConnected = true;
                        }
                    }
                });
    }

Details

• Affected HiveMQ MQTT Client version(s):
• 1.3.0
• Used JVM version:
• 8
• Used OS (name and version):
• win 10, Raspberry Pi OS
• Used MQTT version:
• 5
• Used MQTT broker (name and version):
• Mosquito 2.0.11

[CJure]

It was problem in my logic. Variables weren't created yet at subscription step, so it didn't make any subscriptions.