Examples of ProxyManager


Examples of com.hazelcast.client.spi.ProxyManager

                    .build();
        } catch (Exception e) {
            throw ExceptionUtil.rethrow(e);
        }
        serializationService = (SerializationServiceImpl) ss;
        proxyManager = new ProxyManager(this);
        executionService = new ClientExecutionServiceImpl(instanceName, threadGroup,
                Thread.currentThread().getContextClassLoader(), config.getExecutorPoolSize());
        transactionManager = new ClientTransactionManager(this);
        LoadBalancer lb = config.getLoadBalancer();
        if (lb == null) {
View Full Code Here

Examples of com.salesforce.ide.core.internal.preferences.proxy.ProxyManager

            public void widgetSelected(SelectionEvent e) {
                widgetDefaultSelected(e);
            }

            public void widgetDefaultSelected(SelectionEvent e) {
                ProxyManager proxyManager = PreferenceManager.getInstance().getProxyManager();
                PreferenceDialog dialog = null;
                if (proxyManager != null && proxyManager.isCoreNetAvailable()) {
                    dialog =
                            PreferencesUtil.createPreferenceDialogOn(getShell(), Constants.PROXY_PREFERENCE_3_2_X,
                                null, null);
                } else {
                    logger.warn("'" + Constants.PROXY_PREFERENCE_3_2_X + "' preference page not found, opening '"
View Full Code Here

Examples of com.volantis.shared.net.proxy.ProxyManager

        Proxy replaced = null;
        if (proxy != null) {
            replaced = (Proxy)proxies.put(proxy.getId(), proxy);

            // Create a ProxyManagerAdapter around an old style Proxy.
            ProxyManager manager = new ProxyManagerAdapter(proxy);

            // Store the manager with the specified id.
            proxyManagers.put(proxy.getId(), manager);
        }
View Full Code Here

Examples of org.apache.aries.proxy.ProxyManager

            List<Object> paths = getBlueprintPaths(bundle);
            if (paths == null) {
                // This bundle is not a blueprint bundle, so ignore it
                return false;
            }
            ProxyManager pm = proxyManager.getService();
            if (pm == null) {
                // The pm isn't available.  It may be because it is being untracked
                return false;
            }
            BundleContext bundleContext = bundle.getBundleContext();
View Full Code Here

Examples of org.apache.aries.proxy.ProxyManager

    registerService(service);
  }
 
  private void registerProxyManager()
  {
    ProxyManager mgr = Skeleton.newMock(ProxyManager.class);
   
    //   public Object createProxy(Bundle clientBundle, Collection<Class<?>> classes, Callable<Object> dispatcher) throws UnableToProxyException;

    Skeleton.getSkeleton(mgr).registerMethodCallHandler(new MethodCall(ProxyManager.class, "createProxy", Bundle.class, Collection.class, Callable.class),
        new MethodCallHandler()
View Full Code Here

Examples of org.apache.aries.proxy.ProxyManager

    // are enabling a slightly odd use case anyway.

    Bundle serviceProviderBundle = pair.ref.getBundle();
    Bundle owningBundle = ctx.getBundle();

    ProxyManager proxyManager = Activator.getProxyManager();

    for (String interfaceName : interfaces) {
      try {
        Class<?> potentialClass = serviceProviderBundle.loadClass(interfaceName);
        if (pair.ref.isAssignableTo(owningBundle, interfaceName)) {
          clazz.add(potentialClass);
        }
      } catch (ClassNotFoundException e) {
      }
    }

    if (clazz.isEmpty()) {
      throw new IllegalArgumentException(Arrays.asList(interfaces).toString());
    }

    Callable<Object> ih = new JNDIServiceDamper(ctx, interface1, filter, pair, dynamicRebind, timeout);

    // The ClassLoader needs to be able to load the service interface
    // classes so it needs to be
    // wrapping the service provider bundle. The class is actually defined
    // on this adapter.

    try {
      return proxyManager.createProxy(serviceProviderBundle, clazz, ih);
    } catch (UnableToProxyException e) {
      throw new IllegalArgumentException(e);
    } catch (RuntimeException e) {
      throw new IllegalArgumentException("Unable to create proxy for " + pair.ref, e);
    }
View Full Code Here

Examples of org.apache.avalon.fortress.impl.factory.ProxyManager

     */
    protected ProxyManager getProxyManager() throws Exception
    {
        if ( null == m_proxyManager )
        {
            m_proxyManager = new ProxyManager( ProxyManager.DISCOVER );
        }

        return m_proxyManager;
    }
View Full Code Here

Examples of org.apache.geronimo.kernel.proxy.ProxyManager

    /**
     * Get a list of containers for this web implementation.
     */
    public Object[] getContainers() {
        ProxyManager proxyManager = kernel.getProxyManager();
        AbstractNameQuery query = new AbstractNameQuery(JettyContainer.class.getName());
        Set names = kernel.listGBeans(query);
        JettyContainer[] results = new JettyContainer[names.size()];
        int i = 0;
        for (Iterator it = names.iterator(); it.hasNext(); i++) {
            AbstractName name = (AbstractName) it.next();
            results[i] = (JettyContainer) proxyManager.createProxy(name, JettyContainer.class.getClassLoader());
        }
        return results;
    }
View Full Code Here

Examples of org.apache.geronimo.kernel.proxy.ProxyManager

    public Object[] getGBeansImplementing(Class iface) {
        Set set = kernel.listGBeans(new AbstractNameQuery(iface.getName()));
        Object[] result = (Object[]) Array.newInstance(iface, set.size());
        int index = 0;
        ProxyManager mgr = kernel.getProxyManager();
        for (Iterator it = set.iterator(); it.hasNext();) {
            AbstractName name = (AbstractName) it.next();
            result[index++] = mgr.createProxy(name, iface);
        }
        return result;
    }   
View Full Code Here

Examples of org.apache.geronimo.kernel.proxy.ProxyManager

    public NetworkConnector[] getConnectors(String protocol) {
        if (protocol == null) {
            return getConnectors();
        }
        List result = new ArrayList();
        ProxyManager proxyManager = kernel.getProxyManager();
        AbstractNameQuery query = new AbstractNameQuery(JettyWebConnector.class.getName());
        Set names = kernel.listGBeans(query);
        for (Iterator it = names.iterator(); it.hasNext();) {
            AbstractName name = (AbstractName) it.next();
            try {
                if (kernel.getAttribute(name, "protocol").equals(protocol)) {
                    result.add(proxyManager.createProxy(name, JettyWebConnector.class.getClassLoader()));
                }
            } catch (Exception e) {
                log.error("Unable to check the protocol for a connector", e);
            }
        }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.