Top Description Fields Constructors Methods
com.mysql.cj.protocol.x

public Class ResultMessageListener<R>

extends Object
implements MessageListener<XMessage>
Class Inheritance
All Implemented Interfaces
com.mysql.cj.protocol.MessageListener
Imports
java.util.HashMap, .Map, java.util.concurrent.CompletableFuture, com.google.protobuf.Message, com.mysql.cj.exceptions.WrongArgumentException, com.mysql.cj.protocol.MessageListener, .ProtocolEntity, .ProtocolEntityFactory, .ResultBuilder, com.mysql.cj.x.protobuf.Mysqlx.Error
A MessageListener to handle result data and propagate it to a ResultBuilder.

Field Summary

Modifier and TypeField and Description
private CompletableFuture<R>
future

private Map<Class<? extends Message>, ProtocolEntityFactory<? extends ProtocolEntity, XMessage>>
messageToProtocolEntityFactory

private ResultBuilder<?>
resultBuilder

Constructor Summary

AccessConstructor and Description
public
ResultMessageListener(Map<Class<? extends Message>, ProtocolEntityFactory<? extends ProtocolEntity, XMessage>> messageToProtocolEntityFactory, ResultBuilder<R> resultBuilder, CompletableFuture<R> future)

Method Summary

Modifier and TypeMethod and Description
public void
error(Throwable
exception to pass to underlying Future.
ex)

Implements com.mysql.cj.protocol.MessageListener.error.

Exceptionally complete underlying Future.

public boolean
processMessage(XMessage
Message instance
message)

Overrides default com.mysql.cj.protocol.MessageListener.processMessage.

Process protocol message.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

futureback to summary
private CompletableFuture<R> future
messageToProtocolEntityFactoryback to summary
private Map<Class<? extends Message>, ProtocolEntityFactory<? extends ProtocolEntity, XMessage>> messageToProtocolEntityFactory
resultBuilderback to summary
private ResultBuilder<?> resultBuilder

Constructor Detail

ResultMessageListenerback to summary
public ResultMessageListener(Map<Class<? extends Message>, ProtocolEntityFactory<? extends ProtocolEntity, XMessage>> messageToProtocolEntityFactory, ResultBuilder<R> resultBuilder, CompletableFuture<R> future)

Method Detail

errorback to summary
public void error(Throwable ex)

Implements com.mysql.cj.protocol.MessageListener.error.

Doc from com.mysql.cj.protocol.MessageListener.error.

Exceptionally complete underlying Future.

Parameters
ex:Throwable

exception to pass to underlying Future.

Annotations
@Override
processMessageback to summary
public boolean processMessage(XMessage message)

Overrides default com.mysql.cj.protocol.MessageListener.processMessage.

Doc from com.mysql.cj.protocol.MessageListener.processMessage.

Process protocol message.

Parameters
message:XMessage

Message instance

Returns:boolean

true - if this listener is done with processing the messages sequence and may be discarded; false - if the next message must be dispatched to the same listener

Annotations
@Override
@SuppressWarnings:unchecked