R
- the response typepublic class StreamSegmentResponseCommand<R> extends StreamResponseCommand<R>
Modifier and Type | Field and Description |
---|---|
static byte |
COMMAND_ID |
protected Set<Integer> |
missedSegments |
complete, csm, id, response
cacheName
Modifier | Constructor and Description |
---|---|
protected |
StreamSegmentResponseCommand() |
|
StreamSegmentResponseCommand(String cacheName) |
|
StreamSegmentResponseCommand(String cacheName,
Address origin,
Object id,
boolean complete,
R response,
Set<Integer> missedSegments) |
Modifier and Type | Method and Description |
---|---|
boolean |
canBlock()
If true, the command is processed asynchronously in a thread provided by an Infinispan thread pool.
|
byte |
getCommandId()
Used by marshallers to convert this command into an id for streaming.
|
boolean |
isReturnValueExpected()
If true, a return value will be provided when performed remotely.
|
Object |
perform(InvocationContext ctx)
Performs the primary function of the command.
|
void |
readFrom(ObjectInput input)
Reads this instance from the stream written by
ReplicableCommand.writeTo(ObjectOutput) . |
void |
writeTo(ObjectOutput output)
Writes this instance to the
ObjectOutput . |
inject
getCacheName, getOrigin, setOrigin, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getParameters, setParameters
public static final byte COMMAND_ID
protected StreamSegmentResponseCommand()
public StreamSegmentResponseCommand(String cacheName)
public Object perform(InvocationContext ctx) throws Throwable
ReplicableCommand
perform
in interface ReplicableCommand
perform
in class StreamResponseCommand<R>
ctx
- invocation contextThrowable
- in the event of problems.public byte getCommandId()
ReplicableCommand
getCommandId
in interface ReplicableCommand
getCommandId
in class StreamResponseCommand<R>
public void writeTo(ObjectOutput output) throws IOException
ReplicableCommand
ObjectOutput
.writeTo
in interface ReplicableCommand
writeTo
in class StreamResponseCommand<R>
output
- the stream.IOException
- if an error occurred during the I/O.public void readFrom(ObjectInput input) throws IOException, ClassNotFoundException
ReplicableCommand
ReplicableCommand.writeTo(ObjectOutput)
.readFrom
in interface ReplicableCommand
readFrom
in class StreamResponseCommand<R>
input
- the stream to read.IOException
- if an error occurred during the I/O.ClassNotFoundException
- if it tries to load an undefined class.public boolean isReturnValueExpected()
ReplicableCommand
ResponseGenerator
may choose to simply return null to save on marshalling costs.isReturnValueExpected
in interface ReplicableCommand
isReturnValueExpected
in class StreamResponseCommand<R>
public boolean canBlock()
ReplicableCommand
canBlock
in interface ReplicableCommand
canBlock
in class StreamResponseCommand<R>
true
if the command can block/wait, false
otherwiseCopyright © 2024 JBoss, a division of Red Hat. All rights reserved.