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.notifications |
The
org.objectweb.joram.mom.notifications package holds the notifications used for interacting with the MOM destination agents. |
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 void |
Topic.clusterAdd(FwdAdminRequestNot req,
String joiningTopic)
Reaction to the request of adding a new cluster element.
|
private void |
ClusterQueue.clusterAdd(FwdAdminRequestNot req,
String joiningQueue)
Reaction to the request of adding a new cluster element.
|
void |
Topic.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
Queue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
ElasticTopic.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not)
This method handles the scaling operations.
|
protected void |
Destination.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
ClusterQueue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
void |
AliasInQueue.handleAdminRequestNot(AgentId from,
FwdAdminRequestNot not) |
private void |
ElasticTopic.handleGetSubscriptionsRequest(FwdAdminRequestNot not) |
private void |
ElasticTopic.handleScaleRequest(FwdAdminRequestNot not) |
Modifier and Type | Field and Description |
---|---|
private FwdAdminRequestNot |
ReconnectSubscribersNot.not |
private FwdAdminRequestNot |
GetClientSubscriptions.not |
Modifier and Type | Method and Description |
---|---|
FwdAdminRequestNot |
GetClientSubscriptions.getAdminNot() |
FwdAdminRequestNot |
ReconnectSubscribersNot.getNot() |
Constructor and Description |
---|
GetClientSubscriptions(FwdAdminRequestNot not) |
ReconnectSubscribersNot(ArrayList<Integer> subs,
ArrayList<Message> msgs,
FwdAdminRequestNot not) |
Modifier and Type | Method and Description |
---|---|
private void |
UserAgent.deleteProxy(FwdAdminRequestNot not)
This method deletes the proxy by notifying its connected clients,
denying the non acknowledged messages, deleting the temporary
destinations, removing the subscriptions.
|
private void |
UserAgent.doReact(FwdAdminRequestNot not) |
Copyright © 2020 ScalAgent D.T.. All rights reserved.