|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use QueueConsumer | |
---|---|
org.hornetq.rest.queue | |
org.hornetq.rest.topic |
Uses of QueueConsumer in org.hornetq.rest.queue |
---|
Subclasses of QueueConsumer in org.hornetq.rest.queue | |
---|---|
class |
AcknowledgedQueueConsumer
|
Fields in org.hornetq.rest.queue with type parameters of type QueueConsumer | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,QueueConsumer> |
ConsumersResource.queueConsumers
|
Methods in org.hornetq.rest.queue that return QueueConsumer | |
---|---|
QueueConsumer |
ConsumersResource.createAcknowledgedConsumer(java.lang.String selector)
|
QueueConsumer |
ConsumersResource.createConsumer(java.lang.String selector)
|
QueueConsumer |
ConsumersResource.findConsumer(int attributes,
java.lang.String consumerId,
javax.ws.rs.core.UriInfo uriInfo)
|
Methods in org.hornetq.rest.queue with parameters of type QueueConsumer | |
---|---|
protected void |
ConsumersResource.addConsumer(QueueConsumer consumer)
|
Uses of QueueConsumer in org.hornetq.rest.topic |
---|
Subclasses of QueueConsumer in org.hornetq.rest.topic | |
---|---|
class |
AcknowledgedSubscriptionResource
|
class |
SubscriptionResource
|
Fields in org.hornetq.rest.topic with type parameters of type QueueConsumer | |
---|---|
protected java.util.concurrent.ConcurrentHashMap<java.lang.String,QueueConsumer> |
SubscriptionsResource.queueConsumers
|
Methods in org.hornetq.rest.topic that return QueueConsumer | |
---|---|
protected QueueConsumer |
SubscriptionsResource.createConsumer(boolean durable,
boolean autoAck,
java.lang.String subscriptionName,
java.lang.String selector)
|
QueueConsumer |
SubscriptionsResource.findAcknoledgeSubscription(java.lang.String subscriptionId)
|
QueueConsumer |
SubscriptionsResource.findAutoAckSubscription(java.lang.String subscriptionId)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |