Class MemcachedResponse

java.lang.Object

org.infinispan.server.memcached.MemcachedResponse

Direct Known Subclasses:

BinaryResponse, TextResponse

public abstract class MemcachedResponse
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
protected final Header	header
protected int	responseBytes

Constructor Summary

Constructors

Constructor	Description
MemcachedResponse(Throwable failure, Header header)
MemcachedResponse(CompletionStage<?> response, Header header, io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)

Method Summary

Modifier and Type	Method	Description
void	flushed(io.netty.channel.ChannelFuture future)
CompletionStage<?>	getResponse()
boolean	isSuccessful()
protected void	useErrorMessage(String message)
abstract void	writeFailure(Throwable throwable, ByteBufPool allocator)
void	writeFailure(ByteBufPool allocator)
void	writeResponse(Object response, ByteBufPool allocator)

Methods inherited from class java.lang.Object

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

Field Details

header

protected final Header header

responseBytes

protected int responseBytes

Constructor Details

MemcachedResponse

public MemcachedResponse(CompletionStage<?> response,
 Header header,
 io.netty.util.concurrent.GenericFutureListener<? extends io.netty.util.concurrent.Future<? super Void>> listener)

MemcachedResponse

public MemcachedResponse(Throwable failure,
 Header header)

Method Details

getResponse

public CompletionStage<?> getResponse()

isSuccessful

public boolean isSuccessful()

writeResponse

public void writeResponse(Object response,
 ByteBufPool allocator)

writeFailure

public abstract void writeFailure(Throwable throwable,
 ByteBufPool allocator)

writeFailure

public void writeFailure(ByteBufPool allocator)

useErrorMessage

protected void useErrorMessage(String message)

flushed

public void flushed(io.netty.channel.ChannelFuture future)