Package | Description |
---|---|
org.objectweb.joram.mom.dest |
The
org.objectweb.joram.mom.dest package holds the classes implementing the queue, topic and specialized destinations provided by JORAM's MOM. |
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. |
Modifier and Type | Method and Description |
---|---|
private AdminTopic.DestinationDesc |
AdminTopic.createDestination(String destName,
AgentId adminId,
Properties properties,
byte type,
String className,
String requestClassName,
StringBuffer strbuf)
Instantiating the destination class or retrieving the destination.
|
static AdminTopic.DestinationDesc |
AdminTopic.createDestinationAndSave(String destName,
AgentId adminId,
Properties properties,
byte type,
String className,
String requestClassName,
StringBuffer strbuf)
Deprecated.
|
static void |
AdminTopic.CreateUserAndSave(CreateUserRequest request,
AgentId replyTo,
String msgId)
Deprecated.
|
private void |
AdminTopic.doProcess(CreateDestinationRequest request,
AgentId replyTo,
String msgId)
Processes a
CreateDestinationRequest instance
requesting the creation of a destination. |
private void |
AdminTopic.doProcess(CreateUserRequest request,
AgentId replyTo,
String msgId)
Processes a
CreateUserRequest instance requesting the
creation of a UserAgent for a given user. |
private void |
AdminTopic.doProcess(UpdateUser request,
AgentId replyTo,
String msgId)
Processes an
UpdateUser instance requesting to modify the
identification of a user. |
static AdminTopic.DestinationDesc |
AdminTopic.lookupDest(String name,
byte type)
Retrieves an existing destination.
|
protected void |
DistributionQueue.processSetRight(AgentId user,
int right) |
protected void |
Destination.processSetRight(AgentId user,
int right)
set user right.
|
protected void |
AliasQueue.processSetRight(AgentId user,
int right) |
protected void |
AliasInQueue.processSetRight(AgentId user,
int right) |
Constructor and Description |
---|
AdminTopic()
Constructs an
AdminTopic agent. |
Modifier and Type | Method and Description |
---|---|
private void |
UserAgent.doReact(ConsumerSubRequest req)
Method implementing the JMS proxy reaction to a
ConsumerSubRequest
requesting to subscribe to a topic. |
private void |
UserAgent.doReact(SessCreateDestRequest req)
Method implementing the JMS proxy reaction to a
SessCreateDestRequest
requesting the creation of a destination. |
private void |
UserAgent.reactToClientRequest(int key,
ConsumerReceiveRequest req)
Either forwards the
ConsumerReceiveRequest request as a
ReceiveRequest directly to the target queue, or wraps it
and sends it to the proxy if destinated to a subscription. |
private void |
UserAgent.reactToClientRequest(int key,
ConsumerSetListRequest req)
Either forwards the
ConsumerSetListRequest request as a
ReceiveRequest directly to the target queue, or wraps it
and sends it to the proxy if destinated to a subscription. |
private void |
UserAgent.reactToClientRequest(int key,
ProducerMessages req,
CallbackNotification callbackNotification)
Forwards the messages sent by the client in a
ProducerMessages request as a ClientMessages
MOM request directly to a destination, and acknowledges them by sending
a ServerReply back. |
private void |
UserAgent.reactToClientRequest(int key,
QBrowseRequest req)
Forwards the client's
QBrowseRequest request as
a BrowseRequest MOM request directly to a destination. |
Constructor and Description |
---|
ClientSubscription(AgentId proxyId,
int contextId,
int reqId,
boolean durable,
AgentId topicId,
String name,
String selector,
boolean noLocal,
AgentId dmqId,
int threshold,
int nbMaxMsg,
MessageTable messagesTable,
String clientID)
Constructs a
ClientSubscription instance. |
Copyright © 2015 ScalAgent D.T.. All Rights Reserved.