Btukfyl

my problem is that I need to put a message in a rabbitmq broker. I have seen many examples of github and they do not satisfy my case. Let's go to the problem, I think to connect in rabbitmq I need to make a thread (every time I do this without threads it does not work) and the vars I assign inside a thread do not go out, because of this my basicPublish does not work. Can someone help me?

code:

public class MainActivity extends AppCompatActivity {

    Connection connection = null;

    Channel ch = null;

    ConnectionFactory factory = new ConnectionFactory();



    @Override

    protected void onCreate(Bundle savedInstanceState)

    {

        super.onCreate(savedInstanceState);

        setContentView(R.layout.activity_main);

        setupConnectionFactory();

        publishToAMQP();

        setupPubButton();

    }

    void setupPubButton() {

        Button button = (Button) findViewById(R.id.publish);

        button.setOnClickListener(new OnClickListener() {

            @Override

            public void onClick(View arg0) {

                EditText et = (EditText) findViewById(R.id.text);

                publishMessage(et.getText().toString());

                et.setText("");

            }

        });

    }



    public void setupConnectionFactory() {

        try {

            factory.setUsername("guest");

            factory.setPassword("guest");

            factory.setVirtualHost("/");

            factory.setHost("localhost");

            factory.setPort(5672);

            Log.d("","foi");

        }

        catch(Exception e){

            Log.d("IOAJSOIUA", e.getMessage());

        }

    }



    public void publishToAMQP()

    {

        Thread connectChannel = new Thread(new Runnable() {

            @Override

            public void run() {

                try {

                    connection = factory.newConnection();

                    ch = connection.createChannel();

                    ch.queueDeclare("chat", false, false, false, null);

                    ch.exchangeDeclare("amq.topic", "topic",true);

                    ch.queueBind("amq.topic", "chat", null);

                    Log.d("", "isso");

                } catch (Exception e) {

                    Log.d("", "Connection broken: " + e.getClass().getName());

                }

            }

        });

        connectChannel.start();

    }



    void publishMessage(String message) {

        Thread publishMessage = new Thread(new Runnable() {

            @Override

            public void run() {

                try {

                    ch.basicPublish("amq.topic", "chat", null, message.getBytes());

                } catch (IOException e) {

                    e.printStackTrace();

                }

            }

        });

        publishMessage.start();

    }

}

error:

E/AndroidRuntime: FATAL EXCEPTION: Thread-4

    Process: com.example.youssef.chatbot, PID: 11432

    java.lang.NullPointerException: Attempt to invoke interface method 'void com.rabbitmq.client.Channel.basicPublish(java.lang.String, java.lang.String, com.rabbitmq.client.AMQP$BasicProperties, byte)' on a null object reference

        at com.example.youssef.chatbot.Activities.Activities.MainActivity$3.run(MainActivity.java:89)

        at java.lang.Thread.run(Thread.java:764)