sdis1819-t7g02 / protocols / SendSoredMessageProtocol.java
History | View | Annotate | Download (498 Bytes)
1 |
package protocols; |
---|---|
2 |
|
3 |
import channels.MessageHeader; |
4 |
import service.Cloud; |
5 |
|
6 |
public class SendSoredMessageProtocol extends Thread { |
7 |
MessageHeader messageToSend; |
8 |
Cloud cloud; |
9 |
|
10 |
public SendSoredMessageProtocol(MessageHeader toSend, Cloud c) {
|
11 |
messageToSend = toSend; |
12 |
cloud = c; |
13 |
} |
14 |
|
15 |
@Override
|
16 |
public void run() { |
17 |
try {
|
18 |
cloud.controlRoom.waitRandomTime(); |
19 |
cloud.controlRoom.sendHeader(messageToSend); |
20 |
} catch (InterruptedException e) { |
21 |
System.out.println(e.getMessage());
|
22 |
} |
23 |
} |
24 |
} |