Notice: This Wiki is now read only and edits are no longer possible. Please see: https://gitlab.eclipse.org/eclipsefdn/helpdesk/-/wikis/Wiki-shutdown-plan for the plan.
Difference between revisions of "SMILA/Documentation/QueueWorker/Listener"
(New page: == What is Router== 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 t...) |
|||
Line 1: | Line 1: | ||
− | == What is | + | == 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 [[SMILA/Documentation/QueueWorker|Queue Worker]] specific tasks like resending Record into new JMS Queue. | 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. | ||
Line 10: | Line 10: | ||
Configuration is a list of listening rules. | 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== | == Configuration Sample== |
Revision as of 09:57, 20 August 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.
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 Router rules:
- - source queue reference.
Invalid language.
You need to specify a language like this: <source lang="html4strict">...</source>
Supported languages for syntax highlighting:
4cs, 6502acme, 6502kickass, 6502tasm, 68000devpac, abap, actionscript, actionscript3, ada, algol68, apache, applescript, apt_sources, arm, asm, asp, asymptote, autoconf, autohotkey, autoit, avisynth, awk, bascomavr, bash, basic4gl, bf, bibtex, blitzbasic, bnf, boo, c, c_loadrunner, c_mac, caddcl, cadlisp, cfdg, cfm, chaiscript, cil, clojure, cmake, cobol, coffeescript, cpp, cpp-qt, csharp, css, cuesheet, d, dcl, dcpu16, dcs, delphi, diff, div, dos, dot, e, ecmascript, eiffel, email, epc, erlang, euphoria, f1, falcon, fo, fortran, freebasic, freeswitch, fsharp, gambas, gdb, genero, genie, gettext, glsl, gml, gnuplot, go, groovy, gwbasic, haskell, haxe, hicest, hq9plus, html4strict, html5, icon, idl, ini, inno, intercal, io, j, java, java5, javascript, jquery, kixtart, klonec, klonecpp, latex, lb, ldif, lisp, llvm, locobasic, logtalk, lolcode, lotusformulas, lotusscript, lscript, lsl2, lua, m68k, magiksf, make, mapbasic, matlab, mirc, mmix, modula2, modula3, mpasm, mxml, mysql, nagios, netrexx, newlisp, nsis, oberon2, objc, objeck, ocaml, ocaml-brief, octave, oobas, oorexx, oracle11, oracle8, otj, oxygene, oz, parasail, parigp, pascal, pcre, per, perl, perl6, pf, php, php-brief, pic16, pike, pixelbender, pli, plsql, postgresql, povray, powerbuilder, powershell, proftpd, progress, prolog, properties, providex, purebasic, pycon, pys60, python, q, qbasic, rails, rebol, reg, rexx, robots, rpmspec, rsplus, ruby, sas, scala, scheme, scilab, sdlbasic, smalltalk, smarty, spark, sparql, sql, stonescript, systemverilog, tcl, teraterm, text, thinbasic, tsql, typoscript, unicon, upc, urbi, uscript, vala, vb, vbnet, vedit, verilog, vhdl, vim, visualfoxpro, visualprolog, whitespace, whois, winbatch, xbasic, xml, xorg_conf, xpp, yaml, z80, zxbasic
- WaitMessageTimeout - timeout for attempts to pull JMS message from queue
- Workers - startup number of threads to listen queue under this rule.
Configuration Sample
<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>