Author: rhs
Date: Thu Jul 17 19:52:35 2014
New Revision: 1611457
URL: http://svn.apache.org/r1611457
Log:
coalesce duplicate events
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/CollectorImpl.java
Modified:
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/CollectorImpl.java
URL:
http://svn.apache.org/viewvc/qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/CollectorImpl.java?rev=1611457&r1=1611456&r2=1611457&view=diff
==============================================================================
---
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/CollectorImpl.java
(original)
+++
qpid/proton/trunk/proton-j/src/main/java/org/apache/qpid/proton/engine/impl/CollectorImpl.java
Thu Jul 17 19:52:35 2014
@@ -60,6 +60,11 @@ public class CollectorImpl implements Co
public EventImpl put(Event.Type type, Object context)
{
+ if (tail != null && tail.getType() == type &&
+ tail.getContext() == context) {
+ return null;
+ }
+
EventImpl event;
if (free == null) {
event = new EventImpl();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
