org.ddbstoolkit.toolkit.modules.middleware.sqlspaces

Class SqlSpacesReceiver

java.lang.Object

org.ddbstoolkit.toolkit.modules.middleware.sqlspaces.SqlSpacesReceiver

All Implemented Interfaces:

info.collide.sqlspaces.commons.Callback, DistributableReceiverInterface

public class SqlSpacesReceiver
extends java.lang.Object
implements info.collide.sqlspaces.commons.Callback, DistributableReceiverInterface

SQLSpaces receiver User: Cyril GRANDJEAN Date: 21/06/2012 Time: 10:18

Nested Class Summary

Nested classes/interfaces inherited from interface info.collide.sqlspaces.commons.Callback

info.collide.sqlspaces.commons.Callback.Command

Constructor Summary

Constructors

Constructor and Description
SqlSpacesReceiver(DistributableEntityManager entityManager, java.lang.String clusterName, java.lang.String peerName) Create a SqlSpaces Receiver using localhost server
SqlSpacesReceiver(DistributableEntityManager entityManager, java.lang.String clusterName, java.lang.String peerName, java.lang.String ipAddress, int port) Create a SqlSpaces Receiver using an external server

Method Summary

Modifier and Type	Method and Description
void	call(info.collide.sqlspaces.commons.Callback.Command c, int seq, info.collide.sqlspaces.commons.Tuple afterTuple, info.collide.sqlspaces.commons.Tuple beforeTuple)
Peer	getMyPeer() Return the peer associated with the receiver
void	setEntityManager(DistributableEntityManager entityManager) Set the entity manager
void	start() Start the receiver
void	stop() Stop to listen on the interface

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlSpacesReceiver

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

Create a SqlSpaces Receiver using localhost server

Parameters:

entityManager - Entity manager that will receive commands

clusterName - Name of the cluster

peerName - Name of the peer

SqlSpacesReceiver

public SqlSpacesReceiver(DistributableEntityManager entityManager,
                         java.lang.String clusterName,
                         java.lang.String peerName,
                         java.lang.String ipAddress,
                         int port)

Create a SqlSpaces Receiver using an external server

Parameters:

entityManager - Entity manager that will receive commands

clusterName - Name of the cluster

peerName - Name of the peer

ipAddress - Ip address of the SQLSpaces Server

port - Port of the SQLSpaces Server

Method Detail

setEntityManager

public void setEntityManager(DistributableEntityManager entityManager)

Description copied from interface: DistributableReceiverInterface

Set the entity manager

Specified by:

setEntityManager in interface DistributableReceiverInterface

Parameters:

entityManager - Entity manager to modify

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

call

public void call(info.collide.sqlspaces.commons.Callback.Command c,
                 int seq,
                 info.collide.sqlspaces.commons.Tuple afterTuple,
                 info.collide.sqlspaces.commons.Tuple beforeTuple)

Specified by:

call in interface info.collide.sqlspaces.commons.Callback

stop

public void stop()
          throws java.lang.Exception

Description copied from interface: DistributableReceiverInterface

Stop to listen on the interface

Specified by:

stop in interface DistributableReceiverInterface

Throws:

java.lang.Exception - Error during closing the connection