You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ta...@apache.org on 2014/09/29 15:42:41 UTC
git commit: Create the message level Destination and ReplyTo objects
lazily since we may never need them if the client doesn't call
getJMSDestination or getJMSReplyTo, pushes off the work to the client threads.
Repository: qpid-jms
Updated Branches:
refs/heads/master 0d7e2539a -> cc9f8dfea
Create the message level Destination and ReplyTo objects lazily since we
may never need them if the client doesn't call getJMSDestination or
getJMSReplyTo, pushes off the work to the client threads.
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/cc9f8dfe
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/cc9f8dfe
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/cc9f8dfe
Branch: refs/heads/master
Commit: cc9f8dfea8e91aabf5b50a9edfc120f90ba0841a
Parents: 0d7e253
Author: Timothy Bish <ta...@gmail.com>
Authored: Mon Sep 29 09:42:22 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Mon Sep 29 09:42:22 2014 -0400
----------------------------------------------------------------------
.../provider/amqp/message/AmqpJmsMessageFacade.java | 13 ++++++++++---
1 file changed, 10 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/cc9f8dfe/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java
index 02f3d7e..8d1b774 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/message/AmqpJmsMessageFacade.java
@@ -67,6 +67,7 @@ public class AmqpJmsMessageFacade implements JmsMessageFacade {
private JmsDestination replyTo;
private JmsDestination destination;
+ private JmsDestination consumerDestination;
private Long syntheticTTL;
@@ -103,6 +104,7 @@ public class AmqpJmsMessageFacade implements JmsMessageFacade {
public AmqpJmsMessageFacade(AmqpConsumer consumer, Message message) {
this.message = message;
this.connection = consumer.getConnection();
+ this.consumerDestination = consumer.getDestination();
annotations = message.getMessageAnnotations();
if (annotations != null) {
@@ -118,9 +120,6 @@ public class AmqpJmsMessageFacade implements JmsMessageFacade {
if (absoluteExpiryTime == null && ttl != null) {
syntheticTTL = System.currentTimeMillis() + ttl;
}
-
- this.destination = AmqpDestinationHelper.INSTANCE.getJmsDestination(this, consumer.getDestination());
- this.replyTo = AmqpDestinationHelper.INSTANCE.getJmsReplyTo(this, consumer.getDestination());
}
/**
@@ -580,6 +579,10 @@ public class AmqpJmsMessageFacade implements JmsMessageFacade {
@Override
public JmsDestination getDestination() {
+ if (destination == null) {
+ this.destination = AmqpDestinationHelper.INSTANCE.getJmsDestination(this, consumerDestination);
+ }
+
return destination;
}
@@ -592,6 +595,10 @@ public class AmqpJmsMessageFacade implements JmsMessageFacade {
@Override
public JmsDestination getReplyTo() {
+ if (replyTo == null) {
+ replyTo = AmqpDestinationHelper.INSTANCE.getJmsReplyTo(this, consumerDestination);
+ }
+
return replyTo;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org