org.ddbstoolkit.toolkit.modules.middleware.jgroups

Class JGroupReceiver

java.lang.Object

org.ddbstoolkit.toolkit.modules.middleware.jgroups.JGroupReceiver

All Implemented Interfaces:

DistributableReceiverInterface, org.jgroups.blocks.RequestHandler

public class JGroupReceiver
extends java.lang.Object
implements org.jgroups.blocks.RequestHandler, DistributableReceiverInterface

Receiver using JGroups technology

Constructor Summary

Constructors

Constructor and Description
JGroupReceiver(DistributableEntityManager entityManager, java.lang.String clusterName, java.lang.String peerName) Constructor of the receiver

Method Summary

Modifier and Type	Method and Description
Peer	getMyPeer() Return the peer associated with the receiver
java.lang.Object	handle(org.jgroups.Message msg) When received a message
void	setEntityManager(DistributableEntityManager entityManager) Set the entity manager
void	start() Start the receiver
void	stop() Stop the receiver

Methods inherited from class java.lang.Object

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

Constructor Detail

JGroupReceiver

public JGroupReceiver(DistributableEntityManager entityManager,
                      java.lang.String clusterName,
                      java.lang.String peerName)

Constructor of the receiver

Parameters:

entityManager - Manager that will execute commands

clusterName - Name of the cluster

peerName - Name of the peer

Method Detail

getMyPeer

public Peer getMyPeer()

Description copied from interface: DistributableReceiverInterface

Return the peer associated with the receiver

Specified by:

getMyPeer in interface DistributableReceiverInterface

Returns:

Peer associated with the receiver

start

public void start()
           throws java.lang.Exception

Start the receiver

Specified by:

start in interface DistributableReceiverInterface

Throws:

java.lang.Exception - Exception

stop

public void stop()
          throws java.lang.Exception

Stop the receiver

Specified by:

stop in interface DistributableReceiverInterface

Throws:

java.lang.Exception - Error during closing the connection

setEntityManager

public void setEntityManager(DistributableEntityManager entityManager)

Set the entity manager

Specified by:

setEntityManager in interface DistributableReceiverInterface

Parameters:

entityManager - Entity manager to modify

handle

public java.lang.Object handle(org.jgroups.Message msg)
                        throws java.lang.Exception

When received a message

Specified by:

handle in interface org.jgroups.blocks.RequestHandler

Parameters:

msg - Message received

Returns:

Object handled

Throws:

java.lang.Exception