org.maestro.client.notes

Class DrainRequest

java.lang.Object

org.maestro.client.notes.MaestroEvent<T>

org.maestro.client.notes.MaestroRequest<MaestroReceiverEventListener>

org.maestro.client.notes.DrainRequest

All Implemented Interfaces:

MaestroNote

public class DrainRequest
extends MaestroRequest<MaestroReceiverEventListener>

Constructor Summary

Constructors

Constructor and Description
DrainRequest()
DrainRequest(org.msgpack.core.MessageUnpacker unpacker)

Method Summary

Modifier and Type	Method and Description
MessageCorrelation	correlate()
void	correlate(MaestroNote note)
void	correlate(MessageCorrelation correlation)
boolean	correlatesTo(MaestroNote note)
boolean	correlatesTo(MessageCorrelation correlation)
String	getDuration()
MaestroCommand	getMaestroCommand() Gets the Maestro command for the note
MaestroNoteType	getNoteType() Gets the note type
String	getParallelCount()
String	getUrl()
String	getWorkerName()
void	notify(MaestroReceiverEventListener visitor)
protected org.msgpack.core.MessageBufferPacker	pack()
byte[]	serialize() Serialize the note
void	setDuration(String duration)
void	setParallelCount(String parallelCount)
void	setUrl(String url)
void	setWorkerName(String workerName)
String	toString() Converts the note to string for debugging purposes

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.maestro.common.client.notes.MaestroNote

hasNext, next

Constructor Detail

DrainRequest

public DrainRequest()

DrainRequest

public DrainRequest(org.msgpack.core.MessageUnpacker unpacker)
             throws IOException

Throws:

IOException

Method Detail

getDuration

public String getDuration()

setDuration

public void setDuration(String duration)

getUrl

public String getUrl()

setUrl

public void setUrl(String url)

getParallelCount

public String getParallelCount()

setParallelCount

public void setParallelCount(String parallelCount)

getWorkerName

public String getWorkerName()

setWorkerName

public void setWorkerName(String workerName)

notify

public void notify(MaestroReceiverEventListener visitor)

Specified by:

notify in class MaestroEvent<MaestroReceiverEventListener>

pack

protected org.msgpack.core.MessageBufferPacker pack()
                                             throws IOException

Throws:

IOException

toString

public String toString()

Description copied from interface: MaestroNote

Converts the note to string for debugging purposes

Specified by:

toString in interface MaestroNote

Overrides:

toString in class MaestroRequest<MaestroReceiverEventListener>

Returns:

the note in String format

getNoteType

public MaestroNoteType getNoteType()

Description copied from interface: MaestroNote

Gets the note type

Specified by:

getNoteType in interface MaestroNote

Returns:

the note type

getMaestroCommand

public MaestroCommand getMaestroCommand()

Description copied from interface: MaestroNote

Gets the Maestro command for the note

Specified by:

getMaestroCommand in interface MaestroNote

Returns:

the maestro command as an instance of MaestroCommand

correlate

public MessageCorrelation correlate()

Specified by:

correlate in interface MaestroNote

correlate

public void correlate(MessageCorrelation correlation)

Specified by:

correlate in interface MaestroNote

correlate

public void correlate(MaestroNote note)

Specified by:

correlate in interface MaestroNote

correlatesTo

public boolean correlatesTo(MessageCorrelation correlation)

Specified by:

correlatesTo in interface MaestroNote

correlatesTo

public boolean correlatesTo(MaestroNote note)

Specified by:

correlatesTo in interface MaestroNote

serialize

public final byte[] serialize()
                       throws IOException

Description copied from interface: MaestroNote

Serialize the note

Specified by:

serialize in interface MaestroNote

Returns:

The serialized note

Throws:

IOException - if unable to serialize the note