Package | Description |
---|---|
org.apache.qpid.jms |
The core AMQP JMS client implementation classes.
|
org.apache.qpid.jms.message | |
org.apache.qpid.jms.meta | |
org.apache.qpid.jms.provider | |
org.apache.qpid.jms.provider.amqp | |
org.apache.qpid.jms.provider.failover |
Modifier and Type | Method and Description |
---|---|
JmsConsumerId |
JmsMessageConsumer.getConsumerId() |
protected JmsConsumerId |
JmsSession.getNextConsumerId() |
Constructor and Description |
---|
JmsDurableTopicSubscriber(JmsConsumerId id,
JmsSession s,
JmsDestination destination,
String name,
boolean noLocal,
String selector) |
JmsMessageConsumer(JmsConsumerId consumerId,
JmsSession session,
JmsDestination destination,
String selector,
boolean noLocal) |
JmsMessageConsumer(JmsConsumerId consumerId,
JmsSession session,
JmsDestination destination,
String name,
String selector,
boolean noLocal) |
JmsQueueReceiver(JmsConsumerId id,
JmsSession session,
JmsDestination dest,
String selector)
Constructor
|
Modifier and Type | Method and Description |
---|---|
JmsConsumerId |
JmsInboundMessageDispatch.getConsumerId() |
Modifier and Type | Method and Description |
---|---|
void |
JmsInboundMessageDispatch.setConsumerId(JmsConsumerId consumerId) |
Modifier and Type | Method and Description |
---|---|
JmsConsumerId |
JmsConsumerInfo.getId() |
Modifier and Type | Method and Description |
---|---|
int |
JmsConsumerId.compareTo(JmsConsumerId other) |
Constructor and Description |
---|
JmsConnectionId(JmsConsumerId id) |
JmsConsumerId(JmsConsumerId consumerId) |
JmsConsumerInfo(JmsConsumerId consumerId) |
JmsSessionId(JmsConsumerId id) |
Modifier and Type | Method and Description |
---|---|
void |
Provider.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request)
Request a remote peer send a Message to this client.
|
void |
ProviderWrapper.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request) |
Modifier and Type | Method and Description |
---|---|
JmsConsumerId |
AmqpConsumer.getConsumerId() |
Modifier and Type | Method and Description |
---|---|
AmqpConsumer |
AmqpSession.getConsumer(JmsConsumerId consumerId) |
void |
AmqpProvider.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request) |
Modifier and Type | Method and Description |
---|---|
void |
FailoverProvider.pull(JmsConsumerId consumerId,
long timeout,
AsyncResult request) |
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.