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