Package net.dv8tion.jda.internal.requests

Class WebSocketClient

java.lang.Object

com.neovisionaries.ws.client.WebSocketAdapter

net.dv8tion.jda.internal.requests.WebSocketClient

All Implemented Interfaces:

WebSocketListener

public class WebSocketClient
extends WebSocketAdapter
implements WebSocketListener

Field Summary

Fields

Modifier and Type	Field	Description
static final org.slf4j.Logger	LOG
WebSocket	socket
static final ThreadLocal<Boolean>	WS_THREAD

Constructor Summary

Constructors

Constructor	Description
WebSocketClient(JDAImpl api, Compression compression, int gatewayIntents, GatewayEncoding encoding)

Method Summary

Modifier and Type	Method	Description
void	cancelChunkRequest(String nonce)
void	close()
void	close(int code)
void	close(int code, String reason)
MemberChunkManager	getChunkManager()
int	getGatewayIntents()
<T extends SocketHandler> T	getHandler(String type)
Map<String,SocketHandler>	getHandlers()
JDA	getJDA()
void	handle(List<DataObject> events)
void	handleCallbackError(WebSocket websocket, Throwable cause)
boolean	isConnected()
boolean	isReady()
boolean	isSession()
void	onBinaryMessage(WebSocket websocket, byte[] binary)
void	onConnected(WebSocket websocket, Map<String,List<String>> headers)
void	onDisconnected(WebSocket websocket, WebSocketFrame serverCloseFrame, WebSocketFrame clientCloseFrame, boolean closedByServer)
void	onError(WebSocket websocket, WebSocketException cause)
void	onTextMessage(WebSocket websocket, byte[] data)
void	onThreadCreated(WebSocket websocket, ThreadType threadType, Thread thread)
void	onThreadStarted(WebSocket websocket, ThreadType threadType, Thread thread)
void	queueAudioConnect(AudioChannel channel)
void	queueAudioDisconnect(Guild guild)
void	queueAudioReconnect(AudioChannel channel)
void	ready()
void	reconnect(boolean callFromQueue)	This method is used to start the reconnect of the JDA instance.
ConnectionRequest	removeAudioConnection(long guildId)
void	send(DataObject message)
void	sendChunkRequest(DataObject request)
void	setAutoReconnect(boolean reconnect)
void	shutdown()
ConnectionRequest	updateAudioConnection(long guildId, AudioChannel connectedChannel)
ConnectionRequest	updateAudioConnection0(long guildId, AudioChannel connectedChannel)

Methods inherited from class com.neovisionaries.ws.client.WebSocketAdapter

onBinaryFrame, onCloseFrame, onConnectError, onContinuationFrame, onFrame, onFrameError, onFrameSent, onFrameUnsent, onMessageDecompressionError, onMessageError, onPingFrame, onPongFrame, onSendError, onSendingFrame, onSendingHandshake, onStateChanged, onTextFrame, onTextMessage, onTextMessageError, onThreadStopping, onUnexpectedError

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.neovisionaries.ws.client.WebSocketListener

onBinaryFrame, onCloseFrame, onConnectError, onContinuationFrame, onFrame, onFrameError, onFrameSent, onFrameUnsent, onMessageDecompressionError, onMessageError, onPingFrame, onPongFrame, onSendError, onSendingFrame, onSendingHandshake, onStateChanged, onTextFrame, onTextMessage, onTextMessageError, onThreadStopping, onUnexpectedError

Field Details

WS_THREAD

public static final ThreadLocal<Boolean> WS_THREAD

LOG

public static final org.slf4j.Logger LOG

socket

public WebSocket socket

Constructor Details

WebSocketClient

public WebSocketClient(JDAImpl api,
 Compression compression,
 int gatewayIntents,
 GatewayEncoding encoding)

Method Details

getJDA

public JDA getJDA()

setAutoReconnect

public void setAutoReconnect(boolean reconnect)

isConnected

public boolean isConnected()

getGatewayIntents

public int getGatewayIntents()

getChunkManager

public MemberChunkManager getChunkManager()

ready

public void ready()

isReady

public boolean isReady()

isSession

public boolean isSession()

handle

public void handle(List<DataObject> events)

send

public void send(DataObject message)

cancelChunkRequest

public void cancelChunkRequest(String nonce)

sendChunkRequest

public void sendChunkRequest(DataObject request)

close

public void close()

close

public void close(int code)

close

public void close(int code,
 String reason)

shutdown

public void shutdown()

onThreadStarted

public void onThreadStarted(WebSocket websocket,
 ThreadType threadType,
 Thread thread)
                     throws Exception

Specified by:

onThreadStarted in interface WebSocketListener

Overrides:

onThreadStarted in class WebSocketAdapter

Throws:

Exception

onConnected

public void onConnected(WebSocket websocket,
 Map<String,List<String>> headers)

Specified by:

onConnected in interface WebSocketListener

Overrides:

onConnected in class WebSocketAdapter

onDisconnected

public void onDisconnected(WebSocket websocket,
 WebSocketFrame serverCloseFrame,
 WebSocketFrame clientCloseFrame,
 boolean closedByServer)

Specified by:

onDisconnected in interface WebSocketListener

Overrides:

onDisconnected in class WebSocketAdapter

reconnect

public void reconnect(boolean callFromQueue)
               throws InterruptedException

This method is used to start the reconnect of the JDA instance. It is public for access from SessionReconnectQueue extensions.

Parameters:

callFromQueue - whether this was in SessionReconnectQueue and got polled

Throws:

InterruptedException

onTextMessage

public void onTextMessage(WebSocket websocket,
 byte[] data)

Specified by:

onTextMessage in interface WebSocketListener

Overrides:

onTextMessage in class WebSocketAdapter

onBinaryMessage

public void onBinaryMessage(WebSocket websocket,
 byte[] binary)
                     throws DataFormatException

Specified by:

onBinaryMessage in interface WebSocketListener

Overrides:

onBinaryMessage in class WebSocketAdapter

Throws:

DataFormatException

handleCallbackError

public void handleCallbackError(WebSocket websocket,
 Throwable cause)
                         throws Exception

Specified by:

handleCallbackError in interface WebSocketListener

Overrides:

handleCallbackError in class WebSocketAdapter

Throws:

Exception

onError

public void onError(WebSocket websocket,
 WebSocketException cause)
             throws Exception

Specified by:

onError in interface WebSocketListener

Overrides:

onError in class WebSocketAdapter

Throws:

Exception

onThreadCreated

public void onThreadCreated(WebSocket websocket,
 ThreadType threadType,
 Thread thread)
                     throws Exception

Specified by:

onThreadCreated in interface WebSocketListener

Overrides:

onThreadCreated in class WebSocketAdapter

Throws:

Exception

queueAudioReconnect

public void queueAudioReconnect(AudioChannel channel)

queueAudioConnect

public void queueAudioConnect(AudioChannel channel)

queueAudioDisconnect

public void queueAudioDisconnect(Guild guild)

removeAudioConnection

public ConnectionRequest removeAudioConnection(long guildId)

updateAudioConnection

public ConnectionRequest updateAudioConnection(long guildId,
 AudioChannel connectedChannel)

updateAudioConnection0

public ConnectionRequest updateAudioConnection0(long guildId,
 AudioChannel connectedChannel)

getHandlers

public Map<String,SocketHandler> getHandlers()

getHandler

public <T extends SocketHandler> T getHandler(String type)