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 types with arguments of type RiakMessage

Modifier and Type	Method and Description
io.netty.util.concurrent.DefaultPromise<RiakMessage>	HealthCheckDecoder.getPromise()

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)

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	StoreOperation.createChannelMessage()
protected RiakMessage	StoreBucketPropsOperation.createChannelMessage()
protected RiakMessage	SecondaryIndexQueryOperation.createChannelMessage()
protected RiakMessage	SearchOperation.createChannelMessage()
protected RiakMessage	ResetBucketPropsOperation.createChannelMessage()
protected RiakMessage	PingOperation.createChannelMessage()
protected RiakMessage	MapReduceOperation.createChannelMessage()
protected RiakMessage	ListKeysOperation.createChannelMessage()
protected RiakMessage	ListBucketsOperation.createChannelMessage()
protected RiakMessage	FetchOperation.createChannelMessage()
protected RiakMessage	FetchBucketPropsOperation.createChannelMessage()
protected RiakMessage	DtUpdateOperation.createChannelMessage()
protected RiakMessage	DtFetchOperation.createChannelMessage()
protected RiakMessage	DeleteOperation.createChannelMessage()

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

Modifier and Type	Method and Description
static void	Operations.checkMessageType(RiakMessage msg, byte expected)
protected Void	YzPutSchemaOperation.decode(RiakMessage rawMessage)
protected Void	YzPutIndexOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakYokozunaPB.RpbYokozunaSchemaGetResp	YzGetSchemaOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakYokozunaPB.RpbYokozunaIndexGetResp	YzFetchIndexOperation.decode(RiakMessage rawMessage)
protected Void	YzDeleteIndexOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakKvPB.RpbPutResp	StoreOperation.decode(RiakMessage rawMessage)
protected Void	StoreBucketPropsOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakKvPB.RpbIndexResp	SecondaryIndexQueryOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakSearchPB.RpbSearchQueryResp	SearchOperation.decode(RiakMessage rawMessage)
protected Void	ResetBucketPropsOperation.decode(RiakMessage rawMessage)
protected Void	PingOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakKvPB.RpbMapRedResp	MapReduceOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakKvPB.RpbListKeysResp	ListKeysOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakKvPB.RpbListBucketsResp	ListBucketsOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakKvPB.RpbGetResp	FetchOperation.decode(RiakMessage message)
protected com.basho.riak.protobuf.RiakPB.RpbGetBucketResp	FetchBucketPropsOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakDtPB.DtUpdateResp	DtUpdateOperation.decode(RiakMessage rawMessage)
protected com.basho.riak.protobuf.RiakDtPB.DtFetchResp	DtFetchOperation.decode(RiakMessage rawMessage)
protected Void	DeleteOperation.decode(RiakMessage rawResponse)