Package | Description |
---|---|
org.objectweb.joram.client.jms |
The
org.objectweb.joram.client.jms package holds the classes implementing the interfaces defined by the JMS 1.1 specification. |
org.objectweb.joram.client.jms.connection | |
org.objectweb.joram.client.jms.local | |
org.objectweb.joram.client.jms.tcp |
The
org.objectweb.joram.client.jms.tcp package holds the ConnectionFactory and Connection classes specialized for supporting the TCP protocol as client - server communication protocol. |
org.objectweb.joram.mom.proxies |
The
org.objectweb.joram.mom.proxies package holds the classes implementing the MOM proxy, basically linking external client applications to destination agents. |
org.objectweb.joram.shared.client |
The
org.objectweb.joram.shared.client package holds the request and reply objects used in the client-provider interactions. |
Modifier and Type | Method and Description |
---|---|
(package private) AbstractJmsReply |
Session.syncRequest(AbstractJmsRequest request)
Called by MessageConsumer.
|
(package private) AbstractJmsReply |
Connection.syncRequest(AbstractJmsRequest request) |
Modifier and Type | Method and Description |
---|---|
boolean |
MessageConsumerListener.replyReceived(AbstractJmsReply reply)
Called by RequestMultiplexer.
|
Modifier and Type | Method and Description |
---|---|
AbstractJmsReply |
RequestChannel.receive() |
AbstractJmsReply |
MultiThreadSyncChannel.receive() |
AbstractJmsReply |
Requestor.request(AbstractJmsRequest request) |
AbstractJmsReply |
Requestor.request(AbstractJmsRequest request,
CompletionListener completionListener) |
AbstractJmsReply |
Requestor.request(AbstractJmsRequest request,
long timeout,
CompletionListener completionListener)
Method sending a synchronous request to the server and waiting for an
answer.
|
Modifier and Type | Method and Description |
---|---|
private void |
RequestMultiplexer.abortReply(AbstractJmsReply reply) |
boolean |
Requestor.replyReceived(AbstractJmsReply reply) |
boolean |
ReplyListener.replyReceived(AbstractJmsReply reply) |
private void |
RequestMultiplexer.route(AbstractJmsReply reply,
boolean isCompletionListener)
Not synchronized because it may be called by the
demultiplexer during a concurrent close.
|
Modifier and Type | Method and Description |
---|---|
AbstractJmsReply |
LocalRequestChannel.receive() |
Modifier and Type | Method and Description |
---|---|
AbstractJmsReply |
TcpRequestChannel.receive() |
AbstractJmsReply |
ReliableTcpConnection.receive() |
Modifier and Type | Field and Description |
---|---|
(package private) AbstractJmsReply |
SyncReply.reply
The reply to send.
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
ClientContext.addPendingDelivery(AbstractJmsReply reply)
Adds a pending delivery.
|
private void |
UserAgent.doReply(AbstractJmsReply reply)
Method used for sending an
AbstractJmsReply back to an
external client within the active context. |
void |
StandardConnectionContext.pushReply(AbstractJmsReply reply) |
void |
ReliableConnectionContext.pushReply(AbstractJmsReply reply) |
void |
ConnectionContext.pushReply(AbstractJmsReply reply) |
void |
UserAgent.sendToClient(int key,
AbstractJmsReply reply)
Sends a reply to the client connected through
the specified connection.
|
Constructor and Description |
---|
SyncReply(int key,
AbstractJmsReply reply)
Constructs a
SyncReply instance. |
Modifier and Type | Class and Description |
---|---|
class |
AddClientIDReply
A
AddClientIDReply replies to a AddClientIDRequest . |
class |
CnxCloseReply
A
CnxCloseReply replies to a CnxCloseRequest . |
class |
CnxConnectReply
A
CnxConnectReply is sent by a JMS proxy as a reply to a
connection CnxConnectRequest and holds the connection's key
and the proxy identifier. |
class |
ConsumerMessages
A
ConsumerMessages is used by a JMS proxy for sending messages
to a consumer. |
class |
GetAdminTopicReply
A
GetAdminTopicReply is sent by an administrator proxy for
notifying an administrator client of the identifier of the local admin
topic. |
class |
MomExceptionReply
A
MomExceptionReply instance is used by a JMS client proxy
to send a MomException back to a JMS client. |
class |
QBrowseReply
A
QBrowseReply instance is used by a JMS client proxy for
forwarding a BrowseReply destination notification,
actually replying to a client QBrowseRequest . |
class |
ServerReply
A
ServerReply is used by a JMS proxy for
acknowledging the receipt of a synchronous AbstractJmsRequest
request. |
class |
SessCreateDestReply
A
SessCreateTDReply is used by a JMS proxy for replying
to a SessCreate<TQ/TT>Request . |
class |
XACnxRecoverReply
A
XACnxRecoverReply replies to a
XACnxRecoverRequest and carries transaction identifiers. |
Copyright © 2021 ScalAgent D.T.. All rights reserved.