juddi-examples/more-uddi-samples/src/main/java/org/apache/juddi/samples/EntryPoitMultiNode.java

/*
 * Copyright 2015 The Apache Software Foundation.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.juddi.samples;

import java.util.List;
import org.apache.juddi.api_v3.Node;
import org.apache.juddi.v3.client.UDDIConstants;
import org.apache.juddi.v3.client.config.UDDIClient;
import org.uddi.api_v3.BusinessList;
import org.uddi.api_v3.FindBusiness;
import org.uddi.api_v3.FindQualifiers;
import org.uddi.api_v3.FindService;
import org.uddi.api_v3.FindTModel;
import org.uddi.api_v3.Name;
import org.uddi.api_v3.ServiceList;
import org.uddi.api_v3.TModelList;
import org.uddi.v3_service.UDDIInquiryPortType;

/**
 *
 * @author alex
 */
public class EntryPoitMultiNode {

        static void goMultiNode() throws Exception {
               
                UDDIClient clerkManager = new UDDIClient("META-INF/simple-publish-uddi.xml");

               
                String input = null;
                do {
                        System.out.println("1) Sets undirected replication two instances of jUDDI");
                        System.out.println("2) Sets undirected replication 3 instances of jUDDI");
                        System.out.println("3) Sets directed replication between 3 instances of jUDDI");
                        System.out.println("4) Prints the replication status for all nodes");
                        System.out.println("5) Prints the business, service, and tmodels counts");
                        System.out.println("6) Ping all nodes");

                        System.out.println("q) quit");
                        System.out.print("Selection: ");
                        input = System.console().readLine();

                        processInput(input, clerkManager);

                } while (!input.equalsIgnoreCase("q"));
        }

        private static void processInput(String input, UDDIClient clerkManager) throws Exception {
                if (input.equals("1")) {

                        new JuddiAdminService(clerkManager, null).autoMagic();
                        List<Node> uddiNodeList = clerkManager.getClientConfig().getUDDINodeList();
                        for (int i = 0; i < uddiNodeList.size(); i++) {
                                new UddiCreatebulk(uddiNodeList.get(i).getName()).publishBusiness(null, 1, 1, "root@" + uddiNodeList.get(i).getName());
                        }
                        //new UddiCreatebulk("uddi:another.juddi.apache.org:node2").publishBusiness(null, 1, 1);
                } else if (input.equals("2")) {

                        new JuddiAdminService(clerkManager, null).autoMagic3();
                        List<Node> uddiNodeList = clerkManager.getClientConfig().getUDDINodeList();
                        for (int i = 0; i < uddiNodeList.size(); i++) {
                                new UddiCreatebulk(uddiNodeList.get(i).getName()).publishBusiness(null, 1, 1, "root@" + uddiNodeList.get(i).getName());
                        }
                        //new UddiCreatebulk("uddi:another.juddi.apache.org:node2").publishBusiness(null, 1, 1);
                } else if (input.equals("3")) {
                        new JuddiAdminService(clerkManager, null).autoMagicDirected();

                        List<Node> uddiNodeList = clerkManager.getClientConfig().getUDDINodeList();
                        for (int i = 0; i < uddiNodeList.size(); i++) {
                                new UddiCreatebulk(uddiNodeList.get(i).getName()).publishBusiness(null, 1, 1, "root@" + uddiNodeList.get(i).getName());
                        }
                } else if (input.equals("4")) {
                        new JuddiAdminService(clerkManager, null).printStatus();
                } else if (input.equals("5")) {
                        List<Node> uddiNodeList = clerkManager.getClientConfig().getUDDINodeList();
                        for (Node n : uddiNodeList) {
                                UDDIInquiryPortType uddiInquiryService = clerkManager.getTransport(n.getName()).getUDDIInquiryService();

                                FindBusiness fb = new FindBusiness();

                                fb.getName().add(new Name(UDDIConstants.WILDCARD, null));
                                fb.setFindQualifiers(new FindQualifiers());
                                fb.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH);
                                fb.setMaxRows(1);
                                fb.setListHead(0);
                                BusinessList findBusiness = uddiInquiryService.findBusiness(fb);
                                System.out.println(n.getName() + " business count "
                                        + findBusiness.getListDescription().getActualCount());
                                FindService fs = new FindService();

                                fs.getName().add(new Name(UDDIConstants.WILDCARD, null));
                                fs.setFindQualifiers(new FindQualifiers());
                                fs.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH);
                                fs.setMaxRows(1);
                                fs.setListHead(0);
                                ServiceList findService = uddiInquiryService.findService(fs);
                                System.out.println(n.getName() + " service count "
                                        + findService.getListDescription().getActualCount());

                                FindTModel ft = new FindTModel();
                                ft.setName(new Name(UDDIConstants.WILDCARD, null));
                                ft.setFindQualifiers(new FindQualifiers());
                                ft.getFindQualifiers().getFindQualifier().add(UDDIConstants.APPROXIMATE_MATCH);
                                ft.setMaxRows(1);
                                ft.setListHead(0);
                                TModelList findTModel = uddiInquiryService.findTModel(ft);
                                System.out.println(n.getName() + " tModel count "
                                        + findTModel.getListDescription().getActualCount());

                        }
                        System.out.println();
                } else if (input.equals("6")) {
                        new JuddiAdminService(clerkManager, null).pingAll();
                }

        }

}