Merge pull request #26 from dizzzz/develop

Fix for #25

Author: dizzzz

build.properties

@@ -3,7 +3,7 @@ exist.dir=../../dizzzz/exist/
 
 # Extension details
 module.name=messaging-replication
-module.version=0.6
+module.version=0.6.1
 module.title=Messaging and Replication
 
 # Build instructions

java/src/org/exist/messaging/xquery/RegisterReceiver.java

@@ -88,7 +88,8 @@ public Sequence eval(Sequence[] args, Sequence contextSequence) throws XPathExce
             config.loadConfiguration(configMap);
 
             // Setup listener, pass correct User object
-            MessagingJmsListener myListener = new MessagingJmsListener(context.getRealUser(), reference, functionParams, context);
+            // get user via Broker for compatibility < existdb 2.2
+            MessagingJmsListener myListener = new MessagingJmsListener(context.getBroker().getSubject(), reference, functionParams, context);
 
             // Create receiver
             Receiver receiver = new Receiver(config, myListener); // TODO check use .copyContext() ?