diff options
Diffstat (limited to 'java/broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java')
| -rw-r--r-- | java/broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/java/broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java b/java/broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java index c29b9786df..1ef06728f8 100644 --- a/java/broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java +++ b/java/broker-core/src/main/java/org/apache/qpid/server/message/MessageSource.java @@ -32,13 +32,13 @@ import org.apache.qpid.server.store.TransactionLogResource; import java.util.Collection; import java.util.EnumSet; -public interface MessageSource extends TransactionLogResource, MessageNode +public interface MessageSource<C extends Consumer> extends TransactionLogResource, MessageNode { - Consumer addConsumer(ConsumerTarget target, FilterManager filters, + C addConsumer(ConsumerTarget target, FilterManager filters, Class<? extends ServerMessage> messageClass, String consumerName, EnumSet<Consumer.Option> options) throws AMQException; - Collection<Consumer> getConsumers(); + Collection<C> getConsumers(); void addConsumerRegistrationListener(ConsumerRegistrationListener listener); |