Пытаюсь повесить слушателя очереди с андроид-приложения на ПК java приложение

Что сделано: Написан Producer на java(располагается на ПК):

public class Sender {
    public static final TestMessage testMessage = new TestMessage("HELLO FROM BSM");
    public static final String QUEUE_NAME = "TransientQueue";
    public static final String message = testMessage.getMessage();
    private final static String TASK_QUEUE_NAME = "Task queue test";

    public static void main(String[] args) {


        var factory = new com.rabbitmq.client.ConnectionFactory();
        factory.setHost("localhost");
        try (com.rabbitmq.client.Connection connection = factory.newConnection();
             var channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            int prefetchCount = 1;
            channel.basicQos(prefetchCount);
            channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
            channel.exchangeDeclare("logs", "fanout");// example 3
            System.out.println(" [x] Sent '" + message + "'");
        } catch (IOException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            e.printStackTrace();
        }


    }
}

На android что-то пытался написать как foreground сервис... Но че-то дальше исключений не ушел... Вроде бы банальная задача повесить слушателя на очередь, адреса и порты пробросить и на ПК настроить правила фвола. Но чето не понимаю как написать consumer сторону на андроиде. Подскажите пожалуйста, если кому-то не трудно или сталкивался с подобным... Если понадобится: и устройство и ПК в одной подсети