FilesExpand file tree

 master

/

Client.java

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

69 lines (61 loc) · 1.8 KB

 master

/

Client.java

Copy path

Top

File metadata and controls

• Code
• Blame

69 lines (61 loc) · 1.8 KB

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

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

63

64

65

66

67

68

69

import chat.*;

import java.io.*;

import org.omg.CORBA.*;

import org.omg.PortableServer.*;

import org.omg.CosNaming.*;

public class Client implements Runnable {

public void run() {

try {

// getting reference to POA

org.omg.CORBA.Object obj =

orb.resolve_initial_references("RootPOA");

POA rootpoa = POAHelper.narrow(obj);

// getting reference to POA manager

POAManager manager = rootpoa.the_POAManager();

// activating manager

manager.activate();

orb.run();

} catch (Exception e) {}

}

protected static ORB orb;

public static void main(String args[]) {

try {

// initializing ORB

orb = ORB.init(args,null);

// getting NameService

org.omg.CORBA.Object obj =

orb.resolve_initial_references("NameService");

NamingContextExt ncRef =

org.omg.CosNaming.NamingContextExtHelper.narrow(obj);

// resolving servant name

obj = ncRef.resolve_str("chatserver_yzioaw");

ChatServer chatserver = ChatServerHelper.narrow(obj);

// creating servant

ChatClientImpl cc = new ChatClientImpl();

// connecting servant to ORB

ChatClient chatclient = cc._this(orb);

Thread t = new Thread(new Client());

String id = chatserver.subscribe("test", chatclient);

try {

System.out.println("Connected with ID " + id);

System.out.println("Type /quit to exit");

t.start();

BufferedReader br =

new BufferedReader(new InputStreamReader(System.in));

while (true) {

String s = br.readLine();

if (s.equals("/quit")) break;

chatserver.comment(id, s);

}

} finally {

System.out.print("Unsubscribing...");

chatserver.unsubscribe(id);

System.out.println(" done");

orb.destroy();

t.join();

}

} catch(Exception e) {

e.printStackTrace(System.out);

}

}

}