Package | Description |
---|---|
com.gigaspaces.lrmi.nio | |
com.gigaspaces.lrmi.nio.async | |
com.j_spaces.core.server.processor |
Modifier and Type | Method and Description |
---|---|
protected abstract ReplyPacket<?> |
SystemRequestHandlerImpl.AbstractWatchdogMonitorSystemRequestContext.createReplyPacket(boolean found,
ChannelEntry.State channelEntryState) |
protected ReplyPacket<?> |
SystemRequestHandlerImpl.WatchdogMonitorSystemRequestContextV950.createReplyPacket(boolean found,
ChannelEntry.State channelEntryState) |
protected ReplyPacket<?> |
SystemRequestHandlerImpl.WatchdogMonitorSystemRequestContext.createReplyPacket(boolean found,
ChannelEntry.State channelEntryState) |
<T> ReplyPacket<T> |
Reader.readReply() |
<T> ReplyPacket<T> |
Reader.readReply(boolean createNewBuffer) |
<T> ReplyPacket<T> |
Reader.readReply(int slowConsumerTimeout,
int sizeLimit) |
<T> ReplyPacket<T> |
Reader.unmarshallReply(MarshalInputStream stream) |
Modifier and Type | Method and Description |
---|---|
void |
DefaultResponseHandler.handleResponse(IResponseContext respContext,
ReplyPacket respPacket) |
void |
IResponseHandler.handleResponse(IResponseContext responseContext,
ReplyPacket<?> respPacket) |
<T> void |
Reader.readReply(ReplyPacket<T> packet) |
void |
Pivot.requestPending(ChannelEntry channel,
ReplyPacket<?> respPacket,
IResponseContext responseContext) |
void |
Pivot.sendResponse(ChannelEntry channelEntry,
ReplyPacket replyPacket,
IResponseContext respContext) |
void |
PivotResponseContext.sendResponseToClient(ReplyPacket<?> respPacket) |
void |
IResponseContext.sendResponseToClient(ReplyPacket<?> respPacket) |
void |
Writer.writeReply(ReplyPacket packet) |
void |
Writer.writeReply(ReplyPacket packet,
boolean reuseBuffer) |
void |
Writer.writeReply(ReplyPacket packet,
boolean reuseBuffer,
Writer.Context ctx) |
void |
ChannelEntry.writeReply(ReplyPacket packet,
boolean reuseBuffer,
Writer.Context ctx,
String monitoringId) |
Modifier and Type | Method and Description |
---|---|
void |
LRMIFuture.setResultPacket(ReplyPacket<T> replyPacket) |
Modifier and Type | Method and Description |
---|---|
void |
Processor.handleUpdateOrWrite(IResponseContext respContext,
UpdateOrWriteContext ctx,
ReplyPacket<?> respPacket) |
Constructor and Description |
---|
UpdateOrWriteBusPacket(OperationID operationID,
IResponseContext respContext,
UpdateOrWriteContext ctx,
ReplyPacket respPacket) |
Copyright © GigaSpaces.