diff options
Diffstat (limited to 'java/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueue.java')
| -rw-r--r-- | java/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueue.java | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueue.java b/java/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueue.java index 3185abc6cd..1f1e50a058 100644 --- a/java/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueue.java +++ b/java/broker-core/src/main/java/org/apache/qpid/server/queue/SortedQueue.java @@ -50,7 +50,7 @@ public class SortedQueue extends OutOfOrderQueue return _sortedPropertyName; } - public void enqueue(ServerMessage message, Action<MessageInstance> action) throws AMQException + public void enqueue(ServerMessage message, Action<MessageInstance<QueueConsumer>> action) throws AMQException { synchronized (_sortedQueueLock) { |