|
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.exist.cluster.ClusterComunication
public class ClusterComunication
Manage the Cluster communication via RPC JGroups Created by Nicola Breda.
Field Summary | |
---|---|
static String |
CLUSTER_EXCLUDED_COLLECTIONS_ATTRIBUTE
|
static String |
CLUSTER_PROTOCOL_ATTRIBUTE
|
static String |
CLUSTER_PWD_ATTRIBUTE
|
static String |
CLUSTER_USER_ATTRIBUTE
|
static String |
CONFIGURATION_ELEMENT_NAME
|
static String |
DEFAULT_PROTOCOL_STACK
|
static String |
PROPERTY_CLUSTER_EXCLUDED_COLLECTIONS
|
static String |
PROPERTY_CLUSTER_PROTOCOL
|
static String |
PROPERTY_CLUSTER_PWD
|
static String |
PROPERTY_CLUSTER_USER
|
Method Summary | |
---|---|
void |
addCollection(String parent,
String collectionName)
|
void |
block()
|
static void |
configure(Configuration c)
Configure the cluster communication |
Address |
getAddress()
|
Configuration |
getConfiguration()
|
HashMap |
getConsoleInfos(Vector address)
|
ConsoleInfo |
getConsoleProperties()
|
Address |
getCoordinator()
|
static String |
getDbaPwd()
|
static String |
getDbaUser()
|
int[][] |
getHeaders()
|
static ClusterComunication |
getInstance()
********** --------------------------------------------------------- ********** |
Vector |
getMembersNoCoordinator()
|
int[] |
getNextDataRemote(String address)
|
ArrayList |
getNextEvents(int[] header,
int[] myHeader,
Integer start)
|
int[] |
getRemoteHeader()
|
void |
invoke(ClusterEvent event)
|
boolean |
isCoordinator()
************** --------- CONSOLE METHODS ---------- ******************************* |
void |
removeCollection(String parent,
String collection)
|
void |
removeDocument(String collection,
String documentName)
|
void |
stop()
|
void |
storeDocument(String collection,
String documentName,
String content)
|
void |
suspect(Address address)
|
void |
synch()
|
void |
update(String resource,
String name,
String xupdate)
|
void |
viewAccepted(View view)
---------------- MEMBERSHIP LISTENER METHODS ------------------------------ **** |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String CONFIGURATION_ELEMENT_NAME
public static final String CLUSTER_PROTOCOL_ATTRIBUTE
public static final String CLUSTER_USER_ATTRIBUTE
public static final String CLUSTER_PWD_ATTRIBUTE
public static final String CLUSTER_EXCLUDED_COLLECTIONS_ATTRIBUTE
public static final String PROPERTY_CLUSTER_PROTOCOL
public static final String PROPERTY_CLUSTER_USER
public static final String PROPERTY_CLUSTER_PWD
public static final String PROPERTY_CLUSTER_EXCLUDED_COLLECTIONS
public static final String DEFAULT_PROTOCOL_STACK
Method Detail |
---|
public static String getDbaUser()
public static String getDbaPwd()
public void viewAccepted(View view)
viewAccepted
in interface MembershipListener
public void suspect(Address address)
suspect
in interface MembershipListener
public void block()
block
in interface MembershipListener
public static ClusterComunication getInstance()
public boolean isCoordinator()
public Address getCoordinator()
public Address getAddress()
public Vector getMembersNoCoordinator()
public HashMap getConsoleInfos(Vector address)
public int[][] getHeaders() throws ClusterException
ClusterException
public Configuration getConfiguration()
public static void configure(Configuration c) throws ClusterException
c
-
ClusterException
public void synch() throws ClusterException
ClusterException
public void removeDocument(String collection, String documentName) throws ClusterException
ClusterException
public void storeDocument(String collection, String documentName, String content) throws ClusterException
ClusterException
public void addCollection(String parent, String collectionName) throws ClusterException
ClusterException
public void update(String resource, String name, String xupdate) throws ClusterException
ClusterException
public void removeCollection(String parent, String collection) throws ClusterException
ClusterException
public ArrayList getNextEvents(int[] header, int[] myHeader, Integer start)
public int[] getNextDataRemote(String address)
public void invoke(ClusterEvent event) throws ClusterException
ClusterException
public int[] getRemoteHeader() throws ClusterException
ClusterException
public ConsoleInfo getConsoleProperties() throws ClusterException
ClusterException
public void stop()
|
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |