Package | Description |
---|---|
org.ow2.joram.mom.amqp |
Modifier and Type | Field and Description |
---|---|
private Queue |
QueueShell.queue |
Modifier and Type | Field and Description |
---|---|
private static ConcurrentHashMap<String,Queue> |
Naming.queues |
Modifier and Type | Method and Description |
---|---|
Queue |
QueueShell.getReference() |
static Queue |
Queue.loadQueue(String name) |
static Queue |
Naming.lookupQueue(String name) |
Modifier and Type | Method and Description |
---|---|
static Collection<Queue> |
Naming.getQueues() |
Modifier and Type | Method and Description |
---|---|
static void |
Naming.bindQueue(String name,
Queue ref) |
boolean |
StubAgentOut.deliver(String consumerTag,
int channelId,
Queue queue,
short serverId,
long proxyId) |
boolean |
Proxy.deliver(String consumerTag,
int channelNumber,
Queue queue,
short serverId,
long proxyId) |
boolean |
DeliveryListener.deliver(String consumerTag,
int channelNumber,
Queue queue,
short serverId,
long proxyId) |
private int |
Proxy.doGetDeliveries(String consumerTag,
int channelId,
int maxMessage,
Queue queue) |
private void |
Queue.saveQueue(Queue queue) |
Constructor and Description |
---|
QueueShell(Queue queue) |
Copyright © 2021 ScalAgent D.T.. All rights reserved.