com.bigdata.ha.pipeline

Class HASendService.IncSendTask

java.lang.Object

com.bigdata.ha.pipeline.HASendService.IncSendTask

All Implemented Interfaces:

Callable<Void>

Enclosing class:

HASendService

protected class HASendService.IncSendTask
extends Object
implements Callable<Void>

This task implements the raw data transfer. Each instance of this task sends the Buffer.remaining() bytes in a single ByteBuffer to the receiving service on a specified InetSocketAddress.

Constructor Summary

Constructors

Constructor and Description
HASendService.IncSendTask(ByteBuffer data, byte[] marker)

Method Summary

Methods

Modifier and Type	Method and Description
Void	call()

Methods inherited from class java.lang.Object

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

Constructor Detail

HASendService.IncSendTask

public HASendService.IncSendTask(ByteBuffer data,
                         byte[] marker)

Method Detail

call

public Void call()
          throws Exception

Specified by:

call in interface Callable<Void>

Throws:

Exception