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/04/06 16:18:54 UTC
svn commit: r1737984 - in /qpid/java/trunk:
broker-core/src/main/java/org/apache/qpid/server/message/
broker-core/src/main/java/org/apache/qpid/server/queue/
broker-core/src/main/java/org/apache/qpid/server/virtualhost/
broker-core/src/test/java/org/ap...
Author: kwall
Date: Wed Apr 6 14:18:54 2016
New Revision: 1737984
URL: http://svn.apache.org/viewvc?rev=1737984&view=rev
Log:
QPID-7154: [Java Broker] Ensure that acquisition is locked by the correct consumer (0-10)
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/message/MessageInstance.java
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractSystemMessageSource.java
qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/MockMessageInstance.java
qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTestBase.java
qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueTest.java
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ConsumerTarget_0_10.java
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ExplicitAcceptDispositionChangeListener.java
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ImplicitAcceptDispositionChangeListener.java
qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSession.java
qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java
qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapImpl.java
qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapTest.java
qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java
qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/message/MessageInstance.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/message/MessageInstance.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/message/MessageInstance.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/message/MessageInstance.java Wed Apr 6 14:18:54 2016
@@ -70,7 +70,7 @@ public interface MessageInstance
boolean acquire(ConsumerImpl sub);
- boolean lockAcquisition();
+ boolean lockAcquisition(final ConsumerImpl consumer);
boolean unlockAcquisition();
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/queue/QueueEntryImpl.java Wed Apr 6 14:18:54 2016
@@ -291,10 +291,10 @@ public abstract class QueueEntryImpl imp
}
@Override
- public boolean lockAcquisition()
+ public boolean lockAcquisition(final ConsumerImpl consumer)
{
EntryState state = _state;
- if(state instanceof ConsumerAcquiredState)
+ if(state instanceof ConsumerAcquiredState && ((ConsumerAcquiredState) state).getConsumer() == consumer)
{
LockedAcquiredState lockedState = ((ConsumerAcquiredState) state).getLockedState();
boolean updated = _stateUpdater.compareAndSet(this, state, lockedState);
@@ -304,7 +304,7 @@ public abstract class QueueEntryImpl imp
}
return updated;
}
- return state instanceof LockedAcquiredState;
+ return state instanceof LockedAcquiredState && ((LockedAcquiredState) state).getConsumer() == consumer;
}
@Override
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractSystemMessageSource.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractSystemMessageSource.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractSystemMessageSource.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/virtualhost/AbstractSystemMessageSource.java Wed Apr 6 14:18:54 2016
@@ -448,7 +448,7 @@ public abstract class AbstractSystemMess
}
@Override
- public boolean lockAcquisition()
+ public boolean lockAcquisition(final ConsumerImpl consumer)
{
return false;
}
Modified: qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/MockMessageInstance.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/MockMessageInstance.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/MockMessageInstance.java (original)
+++ qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/MockMessageInstance.java Wed Apr 6 14:18:54 2016
@@ -101,7 +101,7 @@ public class MockMessageInstance impleme
}
@Override
- public boolean lockAcquisition()
+ public boolean lockAcquisition(final ConsumerImpl consumer)
{
return false;
}
Modified: qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTestBase.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTestBase.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTestBase.java (original)
+++ qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/QueueEntryImplTestBase.java Wed Apr 6 14:18:54 2016
@@ -170,13 +170,33 @@ public abstract class QueueEntryImplTest
assertFalse("Acquisition should initially be locked",_queueEntry.removeAcquisitionFromConsumer(consumer));
assertTrue("Should be able to unlock locked queue entry",_queueEntry.unlockAcquisition());
- assertTrue("Should be able to unlock locked queue entry",_queueEntry.lockAcquisition());
+ assertTrue("Should be able to lock queue entry",_queueEntry.lockAcquisition(consumer));
assertFalse("Acquisition should not be able to be hijacked when locked",_queueEntry.removeAcquisitionFromConsumer(consumer));
_queueEntry.delete();
assertTrue("Locked queue entry should be able to be deleted", _queueEntry.isDeleted());
}
+ public void testLockAcquisitionOwnership()
+ {
+ QueueConsumer consumer1 = newConsumer();
+ QueueConsumer consumer2 = newConsumer();
+
+ _queueEntry.acquire(consumer1);
+ assertTrue("Queue entry should be acquired by consumer1", _queueEntry.acquiredByConsumer());
+
+ assertTrue("Consumer1 relocking should be allowed", _queueEntry.lockAcquisition(consumer1));
+ assertFalse("Consumer2 should not be allowed", _queueEntry.lockAcquisition(consumer2));
+
+ _queueEntry.unlockAcquisition();
+
+ assertTrue("Queue entry should still be acquired by consumer1", _queueEntry.acquiredByConsumer());
+
+ _queueEntry.release(consumer1);
+
+ assertFalse("Queue entry should no longer be acquired by consumer1", _queueEntry.acquiredByConsumer());
+ }
+
/**
* A helper method to get entry state
*
Modified: qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueTest.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueTest.java (original)
+++ qpid/java/trunk/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueTest.java Wed Apr 6 14:18:54 2016
@@ -354,7 +354,7 @@ public class StandardQueueTest extends A
}
@Override
- public boolean lockAcquisition()
+ public boolean lockAcquisition(final ConsumerImpl consumer)
{
return true;
}
Modified: qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ConsumerTarget_0_10.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/ConsumerTarget_0_10.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ConsumerTarget_0_10.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ConsumerTarget_0_10.java Wed Apr 6 14:18:54 2016
@@ -402,10 +402,10 @@ public class ConsumerTarget_0_10 extends
});
}
- void reject(final MessageInstance entry)
+ void reject(final ConsumerImpl consumer, final MessageInstance entry)
{
entry.setRedelivered();
- if (entry.lockAcquisition())
+ if (entry.lockAcquisition(consumer))
{
entry.routeToAlternate(null, null);
}
@@ -422,7 +422,9 @@ public class ConsumerTarget_0_10 extends
return false;
}
- void release(final MessageInstance entry, final boolean setRedelivered)
+ void release(final ConsumerImpl consumer,
+ final MessageInstance entry,
+ final boolean setRedelivered)
{
if (setRedelivered)
{
@@ -436,20 +438,20 @@ public class ConsumerTarget_0_10 extends
if (isMaxDeliveryLimitReached(entry))
{
- sendToDLQOrDiscard(entry);
+ sendToDLQOrDiscard(consumer, entry);
}
else
{
- entry.release(entry.getAcquiringConsumer());
+ entry.release(consumer);
}
}
- protected void sendToDLQOrDiscard(MessageInstance entry)
+ protected void sendToDLQOrDiscard(final ConsumerImpl consumer, MessageInstance entry)
{
final ServerMessage msg = entry.getMessage();
int requeues = 0;
- if (entry.lockAcquisition())
+ if (entry.lockAcquisition(consumer))
{
requeues = entry.routeToAlternate(new Action<MessageInstance>()
{
Modified: qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ExplicitAcceptDispositionChangeListener.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/ExplicitAcceptDispositionChangeListener.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ExplicitAcceptDispositionChangeListener.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ExplicitAcceptDispositionChangeListener.java Wed Apr 6 14:18:54 2016
@@ -52,12 +52,12 @@ class ExplicitAcceptDispositionChangeLis
public void onRelease(boolean setRedelivered)
{
- _target.release(_entry, setRedelivered);
+ _target.release(_consumer, _entry, setRedelivered);
}
public void onReject()
{
- _target.reject(_entry);
+ _target.reject(_consumer, _entry);
}
public boolean acquire()
Modified: qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ImplicitAcceptDispositionChangeListener.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/ImplicitAcceptDispositionChangeListener.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ImplicitAcceptDispositionChangeListener.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ImplicitAcceptDispositionChangeListener.java Wed Apr 6 14:18:54 2016
@@ -51,13 +51,13 @@ class ImplicitAcceptDispositionChangeLis
public void onRelease(boolean setRedelivered)
{
- _target.release(_entry, setRedelivered);
+ _target.release(_consumer, _entry, setRedelivered);
}
public void onReject()
{
- _target.reject(_entry);
+ _target.reject(_consumer, _entry);
}
public boolean acquire()
Modified: qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSession.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/ServerSession.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSession.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-10-protocol/src/main/java/org/apache/qpid/server/protocol/v0_10/ServerSession.java Wed Apr 6 14:18:54 2016
@@ -527,7 +527,7 @@ public class ServerSession extends Sessi
final ConsumerTarget_0_10 target,
final MessageInstance entry)
{
- if (entry.lockAcquisition())
+ if (entry.lockAcquisition(consumer))
{
_transaction.dequeue(entry.getEnqueueRecord(),
new ServerTransaction.Action()
Modified: qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/AMQChannel.java Wed Apr 6 14:18:54 2016
@@ -1776,7 +1776,7 @@ public class AMQChannel
{
final ServerMessage msg = rejectedQueueEntry.getMessage();
int requeues = 0;
- if (rejectedQueueEntry.lockAcquisition())
+ if (rejectedQueueEntry.lockAcquisition(rejectedQueueEntry.getAcquiringConsumer()))
{
requeues = rejectedQueueEntry.routeToAlternate(new Action<MessageInstance>()
{
Modified: qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapImpl.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapImpl.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapImpl.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/main/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapImpl.java Wed Apr 6 14:18:54 2016
@@ -21,7 +21,6 @@
package org.apache.qpid.server.protocol.v0_8;
import java.util.ArrayList;
-import java.util.Arrays;
import java.util.Collection;
import java.util.Collections;
import java.util.LinkedHashMap;
@@ -156,7 +155,7 @@ public class UnacknowledgedMessageMapImp
List<MessageInstance> acknowledged = new ArrayList<>();
for (MessageInstance instance : ackedMessageMap.values())
{
- if (instance.lockAcquisition())
+ if (instance.lockAcquisition(instance.getAcquiringConsumer()))
{
acknowledged.add(instance);
}
@@ -170,7 +169,7 @@ public class UnacknowledgedMessageMapImp
{
instance = remove(deliveryTag);
}
- if(instance != null && instance.lockAcquisition())
+ if(instance != null && instance.lockAcquisition(instance.getAcquiringConsumer()))
{
return Collections.singleton(instance);
}
Modified: qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapTest.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapTest.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapTest.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-0-8-protocol/src/test/java/org/apache/qpid/server/protocol/v0_8/UnacknowledgedMessageMapTest.java Wed Apr 6 14:18:54 2016
@@ -25,11 +25,14 @@ import static org.mockito.Mockito.when;
import java.util.Collection;
+import org.apache.qpid.server.consumer.ConsumerImpl;
import org.apache.qpid.server.message.MessageInstance;
import org.apache.qpid.test.utils.QpidTestCase;
public class UnacknowledgedMessageMapTest extends QpidTestCase
{
+ private final ConsumerImpl _consumer = mock(ConsumerImpl.class);
+
public void testDeletedMessagesCantBeAcknowledged()
{
UnacknowledgedMessageMap map = new UnacknowledgedMessageMapImpl(100);
@@ -47,8 +50,8 @@ public class UnacknowledgedMessageMapTes
map = new UnacknowledgedMessageMapImpl(100);
msgs = populateMap(map,expectedSize);
// simulate some messages being ttl expired
- when(msgs[2].lockAcquisition()).thenReturn(Boolean.FALSE);
- when(msgs[4].lockAcquisition()).thenReturn(Boolean.FALSE);
+ when(msgs[2].lockAcquisition(_consumer)).thenReturn(Boolean.FALSE);
+ when(msgs[4].lockAcquisition(_consumer)).thenReturn(Boolean.FALSE);
assertEquals(expectedSize,map.size());
@@ -77,7 +80,8 @@ public class UnacknowledgedMessageMapTes
private MessageInstance createMessageInstance(final int id)
{
MessageInstance instance = mock(MessageInstance.class);
- when(instance.lockAcquisition()).thenReturn(Boolean.TRUE);
+ when(instance.lockAcquisition(_consumer)).thenReturn(Boolean.TRUE);
+ when(instance.getAcquiringConsumer()).thenReturn(_consumer);
return instance;
}
}
Modified: qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java (original)
+++ qpid/java/trunk/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/ConsumerTarget_1_0.java Wed Apr 6 14:18:54 2016
@@ -388,7 +388,7 @@ class ConsumerTarget_1_0 extends Abstrac
if(outcome instanceof Accepted)
{
- _queueEntry.lockAcquisition();
+ _queueEntry.lockAcquisition(getConsumer());
txn.dequeue(_queueEntry.getEnqueueRecord(),
new ServerTransaction.Action()
{
Modified: qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java (original)
+++ qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementNode.java Wed Apr 6 14:18:54 2016
@@ -1118,7 +1118,7 @@ class ManagementNode implements MessageS
}
@Override
- public boolean lockAcquisition()
+ public boolean lockAcquisition(final ConsumerImpl consumer)
{
return false;
}
Modified: qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java?rev=1737984&r1=1737983&r2=1737984&view=diff
==============================================================================
--- qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java (original)
+++ qpid/java/trunk/broker-plugins/management-amqp/src/main/java/org/apache/qpid/server/management/amqp/ManagementResponse.java Wed Apr 6 14:18:54 2016
@@ -157,7 +157,7 @@ class ManagementResponse implements Mess
}
@Override
- public boolean lockAcquisition()
+ public boolean lockAcquisition(final ConsumerImpl consumer)
{
return false;
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org