pl.edu.agh.age.services.worker.internal

Interface WorkerCommunication

All Known Implementing Classes:

DefaultWorkerService

public interface WorkerCommunication

Internal API for worker services.

Method Summary

Modifier and Type	Method and Description
ListenableScheduledFuture<?>	scheduleAtFixedRate(java.lang.Runnable command, long initialDelay, long period, java.util.concurrent.TimeUnit unit)
void	sendMessage(WorkerMessage<java.io.Serializable> message) Send a message to other worker services in the distributed environment.

Method Detail

sendMessage

void sendMessage(WorkerMessage<java.io.Serializable> message)

Send a message to other worker services in the distributed environment.

Parameters:

message - a message to send.

scheduleAtFixedRate

ListenableScheduledFuture<?> scheduleAtFixedRate(java.lang.Runnable command,
                                                 long initialDelay,
                                                 long period,
                                                 java.util.concurrent.TimeUnit unit)