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

public Class SimplePacketSender

extends Object
implements MessageSender<NativePacketPayload>
Class Inheritance
All Implemented Interfaces
com.mysql.cj.protocol.MessageSender
Imports
java.io.BufferedOutputStream, .IOException, com.mysql.cj.protocol.MessageSender
Simple implementation of MessageSender which handles the transmission of logical MySQL packets to the provided output stream. Large packets will be split into multiple chunks.

Field Summary

Modifier and TypeField and Description
private BufferedOutputStream
outputStream

Constructor Summary

AccessConstructor and Description
public
SimplePacketSender(BufferedOutputStream outputStream)

Method Summary

Modifier and TypeMethod and Description
public void
send(byte[]
byte array containing a message
packet, int
length of the message
packetLen, byte
message sequence index (used in a native protocol)
packetSequence)

Overrides default com.mysql.cj.protocol.MessageSender.send.

Synchronously send the message to server.

public MessageSender<NativePacketPayload>
undecorate()

Overrides default com.mysql.cj.protocol.MessageSender.undecorate.

Return the previous PacketSender instance from the decorators chain or the current PacketSender if it is the first entry in a chain.

public MessageSender<NativePacketPayload>
undecorateAll()

Overrides default com.mysql.cj.protocol.MessageSender.undecorateAll.

Return a PacketSender instance free of decorators.

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

outputStreamback to summary
private BufferedOutputStream outputStream

Constructor Detail

SimplePacketSenderback to summary
public SimplePacketSender(BufferedOutputStream outputStream)

Method Detail

sendback to summary
public void send(byte[] packet, int packetLen, byte packetSequence) throws IOException

Overrides default com.mysql.cj.protocol.MessageSender.send.

Doc from com.mysql.cj.protocol.MessageSender.send.

Synchronously send the message to server.

Parameters
packet:byte[]

byte array containing a message

packetLen:int

length of the message

packetSequence:byte

message sequence index (used in a native protocol)

Annotations
@Override
Exceptions
IOException:
if an error occurs
undecorateback to summary
public MessageSender<NativePacketPayload> undecorate()

Overrides default com.mysql.cj.protocol.MessageSender.undecorate.

Doc from com.mysql.cj.protocol.MessageSender.undecorate.

Return the previous PacketSender instance from the decorators chain or the current PacketSender if it is the first entry in a chain.

Returns:MessageSender<NativePacketPayload>

MessageSender instance

Annotations
@Override
undecorateAllback to summary
public MessageSender<NativePacketPayload> undecorateAll()

Overrides default com.mysql.cj.protocol.MessageSender.undecorateAll.

Doc from com.mysql.cj.protocol.MessageSender.undecorateAll.

Return a PacketSender instance free of decorators.

Returns:MessageSender<NativePacketPayload>

MessageSender instance

Annotations
@Override