Examples of com.linkedin.databus.client.pub.DatabusRegistration.start()

Class com.linkedin.databus.client.pub.DatabusRegistration

Examples of com.linkedin.databus.client.pub.DatabusRegistration.start()

com.linkedin.databus.client.pub.DatabusRegistration.start()
This API should be called when the application is ready to start consuming events. The methods defined in the ConsumerCallbacks registered will be invoked (in a separate thread) as the events are pulled. These callbacks will continue to be called until the application calls pause() or shutdown() methods. @throws IllegalStateException if the registration is not in REGISTERED state. @throws DatabusClientException if there are no subscriptions or callbacks registered, or if this registration cannot service the sources/subscriptions together. @return false if the client is already started, else true.

      assertEquals("Component Name" , "Status_TestConsumer_a62d57a7", reg.getStatus().getComponentName());
      assertEquals("Component Status", Status.INITIALIZING, reg.getStatus().getStatus());




      // Start
      boolean started = reg.start();
      assertEquals("Started", true, started);
      assertEquals("Registered State", RegistrationState.STARTED, reg.getState());
      assertEquals("Component Status", Status.RUNNING, reg.getStatus().getStatus());

View Full Code Here

      assertEquals("Registered State", RegistrationState.STARTED, reg.getState());
      assertEquals("Component Status", Status.RUNNING, reg.getStatus().getStatus());
      
      
      //Start again
      started = reg.start();
      assertEquals("Started", false, started);
      assertEquals("Registered State", RegistrationState.STARTED, reg.getState());


      // Pause
      reg.pause();

View Full Code Here

      // Start
      boolean started = false;
      boolean gotException = false;
      try
      {
        started = reg.start();
      } catch (DatabusClientException ex) {
        gotException = true;
      }
      
      assertEquals("gotException", true, gotException);

View Full Code Here

      assertEquals("Component Name" , "Status_TestConsumer_922c5e28", reg.getStatus().getComponentName());
      assertEquals("Component Status", Status.INITIALIZING, reg.getStatus().getStatus());




      // Start
      boolean started = reg.start();
      assertEquals("Started", true, started);
      assertEquals("Registered State", RegistrationState.STARTED, reg.getState());
      assertEquals("Component Status", Status.RUNNING, reg.getStatus().getStatus());


      //Start again

View Full Code Here

      assertEquals("Started", true, started);
      assertEquals("Registered State", RegistrationState.STARTED, reg.getState());
      assertEquals("Component Status", Status.RUNNING, reg.getStatus().getStatus());


      //Start again
      started = reg.start();
      assertEquals("Started", false, started);
      assertEquals("Registered State", RegistrationState.STARTED, reg.getState());


      // Pause
      reg.pause();

View Full Code Here

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.