Skip to main content
Jump to: navigation, search

SMILA/Documentation/QueueWorker/Listener

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:

  • 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


      - 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

<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>

Back to the top