@Test public void shouldPassAirlineProxifiedAddressToTravelAgency() throws ContextNotSentException, ServiceInstanceNotFoundException { this.setUpBusUris(); ContextSender sender = mock(ContextSender.class); ContextSenderFactory.testing = true; ContextSenderFactory.senderForTesting = sender; ContextCaster caster = new ContextCaster(models.getChoreography()); caster.cast(); List<String> expectedAirlineUrisList = new ArrayList<String>(); expectedAirlineUrisList.add(AIRLINE_PROXIFIED_URI); verify(sender).sendContext(TRAVEL_AGENCY_URI, AIRLINE, AIRLINE, expectedAirlineUrisList); }
public void cast() { if (!inputOK()) { logger.warn("No deployed services found. Not going to cast context."); return; } int nThreads = getNThreads(); this.executor = Executors.newFixedThreadPool(nThreads); logger.info("Passing context to deployed services on choreograghy " + chor.getId()); for (Service consumer : chor.getServices()) { castContextsToConsumer(consumer); } waitContextCasting(); }
ContextCaster { public void cast() { if (!inputOK()) { logger.warn("No deployed services found. Not going to cast context."); return; } int nThreads = getNThreads(); this.executor = Executors.newFixedThreadPool(nThreads); logger.info("Passing context to deployed services on choreograghy " + chor.getId()); for (Service consumer : chor.getServices()) { castContextsToConsumer(consumer); } waitContextCasting(); } }
ContextCaster { public void cast() { if (!inputOK()) { logger.warn("No deployed services found. Not going to cast context."); return; } int nThreads = getNThreads(); this.executor = Executors.newFixedThreadPool(nThreads); logger.info("Passing context to deployed services on choreograghy " + chor.getId()); for (Service consumer : chor.getServices()) { castContextsToConsumer(consumer); } waitContextCasting(); } ContextCaster(Choreography chor); }
ContextCaster { public void cast() { if (!inputOK()) { logger.warn("No deployed services found. Not going to cast context."); return; } int nThreads = getNThreads(); this.executor = Executors.newFixedThreadPool(nThreads); logger.info("Passing context to deployed services on choreograghy " + chor.getId()); for (Service consumer : chor.getServices()) { castContextsToConsumer(consumer); } waitContextCasting(); } ContextCaster(Choreography chor); void cast(); }
ContextCaster { public void cast() { if (!inputOK()) { logger.warn("No deployed services found. Not going to cast context."); return; } int nThreads = getNThreads(); this.executor = Executors.newFixedThreadPool(nThreads); logger.info("Passing context to deployed services on choreograghy " + chor.getId()); for (Service consumer : chor.getServices()) { castContextsToConsumer(consumer); } waitContextCasting(); } ContextCaster(Choreography chor); void cast();  }