public abstract class FCPMessage
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
BUILD |
static java.lang.String |
BULK_CHK_INSERT_REJECTS |
static java.lang.String |
BULK_CHK_REQUEST_REJECTS |
static java.lang.String |
BULK_SSK_INSERT_REJECTS |
static java.lang.String |
BULK_SSK_REQUEST_REJECTS |
static java.lang.String |
CODE |
static java.lang.String |
HTL |
static java.lang.String |
IDENTIFIER |
static java.lang.String |
LINK_LENGTHS |
static java.lang.String |
LOCAL |
static java.lang.String |
LOCATION |
static java.lang.String |
OUTPUT_BANDWIDTH |
static java.lang.String |
OUTPUT_BANDWIDTH_CLASS |
static java.lang.String |
OVERALL_BULK_OUTPUT_CAPACITY_USAGE |
static java.lang.String |
PROBE_IDENTIFIER |
static java.lang.String |
STORE_SIZE |
static java.lang.String |
TYPE |
static java.lang.String |
UPTIME_PERCENT |
Constructor and Description |
---|
FCPMessage() |
Modifier and Type | Method and Description |
---|---|
static FCPMessage |
create(java.lang.String name,
SimpleFieldSet fs)
Create a message from a SimpleFieldSet, and the message's name, if possible.
|
static FCPMessage |
create(java.lang.String name,
SimpleFieldSet fs,
BucketFactory bfTemp,
PersistentTempBucketFactory bfPersistent)
Create a message from a SimpleFieldSet, and the message's name, if possible.
|
abstract SimpleFieldSet |
getFieldSet() |
abstract java.lang.String |
getName() |
abstract void |
run(FCPConnectionHandler handler,
Node node)
Do whatever it is that we do with this type of message.
|
void |
send(java.io.OutputStream os) |
static FCPMessage |
withListRequestIdentifier(FCPMessage fcpMessage,
java.lang.String listRequestIdentifier)
Returns an FCP message that delegates the methods
getFieldSet() , getName() ,
and run(FCPConnectionHandler, Node) to the given FCP message, adding a
“ListRequestIdentifier” field to the SimpleFieldSet returned by getFieldSet() . |
public static final java.lang.String BUILD
public static final java.lang.String CODE
public static final java.lang.String HTL
public static final java.lang.String IDENTIFIER
public static final java.lang.String LINK_LENGTHS
public static final java.lang.String LOCAL
public static final java.lang.String LOCATION
public static final java.lang.String OUTPUT_BANDWIDTH
public static final java.lang.String PROBE_IDENTIFIER
public static final java.lang.String STORE_SIZE
public static final java.lang.String TYPE
public static final java.lang.String UPTIME_PERCENT
public static final java.lang.String BULK_CHK_REQUEST_REJECTS
public static final java.lang.String BULK_SSK_REQUEST_REJECTS
public static final java.lang.String BULK_CHK_INSERT_REJECTS
public static final java.lang.String BULK_SSK_INSERT_REJECTS
public static final java.lang.String OUTPUT_BANDWIDTH_CLASS
public static final java.lang.String OVERALL_BULK_OUTPUT_CAPACITY_USAGE
public void send(java.io.OutputStream os) throws java.io.IOException
java.io.IOException
public abstract SimpleFieldSet getFieldSet()
public abstract java.lang.String getName()
public static FCPMessage create(java.lang.String name, SimpleFieldSet fs, BucketFactory bfTemp, PersistentTempBucketFactory bfPersistent) throws MessageInvalidException
MessageInvalidException
public static FCPMessage create(java.lang.String name, SimpleFieldSet fs) throws MessageInvalidException
MessageInvalidException
public static FCPMessage withListRequestIdentifier(FCPMessage fcpMessage, java.lang.String listRequestIdentifier)
getFieldSet()
, getName()
,
and run(FCPConnectionHandler, Node)
to the given FCP message, adding a
“ListRequestIdentifier” field to the SimpleFieldSet
returned by getFieldSet()
.fcpMessage
- The FCP message to wraplistRequestIdentifier
- The list request identifier to add (may be null
in which case nothing is
added)public abstract void run(FCPConnectionHandler handler, Node node) throws MessageInvalidException
MessageInvalidException