|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.universAAL.middleware.connectors.communication.jgroups.JGroupsCommunicationConnector
public class JGroupsCommunicationConnector
JGroup communication connector implementation
Constructor Summary | |
---|---|
JGroupsCommunicationConnector(ModuleContext context)
|
Method Summary | |
---|---|
void |
block()
|
void |
configureConnector(List<ChannelDescriptor> channels,
String peerName)
Configure the connector |
void |
dispose()
|
void |
dispose(List<ChannelDescriptor> channels)
Reset the CommunicationConnector |
String |
getDescription()
|
List<String> |
getGroupMembers(String groupName)
|
String |
getName()
|
String |
getProvider()
|
void |
getState(OutputStream output)
|
String |
getVersion()
|
Object |
handle(org.jgroups.Message msg)
|
boolean |
hasChannel(String channelName)
|
boolean |
init()
|
void |
loadConfigurations(Dictionary configurations)
This method allows the connector to obtain all the required configurations |
void |
multicast(ChannelMessage message)
Send multicast message to a group (Broadcast) |
void |
multicast(ChannelMessage message,
List<PeerCard> receivers)
Send multicast message to a list of recipients in the same group |
void |
receive(org.jgroups.Message msg)
|
void |
setDescription(String description)
|
void |
setName(String name)
|
void |
setProvider(String provider)
|
void |
setState(InputStream input)
|
void |
setVersion(String version)
|
void |
suspect(org.jgroups.Address suspectedMbr)
|
String |
toString()
|
void |
unblock()
|
void |
unicast(ChannelMessage message,
String receiver)
Send unicast message to one recipient |
void |
viewAccepted(org.jgroups.View newView)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public JGroupsCommunicationConnector(ModuleContext context) throws Exception
Exception
Method Detail |
---|
public void configureConnector(List<ChannelDescriptor> channels, String peerName) throws CommunicationConnectorException
CommunicationConnector
configureConnector
in interface CommunicationConnector
CommunicationConnectorException
public void dispose(List<ChannelDescriptor> channels)
CommunicationConnector
dispose
in interface CommunicationConnector
channels
- Channels to resetpublic void dispose()
dispose
in interface Connector
public void unicast(ChannelMessage message, String receiver) throws CommunicationConnectorException
CommunicationConnector
unicast
in interface CommunicationConnector
CommunicationConnectorException
public void multicast(ChannelMessage message) throws CommunicationConnectorException
CommunicationConnector
multicast
in interface CommunicationConnector
CommunicationConnectorException
public void multicast(ChannelMessage message, List<PeerCard> receivers) throws CommunicationConnectorException
CommunicationConnector
multicast
in interface CommunicationConnector
CommunicationConnectorException
public void loadConfigurations(Dictionary configurations)
Connector
loadConfigurations
in interface Connector
public String getName()
getName
in interface Connector
public String getVersion()
getVersion
in interface Connector
public String getDescription()
getDescription
in interface Connector
public String getProvider()
getProvider
in interface Connector
public void setName(String name)
public void setVersion(String version)
public void setDescription(String description)
public void setProvider(String provider)
public void receive(org.jgroups.Message msg)
receive
in interface org.jgroups.MessageListener
public void getState(OutputStream output) throws Exception
getState
in interface org.jgroups.MessageListener
Exception
public void setState(InputStream input) throws Exception
setState
in interface org.jgroups.MessageListener
Exception
public void block()
block
in interface org.jgroups.MembershipListener
public void suspect(org.jgroups.Address suspectedMbr)
suspect
in interface org.jgroups.MembershipListener
public void unblock()
unblock
in interface org.jgroups.MembershipListener
public void viewAccepted(org.jgroups.View newView)
viewAccepted
in interface org.jgroups.MembershipListener
public String toString()
toString
in interface CommunicationConnector
toString
in class Object
public Object handle(org.jgroups.Message msg) throws Exception
handle
in interface org.jgroups.blocks.RequestHandler
Exception
public boolean init()
init
in interface Connector
public List<String> getGroupMembers(String groupName)
getGroupMembers
in interface CommunicationConnector
public boolean hasChannel(String channelName)
hasChannel
in interface CommunicationConnector
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |