Commit 38003be8 authored by afreyssin's avatar afreyssin
Browse files

Overrides acquisitionClassName and other specified informations in properties (JORAM-222).

parent 022ecb86
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2012 ScalAgent Distributed Technologies
* Copyright (C) 2012 - 2015 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
......@@ -151,10 +151,8 @@ public class JMSAcquisitionQueue {
Properties props) throws ConnectException, AdminException {
if (props == null)
props = new Properties();
if (!props.containsKey("acquisition.className"))
props.setProperty("acquisition.className", JMSAcquisition);
if (!props.containsKey("jms.DestinationName"))
props.setProperty("jms.DestinationName", dest);
props.setProperty("acquisition.className", JMSAcquisition);
props.setProperty("jms.DestinationName", dest);
Queue queue = Queue.create(serverId, name, Queue.ACQUISITION_QUEUE, props);
return queue;
}
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2012 ScalAgent Distributed Technologies
* Copyright (C) 2012 - 2015 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
......@@ -142,10 +142,8 @@ public class JMSAcquisitionTopic {
Properties props) throws ConnectException, AdminException {
if (props == null)
props = new Properties();
if (!props.containsKey("acquisition.className"))
props.setProperty("acquisition.className", JMSAcquisition);
if (!props.containsKey("jms.DestinationName"))
props.setProperty("jms.DestinationName", dest);
props.setProperty("acquisition.className", JMSAcquisition);
props.setProperty("jms.DestinationName", dest);
Topic topic = Topic.create(serverId, name, Topic.ACQUISITION_TOPIC, props);
return topic;
}
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2012 ScalAgent Distributed Technologies
* Copyright (C) 2012 - 2015 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
......@@ -141,10 +141,8 @@ public class JMSDistributionQueue {
Properties props) throws ConnectException, AdminException {
if (props == null)
props = new Properties();
if (!props.containsKey("distribution.className"))
props.setProperty("distribution.className", JMSDistribution);
if (!props.containsKey("jms.DestinationName"))
props.setProperty("jms.DestinationName", dest);
props.setProperty("distribution.className", JMSDistribution);
props.setProperty("jms.DestinationName", dest);
Queue queue = Queue.create(serverId, name, Queue.DISTRIBUTION_QUEUE, props);
return queue;
}
......
/*
* JORAM: Java(TM) Open Reliable Asynchronous Messaging
* Copyright (C) 2012 ScalAgent Distributed Technologies
* Copyright (C) 2012 - 2015 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
......@@ -141,10 +141,8 @@ public class JMSDistributionTopic {
Properties props) throws ConnectException, AdminException {
if (props == null)
props = new Properties();
if (!props.containsKey("distribution.className"))
props.setProperty("distribution.className", JMSDistribution);
if (!props.containsKey("jms.DestinationName"))
props.setProperty("jms.DestinationName", dest);
props.setProperty("distribution.className", JMSDistribution);
props.setProperty("jms.DestinationName", dest);
Topic topic = Topic.create(serverId, name, Topic.DISTRIBUTION_TOPIC, props);
return topic;
}
......
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