Package | Description |
---|---|
org.ow2.joram.mom.amqp | |
org.ow2.joram.mom.amqp.structures |
Modifier and Type | Field and Description |
---|---|
private SortedSet<Message> |
Queue.toAck |
private SortedSet<Message> |
Queue.toDeliver |
Modifier and Type | Method and Description |
---|---|
static Message |
StubAgentIn.basicGet(AMQP.Basic.Get basicGet,
short serverId,
long proxyId) |
static Message |
StubLocal.basicGet(String queueName,
boolean noAck,
short serverId,
long proxyId) |
Message |
Queue.receive(boolean noAck,
short serverId,
long proxyId) |
Modifier and Type | Method and Description |
---|---|
int |
Message.compareTo(Message o) |
void |
Queue.publish(Message msg,
boolean immediate,
short serverId,
long proxyId) |
private void |
Queue.saveMessage(Message msg) |
Modifier and Type | Method and Description |
---|---|
private void |
Queue.deleteAllMessage(Set<Message> messages) |
Modifier and Type | Method and Description |
---|---|
Message |
PublishToQueue.getMessage() |
Copyright © 2023 ScalAgent D.T.. All rights reserved.