package Communication.Messages.UDP;

import Communication.Messages.Service.MessageFactory;
import Communication.Messages.Service.StandardReceivingThread;

import java.io.IOException;
import java.lang.ref.WeakReference;
import java.net.DatagramSocket;

public class ReceivingDatagramThread extends StandardReceivingThread
{
    private final WeakReference sock;

    public ReceivingDatagramThread(DatagramSocket sock)
    {
        this.sock = new WeakReference<>(sock);
    }

    @Override
    public void receive() throws IOException
    {
        MessageFactory.getInstance().getSession(this.sock.get()).receive();
    }
}