ChatClient/MessageSender.java at master · Zabari/ChatClient · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
/*
 * class MESSAGESENDER
 * Sends messages through socket
*/

// For ObjectInputStream, ObjectOutputStream
importjava.io.*;

publicclassMessageSenderextendsThread {
MessageManager_messageManager;
ObjectOutputStream_out;

publicMessageSender(MessageManagermessageManager, ObjectOutputStreamout) {
_messageManager = messageManager;
_out = out;
 }

publicvoidrun() {
while (true) {
_messageManager.outboxWait();

// We awoke!
MessageoutgoingMsg = _messageManager.getOutboxMessage();
try {
_out.writeObject(outgoingMsg);
 } catch (IOExceptione) {
System.out.println(e);
 }
 }
 }
}