Project

General

Profile

Statistics
| Revision:

root / threads / SendMessage.java @ 15

History | View | Annotate | Download (771 Bytes)

1
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
}