Examples of ClientInvoker

mx4j.remote.rmi.ClientInvoker
An MBeanServerConnection that "converts" the MBeanServerConnection calls to {@link RMIConnection} calls,performing wrapping of parameters and/or the needed actions. @version $Revision: 1.9 $ @see mx4j.remote.rmi.RMIConnectionInvoker
org.jboss.remoting.transport.ClientInvoker
Interface to be used for calling on all the different invoker types (LocalClientInvoker and RemoteClientInvoker). @author Tom Elrod
org.jboss.resteasy.client.core.ClientInvoker
@author Bill Burke @version $Revision: 1 $
org.jboss.resteasy.client.jaxrs.internal.proxy.ClientInvoker
@author Bill Burke @version $Revision: 1 $
org.switchyard.component.resteasy.util.ClientInvoker
Client Invoker for RESTEasy gateway. Code lifted from RESTEasy. @author Bill Burke @author Magesh Kumar B (C) 2013 Red Hat Inc.

Examples of org.jboss.remoting.transport.ClientInvoker

      
      Client callbackClient1 = serverInvokerCallbackHandler1.getCallbackClient();
      Client callbackClient2 = serverInvokerCallbackHandler2.getCallbackClient();
      assertNotSame(callbackClient1, callbackClient2);
  
      ClientInvoker clientInvoker1 = callbackClient1.getInvoker();
      assertTrue(clientInvoker1 instanceof BisocketClientInvoker);
      ClientInvoker clientInvoker2 = callbackClient2.getInvoker();
      assertTrue(clientInvoker2 instanceof BisocketClientInvoker);
      assertNotSame(clientInvoker1, clientInvoker2);
      
      Field field = MicroSocketClientInvoker.class.getDeclaredField("pool");
      field.setAccessible(true);

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

    * an invocation with an invocation specific timeout has been executed.
    */
   public void testTimeoutReset() throws Throwable
   {
      log.info("entering " + getName());
      ClientInvoker invoker = client.getInvoker();
      assertTrue(invoker instanceof MicroSocketClientInvoker);
      Field field = MicroSocketClientInvoker.class.getDeclaredField("pool");
      field.setAccessible(true);
      List pool = (List) field.get(invoker);
      assertEquals(0, pool.size());

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

      log.info("clients added callback handler");
      
      Iterator it = invocationHandler.callbackHandlers.iterator();
      ServerInvokerCallbackHandler serverInvokerCallbackHandler = (ServerInvokerCallbackHandler) it.next();
      Client callbackClient = serverInvokerCallbackHandler.getCallbackClient();
      ClientInvoker clientInvoker = callbackClient.getInvoker();
      assertTrue(clientInvoker instanceof BisocketClientInvoker);
      
      Field field = MicroSocketClientInvoker.class.getDeclaredField("pool");
      field.setAccessible(true);
      List pool = (List) field.get(clientInvoker);

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

      ServerInvokerCallbackHandler serverInvokerCallbackHandler1 = (ServerInvokerCallbackHandler) it.next();
      ServerInvokerCallbackHandler serverInvokerCallbackHandler2 = (ServerInvokerCallbackHandler) it.next();
      Client callbackClient1 = serverInvokerCallbackHandler1.getCallbackClient();
      Client callbackClient2 = serverInvokerCallbackHandler2.getCallbackClient();
      assertNotSame(callbackClient1, callbackClient2);
      ClientInvoker clientInvoker1 = callbackClient1.getInvoker();
      assertTrue(clientInvoker1 instanceof BisocketClientInvoker);
      ClientInvoker clientInvoker2 = callbackClient2.getInvoker();
      assertTrue(clientInvoker2 instanceof BisocketClientInvoker);
      assertNotSame(clientInvoker1, clientInvoker2);
      
      Field field = MicroSocketClientInvoker.class.getDeclaredField("pool");
      field.setAccessible(true);

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

      ServerInvokerCallbackHandler serverInvokerCallbackHandler1 = (ServerInvokerCallbackHandler) it.next();
      ServerInvokerCallbackHandler serverInvokerCallbackHandler2 = (ServerInvokerCallbackHandler) it.next();
      Client callbackClient1 = serverInvokerCallbackHandler1.getCallbackClient();
      Client callbackClient2 = serverInvokerCallbackHandler2.getCallbackClient();
      assertNotSame(callbackClient1, callbackClient2);
      ClientInvoker clientInvoker1 = callbackClient1.getInvoker();
      assertTrue(clientInvoker1 instanceof BisocketClientInvoker);
      ClientInvoker clientInvoker2 = callbackClient2.getInvoker();
      assertTrue(clientInvoker2 instanceof BisocketClientInvoker);
      assertNotSame(clientInvoker1, clientInvoker2);
      
      Field field = MicroSocketClientInvoker.class.getDeclaredField("pool");
      field.setAccessible(true);

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

      ServerInvokerCallbackHandler serverInvokerCallbackHandler1 = (ServerInvokerCallbackHandler) it.next();
      ServerInvokerCallbackHandler serverInvokerCallbackHandler2 = (ServerInvokerCallbackHandler) it.next();
      Client callbackClient1 = serverInvokerCallbackHandler1.getCallbackClient();
      Client callbackClient2 = serverInvokerCallbackHandler2.getCallbackClient();
      assertNotSame(callbackClient1, callbackClient2);
      ClientInvoker clientInvoker1 = callbackClient1.getInvoker();
      assertTrue(clientInvoker1 instanceof BisocketClientInvoker);
      ClientInvoker clientInvoker2 = callbackClient2.getInvoker();
      assertTrue(clientInvoker2 instanceof BisocketClientInvoker);
      assertNotSame(clientInvoker1, clientInvoker2);
      
      Field field = MicroSocketClientInvoker.class.getDeclaredField("pool");
      field.setAccessible(true);

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

   
   
   private void configureParameters()
   {
      Map config = new HashMap();
      ClientInvoker invoker = client.getInvoker();
      if (invoker != null)
      {
         config.putAll(invoker.getLocator().getParameters());
      }
      config.putAll(client.getConfiguration());
      config.putAll(metadata);
      
      Object val = config.get(Client.USE_ALL_PARAMS);

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

   public static boolean checkConnection(InvokerLocator locator, Map config) throws Throwable
   {
      boolean pingWorked = false;
      Map configMap = createPingConfig(config, null);
      int pingTimeout = Integer.parseInt((String) configMap.get(ServerInvoker.TIMEOUT));
      ClientInvoker innerClientInvoker = null;


      try
      {
         innerClientInvoker = InvokerRegistry.createClientInvoker(locator, configMap);


         if (!innerClientInvoker.isConnected())
         {
            if (trace) { log.trace("inner client invoker not connected, connecting ..."); }
            innerClientInvoker.connect();
         }


         pingWorked = doCheckConnection(innerClientInvoker, pingTimeout);
      }
      catch (Throwable throwable)
      {
            log.debug("ConnectionValidator unable to connect to server " +
            innerClientInvoker.getLocator().getProtocol() + "://" +
            innerClientInvoker.getLocator().getHost() + ":" +
            innerClientInvoker.getLocator().getPort(), throwable);
      }
      finally
      {
         if (innerClientInvoker != null)
         {

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

         getParametersFromMap(client.getInvoker().getLocator().getParameters());
      }
      getParametersFromMap(client.getConfiguration());
      getParametersFromMap(metadata);
      
      ClientInvoker clientInvoker = client.getInvoker();
      if (clientInvoker instanceof MicroRemoteClientInvoker)
      {
         sharedInvoker = (MicroRemoteClientInvoker) clientInvoker;
         invokerSessionId = sharedInvoker.getSessionId();
      }

View Full Code Here

Examples of org.jboss.remoting.transport.ClientInvoker

            {
               log.warn(this + " could not convert " + STOP_LEASE_ON_FAILURE + " value" +
               " to a boolean: must be a String");
            }
         }
         ClientInvoker invoker = client.getInvoker();
         if (invoker == null)
         {
            if (trace) log.trace(this + " client invoker == null");
         }
         else
         {
            if (trace) log.trace(this + " InvokerLocator: " + invoker.getLocator());
         }
         o = config.get(FAILURE_DISCONNECT_TIMEOUT);
         if (trace) log.trace(this + " \"failureDisconnectTimeout\" set to " + o);
         if (o != null)
         {

View Full Code Here

0 1 2 3 4 5

TOP

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.