Author: robbie
Date: Thu Feb 2 13:57:39 2012
New Revision: 1239622
URL: http://svn.apache.org/viewvc?rev=1239622&view=rev
Log:
QPID-3784: move the system property key into ClientProperties
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/DispatcherDaemonTest.java
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
Modified:
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java?rev=1239622&r1=1239621&r2=1239622&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
(original)
+++
qpid/trunk/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
Thu Feb 2 13:57:39 2012
@@ -47,6 +47,7 @@ import org.apache.qpid.client.message.Un
import org.apache.qpid.client.protocol.AMQProtocolHandler;
import org.apache.qpid.client.util.FlowControllingBlockingQueue;
import org.apache.qpid.common.AMQPFilterTypes;
+import org.apache.qpid.configuration.ClientProperties;
import org.apache.qpid.filter.MessageFilter;
import org.apache.qpid.framing.AMQShortString;
import org.apache.qpid.framing.FieldTable;
@@ -388,14 +389,9 @@ public abstract class AMQSession<C exten
public static final String IMMEDIATE_PREFETCH_DEFAULT = "false";
/**
- * System property to enable allow dispatcher thread to be run as a daemon
thread
- */
- public static final String DAEMON_DISPATCHER =
"qpid.jms.daemon.dispatcher";
-
- /**
* Flag indicating to start dispatcher as a daemon thread
*/
- protected final boolean DEAMON_DISPATCHER_THREAD =
Boolean.getBoolean(DAEMON_DISPATCHER);
+ protected final boolean DEAMON_DISPATCHER_THREAD =
Boolean.getBoolean(ClientProperties.DAEMON_DISPATCHER);
/** The connection to which this session belongs. */
private AMQConnection _connection;
Modified:
qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/DispatcherDaemonTest.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/DispatcherDaemonTest.java?rev=1239622&r1=1239621&r2=1239622&view=diff
==============================================================================
---
qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/DispatcherDaemonTest.java
(original)
+++
qpid/trunk/qpid/java/client/src/test/java/org/apache/qpid/client/DispatcherDaemonTest.java
Thu Feb 2 13:57:39 2012
@@ -21,6 +21,7 @@ package org.apache.qpid.client;
import javax.jms.Session;
import org.apache.qpid.AMQException;
+import org.apache.qpid.configuration.ClientProperties;
import org.apache.qpid.test.utils.QpidTestCase;
import org.apache.qpid.url.URLSyntaxException;
@@ -47,7 +48,7 @@ public class DispatcherDaemonTest extend
public void
testDispatcherIsRunInDaemonThreadWithConsumerMessageListenerAndDaemonFlagOn()
throws Exception
{
- setTestSystemProperty(AMQSession.DAEMON_DISPATCHER, "true");
+ setTestSystemProperty(ClientProperties.DAEMON_DISPATCHER, "true");
_session = createSession();
_session.startDispatcherIfNecessary();
assertTrue("Dispatcher thread should be daemon as
qpid.jms.daemon.dispatcher is set to true",
Modified:
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
URL:
http://svn.apache.org/viewvc/qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java?rev=1239622&r1=1239621&r2=1239622&view=diff
==============================================================================
---
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
(original)
+++
qpid/trunk/qpid/java/common/src/main/java/org/apache/qpid/configuration/ClientProperties.java
Thu Feb 2 13:57:39 2012
@@ -140,4 +140,8 @@ public class ClientProperties
@Deprecated
public static final String QPID_SSL_TRUST_STORE_CERT_TYPE_PROP_NAME =
"qpid.ssl.trustStoreCertType";
+ /**
+ * System property to enable allow dispatcher thread to be run as a daemon
thread
+ */
+ public static final String DAEMON_DISPATCHER =
"qpid.jms.daemon.dispatcher";
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
