diff --git a/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java b/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java
index 4df774d8..4c9219fa 100644
--- a/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java
+++ b/src/main/java/com/rabbitmq/jms/admin/RMQObjectFactory.java
@@ -93,6 +93,7 @@
*
port
* queueBrowserReadMax
* onMessageTimeoutMs
+ * channelsQos
* ssl
* terminationTimeout
* username
@@ -191,6 +192,7 @@ public Object createConnectionFactory(Reference ref, Hashtable, ?> environment
f.setPort (getIntProperty (ref, environment, "port", true, f.getPort() ));
f.setQueueBrowserReadMax(getIntProperty (ref, environment, "queueBrowserReadMax", true, f.getQueueBrowserReadMax()));
f.setOnMessageTimeoutMs (getIntProperty (ref, environment, "onMessageTimeoutMs", true, f.getOnMessageTimeoutMs() ));
+ f.setChannelsQos (getIntProperty (ref, environment, "channelsQos", true, f.getChannelsQos() ));
if (getBooleanProperty(ref, environment, "ssl", true, f.isSsl())) {
try {
f.useSslProtocol();
diff --git a/src/test/java/com/rabbitmq/jms/admin/RMQObjectFactoryTest.java b/src/test/java/com/rabbitmq/jms/admin/RMQObjectFactoryTest.java
index a40911d9..565332ff 100644
--- a/src/test/java/com/rabbitmq/jms/admin/RMQObjectFactoryTest.java
+++ b/src/test/java/com/rabbitmq/jms/admin/RMQObjectFactoryTest.java
@@ -8,6 +8,7 @@
import javax.naming.Reference;
import java.util.Hashtable;
+import static com.rabbitmq.jms.client.RMQConnection.NO_CHANNEL_QOS;
import static org.junit.jupiter.api.Assertions.*;
/**
@@ -35,6 +36,7 @@ public void getObjectInstanceShouldCreateARMQConnectionFactoryViaReference() thr
assertEquals("guest", createdConFactory.getPassword());
assertEquals("/", createdConFactory.getVirtualHost());
assertEquals("localhost", createdConFactory.getHost());
+ assertEquals(NO_CHANNEL_QOS, createdConFactory.getChannelsQos());
}
@@ -48,6 +50,7 @@ public void getObjectInstanceShouldCreateARMQConnectionFactoryViaEnvironment() t
put("password", "1234");
put("virtualHost", "/fake");
put("host", "fakeHost");
+ put("channelsQos", 10);
}};
Object createdObject = rmqObjectFactory.getObjectInstance("anything but a javax.naming.Reference", new CompositeName("java:global/jms/TestConnectionFactory"), null, environment);
@@ -61,6 +64,7 @@ public void getObjectInstanceShouldCreateARMQConnectionFactoryViaEnvironment() t
assertEquals("1234", createdConFactory.getPassword());
assertEquals("/fake", createdConFactory.getVirtualHost());
assertEquals("fakeHost", createdConFactory.getHost());
+ assertEquals(10, createdConFactory.getChannelsQos());
}