Skip to main content

Notice: this Wiki will be going read only early in 2024 and edits will no longer be possible. Please see: https://gitlab.eclipse.org/eclipsefdn/helpdesk/-/wikis/Wiki-shutdown-plan for the plan.

Jump to: navigation, search

Difference between revisions of "SMILA/Documentation/QueueWorker/Listener"

(Replacing page with '{{note|This has been removed in SMILA 0.9 by the JobManager framework}}')
 
(20 intermediate revisions by 3 users 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"/>  - 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]]
+

Latest revision as of 06:00, 24 January 2012

Note.png
This has been removed in SMILA 0.9 by the JobManager framework

Back to the top