|
|
(19 intermediate revisions by the same user not shown) |
Line 1: |
Line 1: |
− | == What is Listener==
| + | {{note|This has been removed in SMILA 0.9 by the [[SMILA/Documentation/JobManager|JobManager framework]]}} |
− | | + | |
− | The main goal of Listener is to get Record from JMS queue and process by BPEL workflow but it also make any [[SMILA/Documentation/QueueWorker|Queue Worker]] specific tasks like resending Record into new JMS Queue.
| + | |
− | | + | |
− | == Interface ==
| + | |
− | there is no public interface
| + | |
− | | + | |
− | == Configuration ==
| + | |
− | Schema:org.eclipse.eilf.connectivity.queue.worker/schemas/QueueWorkerConfig.xsd
| + | |
− | | + | |
− | Configuration is a list of listening rules.
| + | |
− | There are only three difference with [[SMILA/Documentation/QueueWorker/Router|Router]] rules:
| + | |
− | * <Source BrokerId="broker1" Queue="EILF.connectivity"/&rt; - source queue reference.
| + | |
− | * WaitMessageTimeout - timeout for attempts to pull JMS message from queue
| + | |
− | * Workers - startup number of threads to listen queue under this rule.
| + | |
− | | + | |
− | | + | |
− | == Configuration Sample==
| + | |
− | <source lang="xml">
| + | |
− | <ListenerConfig xmlns="http://www.eclipse.org/eilf/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="EILF.connectivity"/>
| + | |
− | <Condition>Operation='ADD'</Condition>
| + | |
− | <Task>
| + | |
− | <Synchronize Filter="no-filter"/>
| + | |
− | <Process Workflow="AddPipeline"/>
| + | |
− | </Task>
| + | |
− | </Rule>
| + | |
− | | + | |
− | <Rule Name="Default Delete Rule" WaitMessageTimeout="10" Workers="2">
| + | |
− | <Source BrokerId="broker1" Queue="EILF.connectivity"/>
| + | |
− | <Condition>Operation='DELETE'</Condition>
| + | |
− | <Task>
| + | |
− | <Synchronize Filter="nothing"/>
| + | |
− | <Process Workflow="DeletePipeline"/>
| + | |
− | </Task>
| + | |
− | </Rule>
| + | |
− |
| + | |
− | </ListenerConfig>
| + | |
− | </source>
| + | |
− | | + | |
− | [[Category:SMILA]]
| + | |