Project

General

Profile

Statistics
| Revision:

root / src / peer / channels / SenderUDP.java @ 2

History | View | Annotate | Download (804 Bytes)

1
package peer.channels;
2

    
3
import java.io.IOException;
4
import java.net.DatagramPacket;
5
import java.net.DatagramSocket;
6
import java.net.InetAddress;
7
import java.net.SocketException;
8

    
9
/**
10
 * SenderUDP
11
 */
12
public class SenderUDP implements Sender {
13

    
14
        private DatagramSocket socket;
15

    
16
        public SenderUDP() {
17
        }
18

    
19
        @Override
20
        public void send(byte[] message) {
21
                DatagramPacket packet = new DatagramPacket(message, message.length);
22
                try {
23
                        socket.send(packet);
24
                } catch (IOException e) {
25
                        e.printStackTrace();
26
                }
27
        }
28

    
29
        @Override
30
        public void init(InetAddress address, int port) {
31
                try {
32
                        socket = new DatagramSocket(port, address);
33
                } catch (SocketException e) {
34
                        e.printStackTrace();
35
                }
36
        }
37

    
38
        @Override
39
        public void destroy() {
40
                socket.disconnect();
41
        }
42

    
43

    
44

    
45
}