Package org.jboss.remoting.invocation

Examples of org.jboss.remoting.invocation.NameBasedInvocation

113
114
115
116
117
118
119
120
121
122
123
        String[] paramSig = new String[paramTypes.length];
        for (int x = 0; x < paramTypes.length; x++) {
            paramSig[x] = paramTypes[x].getName();
        }

        NameBasedInvocation request = new NameBasedInvocation(methodSig, parameters, paramSig);

        Object response = getRemotingClient().invoke(request);

        if (response instanceof Throwable) {
            throw (Throwable) response;
View Full Code Here
268
269
270
271
272
273
274
275
276
277
278
        }

        RemoteInputStreamCommandResponse response;
        RemoteInputStreamCommand cmd = new RemoteInputStreamCommand();

        cmd.setNameBasedInvocation(new NameBasedInvocation(method, args));
        cmd.setStreamId(m_streamId);

        try {
            response = new RemoteInputStreamCommandResponse(m_sender.sendSynch(cmd));
        } catch (Exception e) {
View Full Code Here
203
204
205
206
207
208
209
210
211
212
213
        }

        RemoteOutputStreamCommandResponse response;
        RemoteOutputStreamCommand cmd = new RemoteOutputStreamCommand();

        cmd.setNameBasedInvocation(new NameBasedInvocation(method, args));
        cmd.setStreamId(m_streamId);

        try {
            response = new RemoteOutputStreamCommandResponse(m_sender.sendSynch(cmd));
        } catch (Exception e) {
View Full Code Here
360
361
362
363
364
365
366
367
368
369
370
                        {
                           log.trace("sending notification queue [" + nq + "] to client [" + locator + "] with sessionId [" + sessionId + "], counter=" + counter + " ,count=" + count);
                        }
                        lastTx = System.currentTimeMillis();
                        client.setSessionId(localServerId);
                        client.invoke(new NameBasedInvocation("$NOTIFICATIONS$",
                                                              new Object[]{nq},
                                                              new String[]{NotificationQueue.class.getName()}),
                                      null);
                     }
                     catch(Throwable t)
View Full Code Here
227
228
229
230
231
232
233
234
      listeners.add(key);
      Object a[] = new Object[]{args[0], null, args[2], key};

      // make sure we pass our local id as session id
      client.setSessionId(serverId);
      client.invoke(new NameBasedInvocation(methodName, a, sig),
                    payload);
   }
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
      Object a[] = new Object[]{args[0], null, id};
      if(cl != null)
      {
         // make sure we pass our local id as session id
         client.setSessionId(serverId);
         client.invoke(new NameBasedInvocation(methodName,
                                               a,
                                               new String[]{ObjectName.class.getName(),
                                                            sig[1],
                                                            Integer.class.getName()}),
                       payload);
View Full Code Here
303
304
305
306
307
308
309
310
311
312
313
      Object value = null;
      try
      {
         // make sure we pass our local id as session id
         client.setSessionId(serverId);
         value = client.invoke(new NameBasedInvocation(methodName, args, sig),
                               payload);
      }
      catch(Throwable throwable)
      {
         if(log.isTraceEnabled())
View Full Code Here
454
455
456
457
458
459
460
461
462
463
464
            {
               Map payload = new HashMap(1);
               // transport the special method that will just return null, but will also return
               // the notification queue for the session in the payload
               client.setSessionId(serverId);
               Boolean continuePolling = (Boolean) client.invoke(new NameBasedInvocation("$GetNotifications$",
                                                                                         new Object[]{},
                                                                                         new String[]{}),
                                                                 payload);
               NotificationQueue queue = (NotificationQueue) payload.get("notifications");
               if(queue != null && queue.isEmpty() == false)
View Full Code Here
172
173
174
175
176
177
178
179
180
181
182
183
184
185
      {
         throw new IllegalStateException("invoke called prior to mbean server being set");
      }
      try
      {
         NameBasedInvocation nbi = (NameBasedInvocation) invocation.getParameter();
         String methodName = nbi.getMethodName();
         Object args [] = nbi.getParameters();
         String signature [] = nbi.getSignature();
         String sessionId = invocation.getSessionId();

         // this method is called by a polling client for notifications
         if(methodName.equals("$GetNotifications$"))  //FIXME- JGH: make this a little better
         {
View Full Code Here
221
222
223
224
225
226
227
228
229
230
231
   public Object invoke(Object proxy, Method method, Object[] args) throws Throwable
   {
      String methodName = method.getName();
      String[] paramSig = createParamSignature(method.getParameterTypes());

      NameBasedInvocation request = new NameBasedInvocation(methodName,
                                                            args,
                                                            paramSig);
      Object response = null;

      boolean failOver = false;
View Full Code Here
TOP

Related Classes of org.jboss.remoting.invocation.NameBasedInvocation

  • org.jboss.mx.remoting.JMXSubsystemInvocationHandler
  • org.jboss.mx.remoting.MBeanNotificationCache$Listener$BiDirectionClientNotificationSender
  • org.jboss.mx.remoting.MBeanServerClientInvokerProxy
  • org.jboss.mx.remoting.MBeanServerClientInvokerProxy$NotificationPoller
  • org.jboss.remoting.transporter.TransporterClient
  • org.jboss.remoting.transporter.TransporterHandler
  • org.jboss.test.remoting.byvalue.ByValueInvocationTestCase
  • org.jboss.test.remoting.classloader.InvokerClientTest
  • org.jboss.test.remoting.exception.cannotconnect.http.CannotConnectTestCase
  • org.jboss.test.remoting.exception.cannotconnect.rmi.CannotConnectTestCase
    • Copyright © 2018 www.massapicom. 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.