qpid-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rob...@apache.org
Subject [2/2] qpid-jms git commit: change regular MessageConsumer creation to use the JmsMessageConsumer object
Date Tue, 02 Dec 2014 17:02:08 GMT
change regular MessageConsumer creation to use the JmsMessageConsumer object


Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/40ad9e8b
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/40ad9e8b
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/40ad9e8b

Branch: refs/heads/master
Commit: 40ad9e8b3c353e3d52f67efc63f7ad563676cd4c
Parents: 70b1690
Author: Robert Gemmell <robbie@apache.org>
Authored: Tue Dec 2 11:03:36 2014 +0000
Committer: Robert Gemmell <robbie@apache.org>
Committed: Tue Dec 2 11:03:36 2014 +0000

----------------------------------------------------------------------
 .../src/main/java/org/apache/qpid/jms/JmsSession.java            | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/40ad9e8b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java
index 19763c9..32b3f11 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/JmsSession.java
@@ -286,12 +286,12 @@ public class JmsSession implements Session, QueueSession, TopicSession,
JmsMessa
      *      java.lang.String, boolean)
      */
     @Override
-    public MessageConsumer createConsumer(Destination destination, String messageSelector,
boolean NoLocal) throws JMSException {
+    public MessageConsumer createConsumer(Destination destination, String messageSelector,
boolean noLocal) throws JMSException {
         checkClosed();
         checkDestination(destination);
         messageSelector = checkSelector(messageSelector);
         JmsDestination dest = JmsMessageTransformation.transformDestination(connection, destination);
-        JmsTopicSubscriber result = new JmsTopicSubscriber(getNextConsumerId(), this, dest,
NoLocal, messageSelector);
+        JmsMessageConsumer result = new JmsMessageConsumer(getNextConsumerId(), this, dest,
messageSelector, noLocal);
         result.init();
         return result;
     }


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org


Mime
View raw message