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

Class VirtualMachineCassandraCommunicator

java.lang.Object

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

All Implemented Interfaces:

Communicator

public class VirtualMachineCassandraCommunicator
extends Object
implements Communicator

Virtual Machine Cassandra Communicator.

Author:

msimonin

Constructor Summary

Constructors

Constructor and Description
VirtualMachineCassandraCommunicator(org.inria.myriads.snoozecommon.communication.NetworkAddress groupLeaderAddress, DatabaseSettings databaseSettings) Virtual Machine Cassandra Communicator.

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

VirtualMachineCassandraCommunicator

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

Virtual Machine Cassandra Communicator.

Parameters:

groupLeaderAddress - Group leader address.

databaseSettings - Database settings.

Throws:

IOException - 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