Example receive messages

(: 
 : Example: register receiver with additional parameters 
 :)
xquery version "3.0";

import module namespace jms="http://exist-db.org/xquery/messaging"  
                        at "java:org.exist.messaging.xquery.MessagingModule";
(: 
 : A (callback) function is required to have 4 parameters. This function
 : logs incoming data to "standard out".
 : 
 : $content The actual data of the messages
 : $params  Additional parameters set when registerering the callback function
 : $messageProperties JMS message properties, contains data of sender and 
 :                    the eXist-db database
 : $jmsConfig Details about the JMS configuration (for debugging) 
 :)
declare function local:handleMessage($content as item(), $params as item()*, 
                            $messageProperties as map(), $jmsConfig as map() )
{
    ( 
        util:log-system-out( util:get-sequence-type($content) 
                             || "->" || data($content) ), 
        
        util:log-system-out( for $param in $params
                             return util:get-sequence-type($param) 
                             || "->" || $param || " ;  " ), 
        
        util:log-system-out( 
            for $key in map:keys($messageProperties)
            let $value := map:get($messageProperties, $key) 
            return util:get-sequence-type($value) || "-->" || $key || "=" ||  $value || " ;  " ), 
            
        util:log-system-out( for $key in map:keys($jmsConfig)
            let $value := map:get($jmsConfig, $key) 
            return util:get-sequence-type($value) || "-->" || $key || "=" ||  $value || " ;  " )
    )
};
(: Configuration for setting-up an JMS connection :)
let $jmsConfiguration :=
    map {
        "java.naming.factory.initial" := "org.apache.activemq.jndi.ActiveMQInitialContextFactory",
        "java.naming.provider.url" := "tcp://myserver.local:61616",
        "destination" := "dynamicQueues/eXistdb-messaging-example",
        "connection-factory" := "ConnectionFactory"
    }
    
(: Define HoF callback function, with 4 parameters :)
let $callback := local:handleMessage#4 

(: Additional (optional) data to parameterize the callback function :)
let $additionalParameters := (1, "2" , xs:float(3.0))
    
return
    (: Register the function to the JMS broker :)
    jms:register( $callback , $additionalParameters, $jmsConfiguration)