ChatClient/Chat.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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}
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
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
/*
 * class CHAT
 * Command center of program
*/

// For Socket
importjava.net.*;

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

importjavax.swing.SwingWorker;

publicclassChat {

privateGUI_gui; // Interface
privateConnection_connection;
privateMessageManager_messageManager;

privateThread_messageSender;
privateThread_messageReceiver;
privateSwingWorker_messageDisplayer;


publicvoidstart() {
createMessageQueue();
createGUI();
establishConnection();
spawnThreads();
 }

publicvoidcreateGUI() {
_gui = newGUI(_messageManager);
 }

publicvoidcreateMessageQueue() {
_messageManager = newMessageManager();
 }

publicvoidestablishConnection() {
_connection = newConnection(this);
_messageManager.setConnection(_connection);
 }

// Called by Connection.java
publicvoidcreateThreads(ObjectOutputStreamoutStream, ObjectInputStreaminStream) {
_messageSender = newMessageSender(_messageManager, outStream);
_messageReceiver = newMessageReceiver(_messageManager, inStream);
_messageDisplayer = newMessageDisplayer(_messageManager, _gui);
 }

publicvoidspawnThreads() {
_messageSender.start();
_messageReceiver.start();
_messageDisplayer.execute();
 }

publicstaticvoidmain(String[] args) {
Chatsession = newChat();
session.start();
 }
}