Uses of Class
com.basho.riak.client.core.RiakMessage

Packages that use RiakMessage

Package	Description
com.basho.riak.client.core
com.basho.riak.client.core.netty
com.basho.riak.client.core.operations

Uses of RiakMessage in com.basho.riak.client.core

Methods in com.basho.riak.client.core that return RiakMessage

Modifier and Type	Method and Description
protected abstract RiakMessage	FutureOperation.createChannelMessage()

Methods in com.basho.riak.client.core with parameters of type RiakMessage

Modifier and Type	Method and Description
protected abstract U	FutureOperation.decode(RiakMessage rawMessage)
void	RiakResponseListener.onSuccess(io.netty.channel.Channel channel, RiakMessage response)
void	RiakNode.onSuccess(io.netty.channel.Channel channel, RiakMessage response)
void	FutureOperation.setResponse(RiakMessage rawResponse)

Uses of RiakMessage in com.basho.riak.client.core.netty

Methods in com.basho.riak.client.core.netty that return RiakMessage

Modifier and Type	Method and Description
RiakMessage	HealthCheckDecoder.HealthCheckFuture.get()
RiakMessage	HealthCheckDecoder.HealthCheckFuture.get(long timeout, TimeUnit unit)
RiakMessage	HealthCheckDecoder.HealthCheckFuture.getNow()

Methods in com.basho.riak.client.core.netty that return types with arguments of type RiakMessage

Modifier and Type	Method and Description
RiakFuture<RiakMessage,Void>	HealthCheckDecoder.getFuture()

Methods in com.basho.riak.client.core.netty with parameters of type RiakMessage

Modifier and Type	Method and Description
protected void	RiakMessageCodec.encode(io.netty.channel.ChannelHandlerContext ctx, RiakMessage msg, io.netty.buffer.ByteBuf out)
void	HealthCheckDecoder.HealthCheckFuture.setMessage(RiakMessage m)

Method parameters in com.basho.riak.client.core.netty with type arguments of type RiakMessage

Modifier and Type	Method and Description
void	HealthCheckDecoder.HealthCheckFuture.addListener(RiakFutureListener<RiakMessage,Void> listener)
void	HealthCheckDecoder.HealthCheckFuture.removeListener(RiakFutureListener<RiakMessage,Void> listener)

Uses of RiakMessage in com.basho.riak.client.core.operations

Methods in com.basho.riak.client.core.operations that return RiakMessage

Modifier and Type	Method and Description
protected RiakMessage	YzPutSchemaOperation.createChannelMessage()
protected RiakMessage	YzPutIndexOperation.createChannelMessage()
protected RiakMessage	YzGetSchemaOperation.createChannelMessage()
protected RiakMessage	YzFetchIndexOperation.createChannelMessage()
protected RiakMessage	YzDeleteIndexOperation.createChannelMessage()
protected RiakMessage	TTBFutureOperation.createChannelMessage()
protected RiakMessage	StoreOperation.createChannelMessage()
protected RiakMessage	StoreBucketPropsOperation.createChannelMessage()
protected RiakMessage	SearchOperation.createChannelMessage()
protected RiakMessage	ResetBucketPropsOperation.createChannelMessage()
protected RiakMessage	PingOperation.createChannelMessage()
protected RiakMessage	PBFutureOperation.createChannelMessage()
protected RiakMessage	FetchOperation.createChannelMessage()
protected RiakMessage	FetchBucketPropsOperation.createChannelMessage()
protected RiakMessage	DtUpdateOperation.createChannelMessage()
protected RiakMessage	DtFetchOperation.createChannelMessage()
protected RiakMessage	DeleteOperation.createChannelMessage()
protected RiakMessage	CoveragePlanOperation.createChannelMessage()

Methods in com.basho.riak.client.core.operations with parameters of type RiakMessage

Modifier and Type	Method and Description
static void	Operations.checkPBMessageType(RiakMessage msg, byte expected)
protected Void	YzPutSchemaOperation.decode(RiakMessage rawMessage)
protected Void	YzPutIndexOperation.decode(RiakMessage rawMessage)
protected RiakYokozunaPB.RpbYokozunaSchemaGetResp	YzGetSchemaOperation.decode(RiakMessage rawMessage)
protected RiakYokozunaPB.RpbYokozunaIndexGetResp	YzFetchIndexOperation.decode(RiakMessage rawMessage)
protected Void	YzDeleteIndexOperation.decode(RiakMessage rawMessage)
protected byte[]	TTBFutureOperation.decode(RiakMessage rawMessage)
protected RiakKvPB.RpbPutResp	StoreOperation.decode(RiakMessage rawMessage)
protected Void	StoreBucketPropsOperation.decode(RiakMessage rawMessage)
protected Object	SecondaryIndexQueryOperation.decode(RiakMessage rawMessage)
protected RiakSearchPB.RpbSearchQueryResp	SearchOperation.decode(RiakMessage rawMessage)
protected Void	ResetBucketPropsOperation.decode(RiakMessage rawMessage)
protected Void	PingOperation.decode(RiakMessage rawMessage)
protected U	PBFutureOperation.decode(RiakMessage rawMessage)
protected RiakKvPB.RpbGetResp	FetchOperation.decode(RiakMessage message)
protected RiakPB.RpbGetBucketResp	FetchBucketPropsOperation.decode(RiakMessage rawMessage)
protected RiakDtPB.DtUpdateResp	DtUpdateOperation.decode(RiakMessage rawMessage)
protected RiakDtPB.DtFetchResp	DtFetchOperation.decode(RiakMessage rawMessage)
protected Void	DeleteOperation.decode(RiakMessage rawResponse)
protected RiakKvPB.RpbCoverageResp	CoveragePlanOperation.decode(RiakMessage rawMessage)