Source Code Cross Referenced for RelationServiceAdaptor.java in  » J2EE » enhydra » mx4j » examples » tools » adaptor » http » Java Source Code / Java DocumentationJava Source Code and Java Documentation

Java Source Code / Java Documentation
1. 6.0 JDK Core
2. 6.0 JDK Modules
3. 6.0 JDK Modules com.sun
4. 6.0 JDK Modules com.sun.java
5. 6.0 JDK Modules sun
6. 6.0 JDK Platform
7. Ajax
8. Apache Harmony Java SE
9. Aspect oriented
10. Authentication Authorization
11. Blogger System
12. Build
13. Byte Code
14. Cache
15. Chart
16. Chat
17. Code Analyzer
18. Collaboration
19. Content Management System
20. Database Client
21. Database DBMS
22. Database JDBC Connection Pool
23. Database ORM
24. Development
25. EJB Server geronimo
26. EJB Server GlassFish
27. EJB Server JBoss 4.2.1
28. EJB Server resin 3.1.5
29. ERP CRM Financial
30. ESB
31. Forum
32. GIS
33. Graphic Library
34. Groupware
35. HTML Parser
36. IDE
37. IDE Eclipse
38. IDE Netbeans
39. Installer
40. Internationalization Localization
41. Inversion of Control
42. Issue Tracking
43. J2EE
44. JBoss
45. JMS
46. JMX
47. Library
48. Mail Clients
49. Net
50. Parser
51. PDF
52. Portal
53. Profiler
54. Project Management
55. Report
56. RSS RDF
57. Rule Engine
58. Science
59. Scripting
60. Search Engine
61. Security
62. Sevlet Container
63. Source Control
64. Swing Library
65. Template Engine
66. Test Coverage
67. Testing
68. UML
69. Web Crawler
70. Web Framework
71. Web Mail
72. Web Server
73. Web Services
74. Web Services apache cxf 2.0.1
75. Web Services AXIS2
76. Wiki Engine
77. Workflow Engines
78. XML
79. XML UI
Java
Java Tutorial
Java Open Source
Jar File Download
Java Articles
Java Products
Java by API
Photoshop Tutorials
Maya Tutorials
Flash Tutorials
3ds-Max Tutorials
Illustrator Tutorials
GIMP Tutorials
C# / C Sharp
C# / CSharp Tutorial
C# / CSharp Open Source
ASP.Net
ASP.NET Tutorial
JavaScript DHTML
JavaScript Tutorial
JavaScript Reference
HTML / CSS
HTML CSS Reference
C / ANSI-C
C Tutorial
C++
C++ Tutorial
Ruby
PHP
Python
Python Tutorial
Python Open Source
SQL Server / T-SQL
SQL Server / T-SQL Tutorial
Oracle PL / SQL
Oracle PL/SQL Tutorial
PostgreSQL
SQL / MySQL
MySQL Tutorial
VB.Net
VB.Net Tutorial
Flash / Flex / ActionScript
VBA / Excel / Access / Word
XML
XML Tutorial
Microsoft Office PowerPoint 2007 Tutorial
Microsoft Office Excel 2007 Tutorial
Microsoft Office Word 2007 Tutorial
Java Source Code / Java Documentation » J2EE » enhydra » mx4j.examples.tools.adaptor.http 
Source Cross Referenced  Class Diagram Java Document (Java Doc) 


001:        /*
002:         * Copyright (C) The MX4J Contributors.
003:         * All rights reserved.
004:         *
005:         * This software is distributed under the terms of the MX4J License version 1.0.
006:         * See the terms of the MX4J License in the documentation provided with this software.
007:         */
008:        package mx4j.examples.tools.adaptor.http;
009:
010:        import java.io.IOException;
011:        import java.util.ArrayList;
012:        import java.util.Iterator;
013:        import java.util.List;
014:        import java.util.Set;
015:        import javax.management.Attribute;
016:        import javax.management.MBeanServer;
017:        import javax.management.MBeanServerFactory;
018:        import javax.management.MBeanServerInvocationHandler;
019:        import javax.management.ObjectInstance;
020:        import javax.management.ObjectName;
021:        import javax.management.Query;
022:        import javax.management.relation.RelationServiceMBean;
023:        import javax.management.relation.Role;
024:        import javax.management.relation.RoleInfo;
025:        import javax.management.relation.RoleList;
026:        import javax.management.relation.RoleResult;
027:
028:        import mx4j.tools.adaptor.http.DefaultProcessor;
029:        import mx4j.tools.adaptor.http.XSLTProcessor;
030:
031:        /**
032:         * Example as how to use the HttpAdaptor and the XSLTProcessor and the RelationProcessor
033:         * To use this example please add as arguments to the command line in this order <host><port><path to xsl files>
034:         *
035:         * @version $Revision: 1.1 $
036:         */
037:        public class RelationServiceAdaptor {
038:            private MBeanServer m_server = null;
039:            private RelationServiceMBean m_proxy = null;
040:            private mx4j.tools.adaptor.http.HttpAdaptor m_adaptor = null;
041:            private DefaultProcessor m_processor = null;
042:            private XSLTProcessor m_xsltProcessor = null;
043:            private ObjectName httpAdaptorObjectName = null;
044:            private ObjectName processorName = null;
045:            private ObjectName m_relationServiceObjectName = null;
046:
047:            public RelationServiceAdaptor() {
048:                m_server = MBeanServerFactory
049:                        .createMBeanServer("MyAdaptorTests");
050:                m_adaptor = new mx4j.tools.adaptor.http.HttpAdaptor();
051:                m_processor = new DefaultProcessor();
052:                m_xsltProcessor = new XSLTProcessor();
053:            }
054:
055:            public void startTests(String[] args) {
056:                int defaultPort = 1999;
057:                String defaultHost = "localhost";
058:                String defaultPath = ".";
059:                if (args.length > 0) {
060:                    defaultHost = args[0];
061:                }
062:                if (args.length > 1) {
063:                    defaultPort = Integer.parseInt(args[1]);
064:                }
065:                if (args.length > 2) {
066:                    defaultPath = args[2];
067:                }
068:
069:                try {
070:                    System.out
071:                            .println("Building the objectNames and registering the HttpAdaptor, and XSLTProcessor");
072:                    // build object names
073:                    httpAdaptorObjectName = new ObjectName(
074:                            "Server:name=HttpAdaptor");
075:                    processorName = new ObjectName(
076:                            "processor:name=XSLTProcessor");
077:
078:                    // register adaptor in server
079:                    m_server.registerMBean(m_adaptor, httpAdaptorObjectName);
080:                    m_server.registerMBean(m_xsltProcessor, processorName);
081:
082:                    m_server.setAttribute(processorName, new Attribute("File",
083:                            defaultPath));
084:
085:                    m_adaptor.setPort(defaultPort);
086:                    m_adaptor.setHost(defaultHost);
087:                    m_adaptor.setProcessor(m_xsltProcessor);
088:                    m_adaptor.setAuthenticationMethod("none");
089:
090:                    System.out
091:                            .println("------------------------------------------- done --------------------------------------------");
092:
093:                    System.out
094:                            .println("starting the adpator and then checking all is active");
095:                    m_adaptor.start();
096:
097:                    if (m_adaptor.isActive()) {
098:                        System.out.println("Adaptor is active");
099:                        System.out.println("The name of the processor: "
100:                                + m_adaptor.getProcessor().getName());
101:                    }
102:
103:                    System.out
104:                            .println("------------------------------------------- done --------------------------------------------");
105:                    System.out
106:                            .println("Press enter to register relationService");
107:                    waitForEnterPressed();
108:                } catch (Exception ex) {
109:                    ex.printStackTrace();
110:                }
111:            }
112:
113:            public void buildMBeans() {
114:                try {
115:                    System.out
116:                            .println("Building and registering the relationService and 6 MBeans");
117:                    String m_relationServiceClassName = "javax.management.relation.RelationService";
118:                    m_relationServiceObjectName = new ObjectName(
119:                            "relations:type=" + m_relationServiceClassName
120:                                    + "_1");
121:                    Object[] params = { new Boolean(true) };
122:                    String[] signature = { "boolean" };
123:                    m_server.createMBean(m_relationServiceClassName,
124:                            m_relationServiceObjectName, null, params,
125:                            signature);
126:
127:                    // create a proxy
128:                    m_proxy = (RelationServiceMBean) MBeanServerInvocationHandler
129:                            .newProxyInstance(m_server,
130:                                    m_relationServiceObjectName,
131:                                    RelationServiceMBean.class, false);
132:
133:                    System.out.println("Press ENTER to register 6 MBeans");
134:                    waitForEnterPressed();
135:                    String mbeanClassName = "mx4j.examples.tools.adaptor.http.SimpleStandard";
136:                    ObjectName mbeanObjectName1 = new ObjectName(
137:                            "domain:type=SimpleStandard_1");
138:                    ObjectName mbeanObjectName2 = new ObjectName(
139:                            "domain:type=SimpleStandard_2");
140:                    ObjectName mbeanObjectName3 = new ObjectName(
141:                            "domain:type=SimpleStandard_3");
142:                    ObjectName mbeanObjectName4 = new ObjectName(
143:                            "domain:type=SimpleStandard_4");
144:                    ObjectName mbeanObjectName5 = new ObjectName(
145:                            "domain:type=SimpleStandard_5");
146:                    ObjectName mbeanObjectName6 = new ObjectName(
147:                            "domain:type=SimpleStandard_6");
148:
149:                    m_server
150:                            .createMBean(mbeanClassName, mbeanObjectName1, null);
151:                    m_server
152:                            .createMBean(mbeanClassName, mbeanObjectName2, null);
153:                    m_server
154:                            .createMBean(mbeanClassName, mbeanObjectName3, null);
155:                    m_server
156:                            .createMBean(mbeanClassName, mbeanObjectName4, null);
157:                    m_server
158:                            .createMBean(mbeanClassName, mbeanObjectName5, null);
159:                    m_server
160:                            .createMBean(mbeanClassName, mbeanObjectName6, null);
161:                    System.out
162:                            .println("------------------------------------------- done --------------------------------------------");
163:
164:                    System.out.println("Creating RoleInfos for RelationType");
165:                    RoleInfo[] roleInfos = new RoleInfo[2];
166:                    String roleName1 = "primary";
167:                    roleInfos[0] = new RoleInfo(roleName1,
168:                            "mx4j.examples.tools.adaptor.http.SimpleStandard",
169:                            true, true, 1, 1, null);
170:
171:                    String roleName2 = "secondary";
172:                    roleInfos[1] = new RoleInfo(roleName2,
173:                            "mx4j.examples.tools.adaptor.http.SimpleStandard",
174:                            true, true, 0, -1, null);
175:
176:                    // create a relation type with those role infos
177:                    String relationTypeName = "Building_relation_view1";
178:                    m_proxy.createRelationType(relationTypeName, roleInfos);
179:
180:                    // creating more relationTypes to test
181:                    String relationTypeName2 = "Testing_2";
182:                    m_proxy.createRelationType(relationTypeName2, roleInfos);
183:
184:                    System.out
185:                            .println("Creating relationIds for relationTypeName: "
186:                                    + relationTypeName);
187:                    System.out.println("First create the roles...");
188:
189:                    ArrayList roleValue1 = new ArrayList();
190:                    roleValue1.add(mbeanObjectName1);
191:
192:                    Role role1 = new Role(roleName1, roleValue1);
193:
194:                    ArrayList roleValue2 = new ArrayList();
195:                    roleValue2.add(mbeanObjectName2);
196:                    roleValue2.add(mbeanObjectName3);
197:                    roleValue2.add(mbeanObjectName4);
198:
199:                    Role role2 = new Role(roleName2, roleValue2);
200:                    RoleList roleList1 = new RoleList();
201:                    roleList1.add(role1);
202:                    roleList1.add(role2);
203:
204:                    /// testing form here
205:                    ArrayList role5Value = new ArrayList();
206:                    role5Value.add(mbeanObjectName2);
207:
208:                    Role role5 = new Role(roleName1, role5Value);
209:                    ArrayList roleValue5 = new ArrayList();
210:                    roleValue5.add(mbeanObjectName4);
211:
212:                    Role role6 = new Role(roleName2, roleValue5);
213:                    RoleList roleList5 = new RoleList();
214:                    roleList5.add(role5);
215:                    roleList5.add(role6);
216:
217:                    System.out
218:                            .println("------------------------------------------- done --------------------------------------------");
219:                    System.out.println("Now create relations with ids:::");
220:
221:                    String relationId1 = "relationId_1";
222:                    m_proxy.createRelation(relationId1, relationTypeName,
223:                            roleList1);
224:
225:                    String relationId2 = "relationId_2";
226:                    m_proxy.createRelation(relationId2, relationTypeName,
227:                            roleList5);
228:
229:                    String relationId3 = "relationId_3";
230:                    m_proxy.createRelation(relationId3, relationTypeName,
231:                            roleList1);
232:                    System.out
233:                            .println("------------------------------------------- done --------------------------------------------");
234:
235:                    System.out
236:                            .println("creating relationIds for relationtypeName: "
237:                                    + relationTypeName2);
238:
239:                    String relationId4 = "relationId_number2_1";
240:                    m_proxy.createRelation(relationId4, relationTypeName2,
241:                            roleList1);
242:
243:                    String relationId5 = "relationId_number2_2";
244:                    m_proxy.createRelation(relationId5, relationTypeName2,
245:                            roleList1);
246:
247:                    String relationId6 = "relationId_number2_3";
248:                    m_proxy.createRelation(relationId6, relationTypeName2,
249:                            roleList1);
250:                    System.out
251:                            .println("------------------------------------------- done --------------------------------------------");
252:                    waitForEnterPressed();
253:
254:                    System.out
255:                            .println("create a relation MBean and add it in the Relation Service");
256:                    String relMBeanClassName = "mx4j.examples.tools.adaptor.http.SimpleRelationTestSupport";
257:                    String relationId7 = "relationId_relationMBean_1";
258:                    ObjectName relMBeanObjName1 = new ObjectName(
259:                            "relationType:name=RelationTypeSupportInstance");
260:                    m_server.createMBean(relMBeanClassName, relMBeanObjName1,
261:                            null, new Object[] { relationId7,
262:                                    m_relationServiceObjectName,
263:                                    relationTypeName2, roleList1 },
264:                            new String[] { "java.lang.String",
265:                                    "javax.management.ObjectName",
266:                                    "java.lang.String",
267:                                    "javax.management.relation.RoleList" });
268:                    m_proxy.addRelation(relMBeanObjName1);
269:                    System.out
270:                            .println("------------------------------------------- done --------------------------------------------");
271:                    waitForEnterPressed();
272:                    RoleResult result = m_proxy.getAllRoles(relationId1);
273:                    Iterator i = result.getRoles().iterator();
274:                    while (i.hasNext()) {
275:                        Role r = (Role) i.next();
276:                        List l = r.getRoleValue();
277:                        Iterator j = l.iterator();
278:                        while (j.hasNext()) {
279:                            ObjectName objName = (ObjectName) j.next();
280:                            System.out.println("ObjectName: "
281:                                    + objName.getCanonicalName()
282:                                    + " for relationId: " + relationId1);
283:                        }
284:                    }
285:
286:                    RoleResult result2 = m_proxy.getAllRoles(relationId2);
287:                    Iterator i2 = result2.getRoles().iterator();
288:                    while (i2.hasNext()) {
289:                        Role r = (Role) i2.next();
290:                        List l = r.getRoleValue();
291:                        Iterator j = l.iterator();
292:                        while (j.hasNext()) {
293:                            ObjectName objName = (ObjectName) j.next();
294:                            System.out.println("ObjectName: "
295:                                    + objName.getCanonicalName()
296:                                    + " for relationId: " + relationId2);
297:                        }
298:                    }
299:
300:                    System.out.println("getting all relationIds");
301:                    List li = m_proxy.getAllRelationIds();
302:                    System.out.println("allrelationIds list: " + li.toString());
303:
304:                    System.out
305:                            .println("You can view the adaptor at url http://......");
306:                    System.out
307:                            .println(">>>>>>>>>>>>>>>> PRESS ENTER TO END THE DEMO <<<<<<<<<<<<<<<<<<<<");
308:
309:                    waitForEnterPressed();
310:                } catch (Exception ex) {
311:                    ex.printStackTrace();
312:                }
313:            }
314:
315:            public void endTests() {
316:                try {
317:                    m_adaptor.stop();
318:                    Set mbeanSet = m_server.queryMBeans(null, Query
319:                            .initialSubString(Query.classattr(), Query
320:                                    .value("test*")));
321:                    for (Iterator i = mbeanSet.iterator(); i.hasNext();) {
322:                        m_server.unregisterMBean(((ObjectInstance) i.next())
323:                                .getObjectName());
324:                    }
325:                    // release the relationService
326:                    m_server.unregisterMBean(m_relationServiceObjectName);
327:                    m_server.unregisterMBean(processorName);
328:                    m_server.unregisterMBean(httpAdaptorObjectName);
329:                    // release the MBeanServer
330:                    MBeanServerFactory.releaseMBeanServer(m_server);
331:                    System.exit(0);
332:                } catch (Exception ex) {
333:                    ex.printStackTrace();
334:                    System.exit(1);
335:                }
336:            }
337:
338:            public static void main(String[] args) {
339:                RelationServiceAdaptor bnb = new RelationServiceAdaptor();
340:                bnb.startTests(args);
341:                bnb.buildMBeans();
342:                bnb.endTests();
343:            }
344:
345:            private static void waitForEnterPressed() {
346:                try {
347:                    boolean done = false;
348:                    while (!done) {
349:                        char ch = (char) System.in.read();
350:                        if (ch < 0 || ch == '\n') {
351:                            done = true;
352:                        }
353:                    }
354:                } catch (IOException ex) {
355:                    ex.printStackTrace();
356:                }
357:                return;
358:            }
359:        }
www.java2java.com | Contact Us
Copyright 2009 - 12 Demo Source and Support. All rights reserved.
All other trademarks are property of their respective owners.