Examples of org.jboss.remoting.Client.addListener()

org.jboss.remoting.Client.addListener()
Adds the specified handler as a callback listener for push (async) callbacks. If the transport is uni-directional (e.g. http), remoting will automatically poll for callbacks from the server and deliver them to the callback handler. If the transport is bi-directional (e.g. multiplex), remoting will automatically create a callback server internally and receive and deliver to callback handler the callbacks as they are generated on the server. The metadata map passed will control configuration for how the callbacks are processed, such as the polling frequency.

      // Configure callback polling.
      TestCallbackHandler handler = new TestCallbackHandler();
      HashMap metadata = new HashMap();
      metadata.put("maxErrorCount", "555");
      metadata.put(Client.USE_ALL_PARAMS, "false");
      client.addListener(handler, metadata);
      
      // Test setting of parameters in CallbackPoller.
      testParameters(client, false, CallbackPoller.DEFAULT_POLL_PERIOD, 555);
      
      client.removeListener(handler);

View Full Code Here

      SimpleCallbackHandler callbackHandler = new SimpleCallbackHandler(client);
      Map metadata = new HashMap();
      metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.BLOCKING);
      metadata.put(ServerInvoker.BLOCKING_TIMEOUT, "500");
      metadata.put(CallbackPoller.MAX_ERROR_COUNT, "4");
      client.addListener(callbackHandler, metadata);
      log.info("client added callback handler for pull callbacks");
      
      // Test for good connection.
      assertEquals("abc", client.invoke("abc"));

View Full Code Here

      assertEquals("abc", client.invoke("abc"));
      log.info("client is connected");


      // Add callback handler.
      TestInvokerCallbackHandler callbackHandler = new TestInvokerCallbackHandler();
      client.addListener(callbackHandler, new HashMap(), null, true);
      client.invoke(CALLBACK_TEST);
      assertEquals(1, callbackHandler.counter);
      log.info("callback handler is installed");


      // Verify that "timeout" is used correctly.

View Full Code Here

      
      // Configure callback polling.
      TestCallbackHandler handler = new TestCallbackHandler();
      HashMap metadata = new HashMap();
      metadata.put("maxErrorCount", "555");
      client.addListener(handler, metadata);
      
      // Test setting of parameters in CallbackPoller.
      testParameters(client, true, 333, 555);
      
      client.removeListener(handler);

View Full Code Here

      Map metadata = new HashMap();
      metadata.put(ServerInvoker.BLOCKING_MODE, ServerInvoker.NONBLOCKING);
      metadata.put(CallbackPoller.CALLBACK_POLL_PERIOD, "500");
      metadata.put(ServerInvoker.BLOCKING_TIMEOUT, "500");
      metadata.put(CallbackPoller.MAX_ERROR_COUNT, "4");
      client.addListener(callbackHandler, metadata);
      log.info("client added callback handler for pull callbacks");
      
      // Test for good connection.
      assertEquals("abc", client.invoke("abc"));

View Full Code Here

      
      // Configure callback polling.
      TestCallbackHandler handler = new TestCallbackHandler();
      HashMap metadata = new HashMap();
      metadata.put("maxErrorCount", "555");
      client.addListener(handler, metadata);
      
      // Test setting of parameters in CallbackPoller.
      testParameters(client, true, 333, 555);
      
      client.removeListener(handler);

View Full Code Here


      // Add callback handler.
      TestInvokerCallbackHandler callbackHandler = new TestInvokerCallbackHandler();
      Map metadata = new HashMap();
      metadata.put(ServerInvoker.TIMEOUT, "3000");
      client.addListener(callbackHandler, metadata, null, true);
      client.invoke(CALLBACK_TEST);
      assertEquals(1, callbackHandler.counter);
      log.info("callback handler is installed");


      // Verify that "timeout" is used correctly.

View Full Code Here

      // Configure callback polling.
      TestCallbackHandler handler = new TestCallbackHandler();
      HashMap metadata = new HashMap();
      metadata.put("maxErrorCount", "555");
      metadata.put(Client.USE_ALL_PARAMS, "true");
      client.addListener(handler, metadata);
      
      // Test setting of parameters in CallbackPoller.
      testParameters(client, true, 333, 555);
      
      client.removeListener(handler);

View Full Code Here


      // Add callback handler.
      TestInvokerCallbackHandler callbackHandler = new TestInvokerCallbackHandler();
      Map metadata = new HashMap();
      metadata.put(ServerInvokerCallbackHandler.CALLBACK_TIMEOUT, "7000");
      client.addListener(callbackHandler, metadata, null, true);
      client.invoke(CALLBACK_TEST);
      assertEquals(1, callbackHandler.counter);
      log.info("callback handler is installed");


      // Verify that "callbackTimeout" is used correctly.

View Full Code Here


      // Add callback handler.
      TestInvokerCallbackHandler callbackHandler = new TestInvokerCallbackHandler();
      Map metadata = new HashMap();
      metadata.put(ServerInvokerCallbackHandler.CALLBACK_TIMEOUT, "11000");
      client.addListener(callbackHandler, metadata, null, true);
      client.invoke(CALLBACK_TEST);
      assertEquals(1, callbackHandler.counter);
      log.info("callback handler is installed");


      // Verify that "callbackTimeout" from Client.addListener() metadata

View Full Code Here

0 1 2 3 4 5 6 7 8 9

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.