Project

General

Profile

Statistics
| Revision:

root / threads / SendMessage.java @ 15

History | View | Annotate | Download (771 Bytes)

1 15 up20160473
package threads;
2
3
import java.io.IOException;
4
import server.Server;
5
import multicastchannels.*;
6
7
public class SendMessage implements Runnable {
8
        private byte[] message;
9
        private String channel;
10
11
        public SendMessage(byte[] message, String channel) {
12
                this.message = message;
13
                this.channel = channel;
14
15
        }
16
17
        @Override
18
        public void run() {
19
                switch (channel) {
20
21
                case "mc":
22
                        try {
23
                                Server.getmc().sendMessage(message);
24
                        } catch (IOException e) {
25
                                e.printStackTrace();
26
                        }
27
                        break;
28
29
                case "mdb":
30
                        try {
31
                                Server.getmdb().sendMessage(message);
32
                        } catch (IOException e) {
33
                                e.printStackTrace();
34
                        }
35
                        break;
36
37
                case "mdr":
38
                        try {
39
                                Server.getmdr().sendMessage(message);
40
                        } catch (IOException e) {
41
                                e.printStackTrace();
42
                        }
43
                        break;
44
45
                }
46
        }
47
}