SMILA/Documentation/QueueWorker/ConfigurationSamples

Configuration Samples

Default Settings

Shortly, the default behavior is

1. Router put record into queue
2. Listener get record from queue and start AddPipeline or DeletePipeline

ConnectionConfig.xml

<ConnectionsConfig xmlns="http://www.eclipse.org/smila/queue" 
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
>
 
  <ConnectionConfig Id="broker1">
    <URL>tcp://localhost:61616</URL>
    <User>any</User>
    <Password>any</Password>
    <ConnectionFactory>org.apache.activemq.ActiveMQConnectionFactory</ConnectionFactory>
  </ConnectionConfig>
 
</ConnectionsConfig>

RouterConfig.xml

<RouterConfig xmlns="http://www.eclipse.org/smila/queue"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
>
  <Rule Name="Default ADD Rule">
    <Condition>Operation='ADD'</Condition>
    <Task> 
      <Send BrokerId="broker1" Queue="SMILA.connectivity" RecordFilter="nothing"/>
    </Task>
  </Rule>
 
  <Rule Name="Default DELETE Rule">
    <Condition>Operation='DELETE'</Condition>
    <Task>
      <Send BrokerId="broker1" Queue="SMILA.connectivity"  RecordFilter="nothing"/>
    </Task>
  </Rule>
 
</RouterConfig>

ListenerConfig.xml

<ListenerConfig xmlns="http://www.eclipse.org/smila/queue"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
>
 
  <Rule Name="Default ADD Rule" WaitMessageTimeout="10" Workers="2">
    <Source BrokerId="broker1" Queue="SMILA.connectivity"/>
    <Condition>Operation='ADD'</Condition>
    <Task>
      <Process Workflow="AddPipeline"/>
    </Task>
  </Rule>
 
  <Rule Name="Default Delete Rule" WaitMessageTimeout="10" Workers="2">
    <Source BrokerId="broker1" Queue="SMILA.connectivity"/>
    <Condition>Operation='DELETE'</Condition>
    <Task>
      <Process Workflow="DeletePipeline"/>
    </Task>
  </Rule>
 
</ListenerConfig>

Settings for direct processing without queue

Shortly, the behavior is: Router executes AddPipeline or DeletePipeline immediately.

ConnectionConfig.xml

<ConnectionsConfig xmlns="http://www.eclipse.org/smila/queue" 
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
/>

RouterConfig.xml

<RouterConfig xmlns="http://www.eclipse.org/smila/queue"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
>
  <Rule Name="Default ADD Rule">
    <Condition>Operation='ADD'</Condition>
    <Task> 
      <Process Workflow="AddPipeline"/>
    </Task>
  </Rule>
 
  <Rule Name="Default DELETE Rule">
    <Condition>Operation='DELETE'</Condition>
    <Task>
      <Process Workflow="DeletePipeline"/>
    </Task>
  </Rule>
 
</RouterConfig>

ListenerConfig.xml

<ListenerConfig xmlns="http://www.eclipse.org/smila/queue"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:noNamespaceSchemaLocation="schemas/QueueWorkerConfig.xsd"
/>