org.inria.myriads.snoozenode.comunicator.api.impl

Class GroupManagerCassandraCommunicator

java.lang.Object

org.inria.myriads.snoozenode.comunicator.api.impl.GroupManagerCassandraCommunicator

All Implemented Interfaces:

Communicator

public class GroupManagerCassandraCommunicator
extends Object
implements Communicator

Group Manager Cassandra Communicator.

Author:

msimonin

Constructor Summary

Constructors

Constructor and Description
GroupManagerCassandraCommunicator(org.inria.myriads.snoozecommon.communication.NetworkAddress groupLeaderAddress, DatabaseSettings databaseSettings) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Closes the communicator.
void	sendHeartbeatData(Object data) Sends Heartbeat Data.
void	sendRegularData(Object data) Sends Regular data.

Methods inherited from class java.lang.Object

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

Constructor Detail

GroupManagerCassandraCommunicator

public GroupManagerCassandraCommunicator(org.inria.myriads.snoozecommon.communication.NetworkAddress groupLeaderAddress,
                                 DatabaseSettings databaseSettings)
                                  throws IOException

Constructor.

Parameters:

groupLeaderAddress - The groupLeader address.

databaseSettings - The database settings.

Throws:

IOException - Connection Exception.

Method Detail

sendRegularData

public void sendRegularData(Object data)
                     throws IOException

Description copied from interface: Communicator

Sends Regular data.

Specified by:

sendRegularData in interface Communicator

Parameters:

data - The data to send.

Throws:

IOException - Exception

sendHeartbeatData

public void sendHeartbeatData(Object data)
                       throws IOException

Description copied from interface: Communicator

Sends Heartbeat Data.

Specified by:

sendHeartbeatData in interface Communicator

Parameters:

data - The data to send as heartbeat.

Throws:

IOException - Exception.

close

public void close()

Description copied from interface: Communicator

Closes the communicator.

Specified by:

close in interface Communicator