Commit f7d94810 authored by Andre Freyssinet's avatar Andre Freyssinet

Minor changes.

parent 1f6fa0e1
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2014 - 2017 ScalAgent Distributed Technologies
* Copyright (C) 2014 - 2018 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -44,13 +44,13 @@ public class Admin {
User.create("anonymous", "anonymous");
// Creating a Queue Distribution bridge on server 1:
Queue distq = JMSDistributionQueue.create(1, "queue");
// Creating a Queue Distribution bridge on bridge server
Queue distq = JMSDistributionQueue.create("queue");
distq.setFreeWriting();
System.out.println("joram distribution queue = " + distq);
// Creating a Queue Acquisition bridge on server 1:
Queue acqq = JMSAcquisitionQueue.create(1, "queue");
// Creating a Queue Acquisition bridge on bridge server
Queue acqq = JMSAcquisitionQueue.create("queue");
acqq.setFreeReading();
System.out.println("joram acquisition queue = " + acqq);
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2014 - 2017 ScalAgent Distributed Technologies
* Copyright (C) 2014 - 2018 ScalAgent Distributed Technologies
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
......@@ -37,7 +37,6 @@ import javax.jms.TextMessage;
public class Producer {
public static void main(String[] args) throws Exception {
Properties jndiProps = new Properties();
jndiProps.setProperty("java.naming.factory.initial", "fr.dyade.aaa.jndi2.client.NamingContextFactory");
jndiProps.setProperty("java.naming.factory.host", "localhost");
......@@ -61,7 +60,6 @@ public class Producer {
}
bridgeSess.commit();
bridgeCnx.close();
}
}
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment