Package | Description |
---|---|
org.ow2.joram.mom.amqp |
Modifier and Type | Field and Description |
---|---|
private Map<Integer,PublishRequest> |
AMQPConnectionListener.openChannel
Contains the opened channels.
|
(package private) List<PublishRequest> |
ChannelContext.pubToCommit
The publish requests waiting the Tx.Commit command.
|
Modifier and Type | Method and Description |
---|---|
private PublishRequest |
AMQPConnectionListener.createPublishRequest(int channel) |
Modifier and Type | Method and Description |
---|---|
void |
Proxy.basicPublish(PublishRequest publishRequest) |
static void |
StubLocal.basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
static void |
StubAgentIn.basicPublish(PublishRequest publishRequest,
short serverId,
long proxyId) |
private void |
AMQPConnectionListener.doProcessBody(byte[] body,
PublishRequest publishRequest,
int channelNumber)
Process the content body.
|
private void |
AMQPConnectionListener.doProcessHeader(MarshallingHeader header,
PublishRequest publishRequest,
int channelNumber)
Process the content header.
|
private void |
AMQPConnectionListener.sendToProxy(PublishRequest publishRequest) |
Copyright © 2023 ScalAgent D.T.. All rights reserved.