You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by kw...@apache.org on 2016/01/13 10:21:28 UTC
svn commit: r1724375 -
/qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java
Author: kwall
Date: Wed Jan 13 09:21:28 2016
New Revision: 1724375
URL: http://svn.apache.org/viewvc?rev=1724375&view=rev
Log:
QPID-6994: Remove superfluous unregister subscriptions at connection level, this is handled on all paths at the session level
Modified:
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java
Modified: qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java?rev=1724375&r1=1724374&r2=1724375&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerConnection.java Wed Jan 13 09:21:28 2016
@@ -419,7 +419,6 @@ public class ServerConnection extends Co
public void closed()
{
performDeleteTasks();
- closeSubscriptions();
if(_virtualHost != null)
{
@@ -430,14 +429,6 @@ public class ServerConnection extends Co
getEventLogger().message(isConnectionLost() ? ConnectionMessages.DROPPED_CONNECTION() : ConnectionMessages.CLOSE());
}
- private void closeSubscriptions()
- {
- for (Session ssn : getChannels())
- {
- ((ServerSession)ssn).unregisterSubscriptions();
- }
- }
-
private void markAllSessionsClosed()
{
for (Session ssn : getChannels())
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org