testtools/com/sun/star/comp/bridge/TestComponentMain.java

   1 /*************************************************************************
   2  *
   3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
   4  *
   5  * Copyright 2008 by Sun Microsystems, Inc.
   6  *
   7  * OpenOffice.org - a multi-platform office productivity suite
   8  *
   9  * $RCSfile: TestComponentMain.java,v $
  10  * $Revision: 1.4.22.1 $
  11  *
  12  * This file is part of OpenOffice.org.
  13  *
  14  * OpenOffice.org is free software: you can redistribute it and/or modify
  15  * it under the terms of the GNU Lesser General Public License version 3
  16  * only, as published by the Free Software Foundation.
  17  *
  18  * OpenOffice.org is distributed in the hope that it will be useful,
  19  * but WITHOUT ANY WARRANTY; without even the implied warranty of
  20  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  21  * GNU Lesser General Public License version 3 for more details
  22  * (a copy is included in the LICENSE file that accompanied this code).
  23  *
  24  * You should have received a copy of the GNU Lesser General Public License
  25  * version 3 along with OpenOffice.org.  If not, see
  26  * <http://www.openoffice.org/license.html>
  27  * for a copy of the LGPLv3 License.
  28  *
  29  ************************************************************************/
  30 package com.sun.star.comp.bridge;
  31
  32 import com.sun.star.bridge.XBridge;
  33 import com.sun.star.bridge.XBridgeFactory;
  34 import com.sun.star.bridge.XInstanceProvider;
  35
  36 import com.sun.star.uno.XComponentContext;
  37 import com.sun.star.lang.EventObject;
  38 import com.sun.star.lang.XComponent;
  39 import com.sun.star.lang.XEventListener;
  40 import com.sun.star.lang.XMultiComponentFactory;
  41 import com.sun.star.lang.XMultiServiceFactory;
  42 import com.sun.star.container.XSet;
  43
  44 import com.sun.star.connection.Acceptor;
  45 import com.sun.star.connection.XAcceptor;
  46 import com.sun.star.connection.XConnection;
  47
  48 import com.sun.star.uno.UnoRuntime;
  49
  50 public class TestComponentMain
  51 {
  52
  53     static class InstanceProvider implements XInstanceProvider {
  54         XComponentContext ctx;
  55
  56         public InstanceProvider( XComponentContext ctx )
  57         {
  58             this.ctx = ctx;
  59         }
  60
  61         public Object getInstance( /*IN*/String sInstanceName )
  62             throws com.sun.star.container.NoSuchElementException, com.sun.star.uno.RuntimeException
  63         {
  64             Object o =null;
  65             try
  66             {
  67                 o = ctx.getServiceManager().createInstanceWithContext(
  68                     "com.sun.star.comp.bridge.TestComponent$_TestObject" , ctx );
  69             }
  70             catch( com.sun.star.uno.Exception e )
  71             {
  72                 System.out.println( "error during instantiation" + e );
  73             }
  74             return o;
  75         }
  76     }
  77
  78     static public void main(String args[]) throws Exception, com.sun.star.uno.Exception {
  79         if(args.length != 2)    {
  80             System.err.println("usage : com.sun.star.comp.bridge.TestComponentMain uno:connection;protocol;objectName singleaccept");
  81             System.exit(-1);
  82         }
  83
  84         String conDcp = null;
  85         String protDcp = null;
  86         String rootOid = null;
  87
  88         String dcp = args[0];
  89         boolean singleaccept = args[1].equals("singleaccept");
  90
  91         int index = dcp.indexOf(':');
  92         String url = dcp.substring(0, index).trim();
  93         dcp = dcp.substring(index + 1).trim();
  94
  95         index = dcp.indexOf(';');
  96         conDcp = dcp.substring(0, index).trim();
  97         dcp = dcp.substring(index + 1).trim();
  98
  99         index = dcp.indexOf(';');
 100         protDcp = dcp.substring(0, index).trim();
 101         dcp = dcp.substring(index + 1).trim();
 102
 103         rootOid = dcp.trim().trim();
 104
 105         XComponentContext ctx = com.sun.star.comp.helper.Bootstrap.createInitialComponentContext( null );
 106         XMultiComponentFactory smgr = ctx.getServiceManager();
 107         XMultiServiceFactory oldsmgr =
 108             UnoRuntime.queryInterface( XMultiServiceFactory.class, smgr );
 109
 110         // prepare servicemanager
 111         XSet set = UnoRuntime.queryInterface(XSet.class, smgr);
 112         Object o = com.sun.star.comp.bridge.TestComponent.__getServiceFactory(
 113             "com.sun.star.comp.bridge.TestComponent$_TestObject", oldsmgr,null );
 114         set.insert(o);
 115
 116         XAcceptor xAcceptor = Acceptor.create(ctx);
 117
 118         while( true )
 119         {
 120             System.err.println("waiting for connect...");
 121
 122             XConnection xConnection = xAcceptor.accept(conDcp);
 123
 124             XBridgeFactory xBridgeFactory = UnoRuntime.queryInterface(
 125                 XBridgeFactory.class,
 126                 smgr.createInstanceWithContext("com.sun.star.bridge.BridgeFactory",ctx));
 127
 128             XBridge xBridge = xBridgeFactory.createBridge(
 129                 "", protDcp, xConnection, new InstanceProvider(ctx));
 130
 131             if (singleaccept) {
 132                 Listener listener = new Listener();
 133                 UnoRuntime.queryInterface(XComponent.class, xBridge).
 134                     addEventListener(listener);
 135                 listener.await();
 136                 break;
 137             }
 138         }
 139
 140     }
 141
 142     private static final class Listener implements XEventListener {
 143         public synchronized void disposing(EventObject source) {
 144             done = true;
 145             notifyAll();
 146         }
 147
 148         public synchronized void await() {
 149             while (!done) {
 150                 try {
 151                     wait();
 152                 } catch (InterruptedException e) {
 153                     Thread.currentThread().interrupt();
 154                     throw new RuntimeException(e);
 155                 }
 156             }
 157         }
 158
 159         private boolean done = false;
 160     }
 161 }