You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by ro...@apache.org on 2014/11/11 17:35:05 UTC
[2/5] qpid-jms git commit: remove producers map that isnt currently
really used
remove producers map that isnt currently really used
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo
Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/b8bb34b7
Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/b8bb34b7
Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/b8bb34b7
Branch: refs/heads/master
Commit: b8bb34b7a1defdd5a584dee9309191109a73fd69
Parents: 2d617c8
Author: Robert Gemmell <ro...@apache.org>
Authored: Tue Nov 11 11:46:35 2014 +0000
Committer: Robert Gemmell <ro...@apache.org>
Committed: Tue Nov 11 11:46:35 2014 +0000
----------------------------------------------------------------------
.../org/apache/qpid/jms/provider/amqp/AmqpSession.java | 12 ++----------
1 file changed, 2 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/b8bb34b7/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java
----------------------------------------------------------------------
diff --git a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java
index 3ffd792..2882db8 100644
--- a/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java
+++ b/qpid-jms-client/src/main/java/org/apache/qpid/jms/provider/amqp/AmqpSession.java
@@ -42,7 +42,6 @@ public class AmqpSession extends AmqpAbstractResource<JmsSessionInfo, Session> {
private final AmqpTransactionContext txContext;
private final Map<JmsConsumerId, AmqpConsumer> consumers = new HashMap<JmsConsumerId, AmqpConsumer>();
- private final Map<JmsProducerId, AmqpProducer> producers = new HashMap<JmsProducerId, AmqpProducer>();
public AmqpSession(AmqpConnection connection, JmsSessionInfo info) {
super(info, connection.getProtonConnection().session());
@@ -124,7 +123,8 @@ public class AmqpSession extends AmqpAbstractResource<JmsSessionInfo, Session> {
if (producerId.getProviderHint() instanceof AmqpProducer) {
return (AmqpProducer) producerId.getProviderHint();
}
- return this.producers.get(producerId);
+
+ return null;
}
public AmqpConsumer createConsumer(JmsConsumerInfo consumerInfo) {
@@ -214,14 +214,6 @@ public class AmqpSession extends AmqpAbstractResource<JmsSessionInfo, Session> {
consumers.remove(consumer.getConsumerId());
}
- void addResource(AmqpProducer producer) {
- producers.put(producer.getProducerId(), producer);
- }
-
- void removeResource(AmqpProducer producer) {
- producers.remove(producer.getProducerId());
- }
-
/**
* Adds Topic or Queue qualifiers to the destination target. We don't add qualifiers to
* Temporary Topics and Queues since AMQP works a bit differently.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org