org.ow2.jonas.discovery.jgroups.comm.handler
Class DiscCommHandlerImpl

java.lang.Object
  org.ow2.jonas.discovery.jgroups.comm.handler.DiscCommHandlerImpl

All Implemented Interfaces:

org.jgroups.ExtendedMembershipListener, org.jgroups.ExtendedMessageListener, org.jgroups.ExtendedReceiver, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver, DiscCommReceiver

Direct Known Subclasses:

DiscCommGreetingHandler

public class DiscCommHandlerImpl
extends Object
implements DiscCommReceiver

Author:

eyindanga

Field Summary

String	discoveryType Host type: MASTER, SLAVE, CLUSTERD.
protected String	hostName The host name.
protected org.objectweb.util.monolog.api.Logger	logger The logger.
protected String	multicastAddress The host name.

Constructor Summary

DiscCommHandlerImpl(org.jgroups.Address hostAddress)

DiscCommHandlerImpl(org.jgroups.Address hostAddress, String discoveryType)
Contructor.

Method Summary

void	block()
org.jgroups.Address	getHostAddress()
byte[]	getState()
void	getState(OutputStream arg0)
byte[]	getState(String arg0)
void	getState(String arg0, OutputStream arg1)
void	receive(org.jgroups.Message msg)
void	sendNotif(org.jgroups.Address dest, DiscMessage msg) Sends a Discovery Message to the group.
void	setHostAddress(org.jgroups.Address hostAddress)
void	setState(byte[] arg0)
void	setState(InputStream arg0)
void	setState(String arg0, byte[] arg1)
void	setState(String arg0, InputStream arg1)
void	suspect(org.jgroups.Address arg0) Defines actions to perform when a group member is suspected.
void	unblock()
void	viewAccepted(org.jgroups.View arg0)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

logger

protected org.objectweb.util.monolog.api.Logger logger

The logger.

discoveryType

public String discoveryType

Host type: MASTER, SLAVE, CLUSTERD.

hostName

protected String hostName

The host name.

multicastAddress

protected String multicastAddress

The host name.

Constructor Detail

DiscCommHandlerImpl

public DiscCommHandlerImpl(org.jgroups.Address hostAddress,
                           String discoveryType)

Contructor.

Parameters:

hostAddress - IP address of discovery.

discoveryType - Host type.

DiscCommHandlerImpl

public DiscCommHandlerImpl(org.jgroups.Address hostAddress)

Parameters:

hostAddress - Discovery IP.

Method Detail

getState

public byte[] getState()

Specified by:

getState in interface org.jgroups.MessageListener

receive

public void receive(org.jgroups.Message msg)

Specified by:

receive in interface org.jgroups.MessageListener

sendNotif

public void sendNotif(org.jgroups.Address dest,
                      DiscMessage msg)

Sends a Discovery Message to the group.

Parameters:

dest -

msg -

setState

public void setState(byte[] arg0)

Specified by:

setState in interface org.jgroups.MessageListener

block

public void block()

Specified by:

block in interface org.jgroups.MembershipListener

suspect

public void suspect(org.jgroups.Address arg0)

Defines actions to perform when a group member is suspected.

Specified by:

suspect in interface org.jgroups.MembershipListener

Parameters:

arg0 -

viewAccepted

public void viewAccepted(org.jgroups.View arg0)

Specified by:

viewAccepted in interface org.jgroups.MembershipListener

getState

public byte[] getState(String arg0)

Specified by:

getState in interface org.jgroups.ExtendedMessageListener

getState

public void getState(OutputStream arg0)

Specified by:

getState in interface org.jgroups.ExtendedMessageListener

getState

public void getState(String arg0,
                     OutputStream arg1)

Specified by:

getState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(InputStream arg0)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(String arg0,
                     byte[] arg1)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener

setState

public void setState(String arg0,
                     InputStream arg1)

Specified by:

setState in interface org.jgroups.ExtendedMessageListener

unblock

public void unblock()

Specified by:

unblock in interface org.jgroups.ExtendedMembershipListener

getHostAddress

public org.jgroups.Address getHostAddress()

Returns:

the hostAddress

setHostAddress

public void setHostAddress(org.jgroups.Address hostAddress)

Parameters:

hostAddress - the hostAddress to set