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.
Difference between revisions of "SMILA/Documentation/QueueWorker/Listener"
| Line 15: | Line 15: | ||
* WaitMessageTimeout - timeout (in seconds) for attempts to pull JMS message from queue, default value is 1 second. | * WaitMessageTimeout - timeout (in seconds) for attempts to pull JMS message from queue, default value is 1 second. | ||
* Workers - startup number of threads to listen queue under this rule, by default it is 1 thread. | * Workers - startup number of threads to listen queue under this rule, by default it is 1 thread. | ||
| − | |||
| − | |||
== Condition == | == Condition == | ||
| Line 26: | Line 24: | ||
* DataSourceID | * DataSourceID | ||
| − | + | Custom JMS properties may be added/used in conditions, look at the [[SMILA/Documentation/QueueWorker/ConfigurationSamples|samples]]. | |
| + | |||
| + | == Tasks == | ||
| + | See [[SMILA/Documentation/QueueWorker/Tasks|Router/Listener Tasks]] page for tasks configuration. | ||
| − | + | == Samples == | |
| + | See [[SMILA/Documentation/QueueWorker/ConfigurationSamples|samples]] page. | ||
| − | |||
[[Category:SMILA]] | [[Category:SMILA]] | ||
Revision as of 06:32, 25 November 2008
What is Listener
The main goal of Listener is to get Record from JMS queue and process by BPEL workflow but it also make any Queue Worker specific tasks like resending Record into new JMS Queue, see Router/Listener Tasks.
Interface
there is no public interface. Its only possible to manually change workers quantity for every Rule by JMX management API/console. It may be useful for workload balancing.
Configuration
Schema: "org.eclipse.smila.connectivity.queue.worker/schemas/QueueWorkerConfig.xsd" Location: "configuration/org.eclipse.smila.connectivity.queue.worker/ListenerConfig.xml"
Configuration is a list of listening rules. There are only three difference with Router rules:
- <Source BrokerId="broker1" Queue="SMILA.connectivity"/> - source queue reference (BrokerID should be specified in Broker Connection Service configuration).
- WaitMessageTimeout - timeout (in seconds) for attempts to pull JMS message from queue, default value is 1 second.
- Workers - startup number of threads to listen queue under this rule, by default it is 1 thread.
Condition
Each listener Rule is a set of Queue consumers (workers) grouped by value of Condition tag. Condition is a String whose syntax is based on a subset of the SQL92 conditional expression syntax pointed in JMS specification ( [| spec] ) and it's absolutely the same syntax that used in Router Condition tag.
There are two JMS properties supported during all queue related processes in router/listener
- Operation
- DataSourceID
Custom JMS properties may be added/used in conditions, look at the samples.
Tasks
See Router/Listener Tasks page for tasks configuration.
Samples
See samples page.