This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Configuration | |
public Option[] config() { | |
return new Option[]{ karafDistributionConfiguration().frameworkUrl( | |
maven().groupId("org.apache.servicemix").artifactId("apache-servicemix").type("zip").versionAsInProject()) | |
.karafVersion("2.2.2").name("Apache Servicemix")}; | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@ProbeBuilder | |
public TestProbeBuilder probeConfiguration(TestProbeBuilder probe) { | |
probe.setHeader(Constants.DYNAMICIMPORT_PACKAGE, "*;status=provisional"); | |
return probe; | |
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Inject | |
CommandProcessor commandProcessor; | |
protected String executeCommands(final String ...commands) { | |
String response; | |
final ByteArrayOutputStream byteArrayOutputStream = new ByteArrayOutputStream(); | |
final PrintStream printStream = new PrintStream(byteArrayOutputStream); | |
final CommandSession commandSession = commandProcessor.createSession(System.in, printStream, System.err); | |
FutureTask<string> commandFuture = new FutureTask<string>( | |
new Callable<string>() { |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
public void createInstances() { | |
//Install broker feature that is provided by FuseESB | |
executeCommands("admin:create --feature broker brokerChildInstance"); | |
//Install producer feature that provided by imaginary feature repo. | |
executeCommands("admin:create --featureURL mvn:imaginary/repo/1.0/xml/features --feature producer producerChildInstance"); | |
//Install producer feature that provided by imaginary feature repo. | |
executeCommands("admin:create --featureURL mvn:imaginary/repo/1.0/xml/features --feature consumer consumerChildInstance"); | |
//start child instances | |
executeCommands("admin:start brokerChildInstance"); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
String routeInfo = executeCommands("admin:connect consumerChildInstance camel:route-info myconsumerRoute"); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<from uri="quartz://cloudTimer?trigger.repeatInterval=3600000&trigger.repeatCount=-1"> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<bean class="org.apache.camel.component.jclouds.JcloudsComponent" id="jclouds"> | |
<property name="computeServices"> | |
<list> | |
<ref bean="computeService"/> | |
</list> | |
</property> | |
</bean> | |
<bean class="org.jclouds.compute.ComputeServiceContextFactory" id="computeCF"/> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<to uri="jclouds:compute:{{jclouds.provider}}?operation=CamelJcloudsListNodes&nodeState=RUNNING"/> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<filter> | |
<simple>${body.size} != 0</simple> | |
<to uri="my:final-destination"/> | |
</filter> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<setheader headername="To"> | |
<constant>[email protected]</constant> | |
</setheader> | |
<setheader headername="From"> | |
<constant>[email protected]</constant> | |
</setheader> | |
<setheader headername="Subject"> | |
<constant>Running nodes in the cloud</constant> | |
</setheader> |
OlderNewer