1
package findEjb;
2
3
import java.util.Iterator;
4
import java.util.Properties;
5
import java.util.Set;
6
7
import javax.management.ObjectInstance;
8
import javax.management.ObjectName;
9
import javax.naming.Context;
10
import javax.naming.InitialContext;
11
import javax.naming.NameClassPair;
12
import javax.naming.NamingEnumeration;
13
14
import org.jboss.jmx.adaptor.rmi.RMIAdaptor;
15
16
public class FindEjb {
17
18
/**
19
* @param args
20
*/
21
@SuppressWarnings("unchecked")
22
public static void main(String[] args) throws Throwable {
23
24
25
// try {
26
// Class c = Class.forName("java.util.ArrayList");
27
// Method m[] = c.getDeclaredMethods();
28
// for (int i = 0; i < m.length; i++)
29
// System.out.println(m[i].toString());
30
// } catch (Throwable e) {
31
// System.err.println(e);
32
// }
33
34
// TODO Auto-generated method stub
35
Properties props = new Properties();
36
props.setProperty(Context.INITIAL_CONTEXT_FACTORY,
37
"org.jnp.interfaces.NamingContextFactory");
38
props.setProperty(Context.PROVIDER_URL, "192.168.1.83:1099");
39
props.setProperty(Context.URL_PKG_PREFIXES,
40
"org.jboss.naming:org.jnp.interfaces");
41
InitialContext ctx = new InitialContext(props);
42
43
NamingEnumeration<NameClassPair> allNameClass = ctx.list("");
44
45
while(allNameClass.hasMoreElements()) {
46
NameClassPair nameClassPair = allNameClass.nextElement();
47
System.out.println(nameClassPair.getName() );
48
}
49
50
RMIAdaptor obj = (RMIAdaptor)ctx.lookup("jmx/rmi/RMIAdaptor");
51
52
53
Set<ObjectInstance> sets = obj.queryMBeans(null, null);
54
Iterator<ObjectInstance> iterator = sets.iterator();
55
while(iterator.hasNext()) {
56
System.out.println(iterator.next().getObjectName());
57
}
58
59
obj.createMBean("org.jboss.deployment.MainDeployer", new ObjectName("11111"));
60
61
System.out.println();
62
// final JmsTestInterface searchInterface = (JmsTestInterface) ctx
63
// .lookup("JmsTestEjb/remote");
64
65
// /System.out.println(searchInterface.getMessageSize());
66
// searchInterface.setMaxJmsQueueSize(10L);
67
// for (int index =0;index< 10; index ++) {
68
// // searchInterface.sendMessage("");
69
// }
70
// System.out.println(searchInterface.receiveMessage("").toString());
71
// searchInterface.createNewQueue("liuQueue2");
72
// for (int index =0;index< 10; index ++) {
73
// searchInterface.sendMessageWithNoRemove();
74
// }
75
// searchInterface.testRemoveEntity();
76
77
78
// searchInterface.sendMessage(null, "message ");
79
80
// ExecutorService service = Executors.newFixedThreadPool(100);
81
// service.execute(new Runnable() {
82
// @Override
83
// public void run() {
84
// try {
85
// for (int i =0;i<100;i++) {
86
// System.out.println("begin to send message by thread " + Thread.currentThread().getName());
87
// searchInterface.sendMessage(null, "message " + i);
88
// System.out.println("end send message by thread " + Thread.currentThread().getName());
89
// try {
90
// Thread.sleep(500);
91
// } catch (InterruptedException e) {
92
// }
93
// }
94
// } catch (Throwable e) {
95
// e.printStackTrace();
96
// }
97
// }
98
// });
99
// service.shutdown();
100
101
102
103
104
}
105
106
// class insertMessageTask implements Runnable {
107
// private JmsTestInterface searchInterface;
108
// public insertMessageTask(JmsTestInterface searchInterface) {
109
// this.searchInterface = searchInterface;
110
// }
111
//
112
// @Override
113
// public void run() {
114
// // TODO Auto-generated method stub
115
//
116
//
117
//
118
// }
119
// }
120
}
121

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

70

71

72

73

74

75

76

77

78

79

80

81

82

83

84

85

86

87

88

89

90

91

92

93

94

95

96

97

98

99

100

101

102

103

104

105

106

107

108

109

110

111

112

113

114

115

116

117

118

119

120

121
