Author: grkvlt
Date: Thu Mar 3 01:57:20 2011
New Revision: 1076494
URL: http://svn.apache.org/viewvc?rev=1076494&view=rev
Log:
QPID-3070: Do not send SessionCompleted with empty range
Modified:
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java
Modified:
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java
URL:
http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java?rev=1076494&r1=1076493&r2=1076494&view=diff
==============================================================================
---
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java
(original)
+++
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/Session.java
Thu Mar 3 01:57:20 2011
@@ -421,7 +421,10 @@ public class Session extends SessionInvo
{
return;
}
- sessionCompleted(copy, options);
+ if (copy.size() > 0)
+ {
+ sessionCompleted(copy, options);
+ }
}
}
Modified:
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java
URL:
http://svn.apache.org/viewvc/qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java?rev=1076494&r1=1076493&r2=1076494&view=diff
==============================================================================
---
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java
(original)
+++
qpid/branches/grkvlt-network-20110301/qpid/java/common/src/main/java/org/apache/qpid/transport/SessionDelegate.java
Thu Mar 3 01:57:20 2011
@@ -92,7 +92,7 @@ public class SessionDelegate
known = new RangeSet();
}
- if (ranges != null)
+ if (ranges != null && ranges.size() > 0)
{
for (Range range : ranges)
{
@@ -104,7 +104,7 @@ public class SessionDelegate
}
}
- if (known != null)
+ if (known != null && known.size() > 0)
{
ssn.sessionKnownCompleted(known);
}
---------------------------------------------------------------------
Apache Qpid - AMQP Messaging Implementation
Project: http://qpid.apache.org
Use/Interact: mailto:[email protected]
