Package org.mokai.impl.camel

Examples of org.mokai.impl.camel.CamelRoutingEngine.addApplication()

275
276
277
278
279
280
281
282
283
284
285
    try {
      routingEngine.start();

      Connector connector = mock(Connector.class);

      ConnectorService cs1 = routingEngine.addApplication("test1", connector);
      cs1.start();

      // check that the application was created successfully
      Assert.assertNotNull(cs1);
      Assert.assertEquals(Service.State.STARTED, cs1.getState());
View Full Code Here
287
288
289
290
291
292
293
294
295
296
297
      // check that there is only one application
      Collection<ConnectorService> applications = routingEngine.getApplications();
      Assert.assertEquals(1, applications.size());

      // create a second and third receiver
      ConnectorService cs2 = routingEngine.addApplication("test2", connector);
      cs2.start();
      ConnectorService cs3 = routingEngine.addApplication("test3", connector);
      cs3.start();

      applications = routingEngine.getApplications();
View Full Code Here
289
290
291
292
293
294
295
296
297
298
299
      Assert.assertEquals(1, applications.size());

      // create a second and third receiver
      ConnectorService cs2 = routingEngine.addApplication("test2", connector);
      cs2.start();
      ConnectorService cs3 = routingEngine.addApplication("test3", connector);
      cs3.start();

      applications = routingEngine.getApplications();
      Assert.assertEquals(3, applications.size());
View Full Code Here
321
322
323
324
325
326
327
328
329
330
331
    CamelRoutingEngine routingEngine = new CamelRoutingEngine();

    try {
      routingEngine.start();
      Connector connector = mock(Connector.class, withSettings().extraInterfaces(Configurable.class));
      routingEngine.addApplication("test1", connector);

      verify((Configurable) connector).configure();
    } finally {
      routingEngine.shutdown();
    }
View Full Code Here
338
339
340
341
342
343
344
345
346
347
348
      routingEngine.start();

      Connector connector = mock(Connector.class);

      // create and start an application
      ConnectorService connectorService = routingEngine.addApplication("test", connector);
      connectorService.start();

      // try to retrieve an existing application
      ConnectorService csTest = routingEngine.getApplication("test");
      Assert.assertEquals(connectorService, csTest);
View Full Code Here
360
361
362
363
364
365
366
367
368
369
370
    CamelRoutingEngine routingEngine = new CamelRoutingEngine();

    try {
      Connector connector = mock(Connector.class);

      ConnectorService cs1 = routingEngine.addApplication("test1", connector).withPriority(2000);
      ConnectorService cs2 = routingEngine.addApplication("test2", connector).withPriority(1000);
      ConnectorService cs3 = routingEngine.addApplication("test3", connector).withPriority(1500);

      List<ConnectorService> connectorServices = routingEngine.getApplications();
View Full Code Here
361
362
363
364
365
366
367
368
369
370
371
    try {
      Connector connector = mock(Connector.class);

      ConnectorService cs1 = routingEngine.addApplication("test1", connector).withPriority(2000);
      ConnectorService cs2 = routingEngine.addApplication("test2", connector).withPriority(1000);
      ConnectorService cs3 = routingEngine.addApplication("test3", connector).withPriority(1500);

      List<ConnectorService> connectorServices = routingEngine.getApplications();

      Assert.assertNotNull(connectorServices);
View Full Code Here
362
363
364
365
366
367
368
369
370
371
372
    try {
      Connector connector = mock(Connector.class);

      ConnectorService cs1 = routingEngine.addApplication("test1", connector).withPriority(2000);
      ConnectorService cs2 = routingEngine.addApplication("test2", connector).withPriority(1000);
      ConnectorService cs3 = routingEngine.addApplication("test3", connector).withPriority(1500);

      List<ConnectorService> connectorServices = routingEngine.getApplications();

      Assert.assertNotNull(connectorServices);
      Assert.assertEquals(3, connectorServices.size());
View Full Code Here
382
383
384
385
386
387
388
389
390
391
392
  public void shouldFailToModifyReturnedApplications() throws Exception {
    CamelRoutingEngine routingEngine = new CamelRoutingEngine();

    try {
      Connector connector = mock(Connector.class);
      ConnectorService cs1 = routingEngine.addApplication("test", connector);

      Collection<ConnectorService> connectorServices = routingEngine.getApplications();
      Assert.assertEquals(connectorServices.size(), 1);

      // add another application to the returned collection
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
    try {
      Connector connector = mock(Connector.class);

      // create an application
      routingEngine.addApplication("test", connector);

      // try to create another application with the same id
      routingEngine.addApplication("test", connector);
    } finally {
      routingEngine.shutdown();
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.