Falcon embeds ActiveMQ in its distribution.
To use ActiveMQ to broker JMS messaging:
If you already have Falcon running on your clusters, suspend your current active feeds and processes:
$FALCON_HOME/bin/falcon entity -type $feedName -name $name -suspend
$FALCON_HOME/bin/falcon entity -type $processName -name $name -suspend
Edit your cluster entity or entities. Add the following line:
<properties> <property name="brokerImplClass" value="org.apache.activemq.ActiveMQConnectionFactory" /> </properties>
Submit your updated cluster entity.
$FALCON_HOME/bin/falcon entity -submit -type cluster -file ~$clusterFileName
Resume your processes.
$FALCON_HOME/bin/falcon entity -type $processName -name $name -resume
$FALCON_HOME/bin/falcon entity -type $feedName -name $name -resume
In ActiveMQ, you should now see Falcon publishing messages to:
FALCON.my-process topic: For each execution of the process.
FALCON.ENTITY.TOPIC topic: For each change on the feeds.
