ReceiveThread

package com.example.testinger;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

public class ReceiveThread extends Thread{

    Integer counter;
    DatagramSocket serverSocket;
    boolean isRunning;
    byte[] receiveData = new byte[50];
    DatagramPacket receivePacket;

    public ReceiveThread(Integer counter, DatagramSocket sock) throws SocketException {
        super();
        this.counter = counter;
        serverSocket = sock;
    }

    public ReceiveThread() {
        super();
    }



    @Override
    public void run() {

        while (isRunning) {

            try {

                System.out.println("received started");
                counter++;
                    receivePacket = new DatagramPacket(receiveData, receiveData.length);
                    serverSocket.receive(receivePacket);

                    System.out.println("droid received: "+new String(receivePacket.getData()));

            } catch (IOException e) {
                e.printStackTrace();
            }

        }
    }

    public void startReceiving(){
        isRunning=true;

        setPriority(NORM_PRIORITY);
        start();
    }

    public void stopReceiving(){
        isRunning=false;

        setPriority(MIN_PRIORITY);
    }

}