com.bigdata.service.jini.util
Class MessageTest.MessageTask

java.lang.Object
  com.bigdata.service.jini.util.MessageTest.MessageTask

All Implemented Interfaces:

Callable<Long>

Enclosing class:

MessageTest

public static class MessageTest.MessageTask
extends Object
implements Callable<Long>

A task which is sumitted to a service. The service then exchanges simple messages at the maximum rate for the specified duration with all of the other services. The task reports the #of messages which were successfully exchanged. Any errors will terminate the task.

Author:

Bryan Thompson

Constructor Summary

MessageTest.MessageTask(long duration, long messages, int parallel, int payload, IDataService[] dataServices)

Method Summary

Long	call() Pumps tasks into a fixed thread pool until done or interrupted.

Methods inherited from class java.lang.Object

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

Constructor Detail

MessageTest.MessageTask

public MessageTest.MessageTask(long duration,
                               long messages,
                               int parallel,
                               int payload,
                               IDataService[] dataServices)

Method Detail

call

public Long call()
          throws Exception

Pumps tasks into a fixed thread pool until done or interrupted.

Specified by:

call in interface Callable<Long>

Throws:

Exception