org.ddbstoolkit.toolkit.modules.middleware.jgroups

Class JGroupSender

java.lang.Object

org.jgroups.ReceiverAdapter

org.ddbstoolkit.toolkit.modules.middleware.jgroups.JGroupSender

All Implemented Interfaces:

DistributableEntityManager, DistributableSenderInterface, UpdatableEntityManager, org.jgroups.MembershipListener, org.jgroups.MessageListener, org.jgroups.Receiver

public class JGroupSender
extends org.jgroups.ReceiverAdapter
implements DistributableSenderInterface

Class to send commands using JGroups technology

Field Summary

Fields

Modifier and Type	Field and Description
protected DDBSEntityManager<DDBSEntity<DDBSEntityProperty>>	ddbsEntityManager DDBS Entity manager

Constructor Summary

Constructors

Constructor and Description
JGroupSender(java.lang.String clusterName, java.lang.String peerName) Constructor of the sender

Method Summary

Modifier and Type	Method and Description
boolean	add(IEntity objectToAdd) Add an object
void	close() Stop connections
void	commit(DDBSTransaction transaction) Commit a transaction
boolean	createEntity(IEntity objectToCreate) Create the structure of the entity
boolean	delete(IEntity objectToDelete) Delete an object
DDBSTransaction	executeTransaction(DDBSTransaction transaction) Execute a list of actions
java.util.List<Peer>	getListPeers() Get the list of peers
boolean	isOpen() Indicates if the object can send commands
<T extends IEntity> java.util.List<T>	listAll(T object, Conditions conditions, OrderBy orderBy) List all entities of a specific object
<T extends IEntity> java.util.List<T>	listAllWithQueryString(T object, java.lang.String conditionQueryString, OrderBy orderBy) List all objects in a network
<T extends IEntity> T	loadArray(T objectToLoad, java.lang.String field, OrderBy orderBy) Load an array
void	open() Open connections
<T extends IEntity> T	read(T object) Read an object in the network
<T extends IEntity> T	readLastElement(T object) Read the last element added
void	rollback(DDBSTransaction transaction) Rollback the transaction
void	setAutoCommit(boolean isAutoCommit) Set the auto-commit for the data source
void	setTimeout(int timeout) Set the maximum timeout of each request
boolean	update(IEntity objectToUpdate) Update an object

Methods inherited from class org.jgroups.ReceiverAdapter

block, getState, receive, setState, suspect, unblock, viewAccepted

Methods inherited from class java.lang.Object

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

Field Detail

ddbsEntityManager

protected DDBSEntityManager<DDBSEntity<DDBSEntityProperty>> ddbsEntityManager

DDBS Entity manager

Constructor Detail

JGroupSender

public JGroupSender(java.lang.String clusterName,
                    java.lang.String peerName)

Constructor of the sender

Parameters:

clusterName - name of the cluster

peerName - name of the peer

Method Detail

getListPeers

public java.util.List<Peer> getListPeers()
                                  throws java.lang.Exception

Get the list of peers

Specified by:

getListPeers in interface DistributableSenderInterface

Returns:

List of peers

Throws:

java.lang.Exception - Exception

setTimeout

public void setTimeout(int timeout)

Set the maximum timeout of each request

Specified by:

setTimeout in interface DistributableSenderInterface

Parameters:

timeout - Timeout for this interface

isOpen

public boolean isOpen()

Indicates if the object can send commands

Specified by:

isOpen in interface DistributableEntityManager

Returns:

boolean

open

public void open()
          throws DDBSToolkitException

Open connections

Specified by:

open in interface DistributableEntityManager

Throws:

DDBSToolkitException - DDBS Toolkit exception

close

public void close()

Stop connections

Specified by:

close in interface DistributableEntityManager

setAutoCommit

public void setAutoCommit(boolean isAutoCommit)
                   throws DDBSToolkitException

Description copied from interface: DistributableEntityManager

Set the auto-commit for the data source

Specified by:

setAutoCommit in interface DistributableEntityManager

Parameters:

isAutoCommit - Boolean returning if there is auto-commit in the transaction

Throws:

DDBSToolkitException - : Error to set the auto-commit value

listAll

public <T extends IEntity> java.util.List<T> listAll(T object,
                                                     Conditions conditions,
                                                     OrderBy orderBy)
                                              throws DDBSToolkitException

List all entities of a specific object

Specified by:

listAll in interface DistributableEntityManager

Type Parameters:

T - IEntity extended entity

Parameters:

object - Object to search

conditions - Conditions to filter the results

orderBy - Order By Object

Returns:

list of entities that match the request

Throws:

DDBSToolkitException - Error during the process

listAllWithQueryString

public <T extends IEntity> java.util.List<T> listAllWithQueryString(T object,
                                                                    java.lang.String conditionQueryString,
                                                                    OrderBy orderBy)
                                                             throws DDBSToolkitException

List all objects in a network

Specified by:

listAllWithQueryString in interface DistributableEntityManager

Type Parameters:

T - IEntity extended entity

Parameters:

object - Object to search

conditionQueryString - Conditions query string

orderBy - String to order the results

Returns:

result list

Throws:

DDBSToolkitException - DDBS Toolkit exception

read

public <T extends IEntity> T read(T object)
                           throws DDBSToolkitException

Read an object in the network

Specified by:

read in interface DistributableEntityManager

Type Parameters:

T - IEntity extended entity

Parameters:

object - object to read

Returns:

object read

Throws:

DDBSToolkitException - DDBS Toolkit exception

readLastElement

public <T extends IEntity> T readLastElement(T object)
                                      throws DDBSToolkitException

Read the last element added

Specified by:

readLastElement in interface DistributableEntityManager

Type Parameters:

T - IEntity extended entity

Parameters:

object - object to read

Returns:

last object added

Throws:

DDBSToolkitException - DDBS Toolkit exception

add

public boolean add(IEntity objectToAdd)
            throws DDBSToolkitException

Add an object

Specified by:

add in interface UpdatableEntityManager

Parameters:

objectToAdd - Add an object to the database or data source

Returns:

boolean

Throws:

DDBSToolkitException - DDBS Toolkit exception

update

public boolean update(IEntity objectToUpdate)
               throws DDBSToolkitException

Update an object

Specified by:

update in interface UpdatableEntityManager

Parameters:

objectToUpdate - Object to update

Returns:

object updated

Throws:

DDBSToolkitException - DDBS Toolkit exception

delete

public boolean delete(IEntity objectToDelete)
               throws DDBSToolkitException

Delete an object

Specified by:

delete in interface UpdatableEntityManager

Parameters:

objectToDelete - Object to delete

Returns:

boolean

Throws:

DDBSToolkitException - DDBS Toolkit exception

createEntity

public boolean createEntity(IEntity objectToCreate)
                     throws DDBSToolkitException

Description copied from interface: UpdatableEntityManager

Create the structure of the entity

Specified by:

createEntity in interface UpdatableEntityManager

Parameters:

objectToCreate - Object to create

Returns:

boolean if the transaction has succeeded

Throws:

DDBSToolkitException - Problem during operation

loadArray

public <T extends IEntity> T loadArray(T objectToLoad,
                                       java.lang.String field,
                                       OrderBy orderBy)
                                throws DDBSToolkitException

Load an array

Specified by:

loadArray in interface DistributableEntityManager

Type Parameters:

T - IEntity extended entity

Parameters:

objectToLoad - Object to load

field - Array to load

orderBy - order by field

Returns:

object loaded

Throws:

DDBSToolkitException - DDBS Toolkit exception

commit

public void commit(DDBSTransaction transaction)
            throws DDBSToolkitException

Description copied from interface: DistributableEntityManager

Commit a transaction

Specified by:

commit in interface DistributableEntityManager

Parameters:

transaction - Transaction

Throws:

DDBSToolkitException - : Error to commit the transaction

rollback

public void rollback(DDBSTransaction transaction)
              throws DDBSToolkitException

Description copied from interface: DistributableEntityManager

Rollback the transaction

Specified by:

rollback in interface DistributableEntityManager

Parameters:

transaction - Transaction

Throws:

DDBSToolkitException - : Error to rollback the connection

executeTransaction

public DDBSTransaction executeTransaction(DDBSTransaction transaction)
                                   throws DDBSToolkitException

Description copied from interface: DistributableEntityManager

Execute a list of actions

Specified by:

executeTransaction in interface DistributableEntityManager

Parameters:

transaction - List of commands

Returns:

transaction executed

Throws:

DDBSToolkitException - : Error to execute the transaction