Package com.github.twitch4j.pubsub

Klasse TwitchPubSub

java.lang.Object

com.github.twitch4j.pubsub.TwitchPubSub

Alle implementierten Schnittstellen:

ITwitchPubSub, AutoCloseable

public class TwitchPubSub
extends Object
implements ITwitchPubSub

Twitch PubSub

Feldübersicht

Felder

Modifizierer und Typ	Feld	Beschreibung
protected final BlockingQueue<String>	commandQueue	Command Queue
protected final Future<?>	heartbeatTask	Heartbeat Thread
protected boolean	isClosed	is Closed?
protected long	lastPing	Last Ping send (1 minute delay before sending the first ping)
protected long	lastPong	Last Pong received
protected final Future<?>	queueTask	Command Queue Thread
static final int	REQUIRED_THREAD_COUNT
protected final Set<PubSubRequest>	subscribedTopics	Holds the subscribed topics in case we need to reconnect
protected final ScheduledExecutorService	taskExecutor	Thread Pool Executor

Konstruktorübersicht

Konstruktoren

Konstruktor	Beschreibung
TwitchPubSub(WebsocketConnection websocketConnection, EventManager eventManager, ScheduledThreadPoolExecutor taskExecutor, ProxyConfig proxyConfig, Collection<String> botOwnerIds, int wsPingPeriod, IBackoffStrategy connectionBackoffStrategy, int wsCloseDelay, Consumer<PubSubResponsePayload> fallbackTopicHandler)	Constructor

Methodenübersicht

Modifizierer und Typ	Methode	Beschreibung
void	close()	Close
void	connect()	Connecting to IRC-WS
void	disconnect()	Disconnecting from WebSocket
EventManager	getEventManager()	EventManager
long	getLatency()
PubSubSubscription	listenOnTopic(PubSubRequest request)	Send WS Message to subscribe to a topic
protected void	onConnected()
protected void	onPreConnect()
protected void	onTextMessage(String text)
void	reconnect()	Reconnecting to WebSocket
boolean	unsubscribeFromTopic(PubSubSubscription subscription)	Unsubscribe from a topic.

Von Klasse geerbte Methoden java.lang.Object

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

Von Schnittstelle geerbte Methoden com.github.twitch4j.pubsub.ITwitchPubSub

listenForAdPropertyRefreshEvents, listenForAdsEvents, listenForAdsManagerEvents, listenForAutomodLevelsModificationEvents, listenForAutomodQueueEvents, listenForBitsBadgeEvents, listenForBountyBoardEvents, listenForBroadcastSettingUpdateEvents, listenForCelebrationEvents, listenForChannelBitsLeaderboardAllTimeEvents, listenForChannelBitsLeaderboardEvents, listenForChannelBitsLeaderboardEvents, listenForChannelBitsLeaderboardMonthlyEvents, listenForChannelChatroomEvents, listenForChannelDropEvents, listenForChannelExtensionEvents, listenForChannelPointsRedemptionEvents, listenForChannelPredictionsEvents, listenForChannelPrimeGiftStatusEvents, listenForChannelSquadEvents, listenForChannelSubGiftsEvents, listenForChannelSubLeaderboardAllTimeEvents, listenForChannelSubLeaderboardEvents, listenForChannelSubLeaderboardEvents, listenForChannelSubLeaderboardMonthlyEvents, listenForChannelUnbanRequestEvents, listenForCharityCampaignEvents, listenForChatHighlightEvents, listenForCheerEvents, listenForCommerceEvents, listenForCommunityBoostEvents, listenForCreatorGoalsEvents, listenForCrowdChantEvents, listenForDashboardActivityFeedEvents, listenForExtensionControlEvents, listenForFollowingEvents, listenForFriendshipEvents, listenForHypeTrainEvents, listenForHypeTrainRewardEvents, listenForLeaderboardAllTimeEvents, listenForLeaderboardEvents, listenForLeaderboardEvents, listenForLeaderboardMonthlyEvents, listenForLowTrustUsersEvents, listenForModerationEvents, listenForModerationEvents, listenForOnsiteNotificationEvents, listenForPinnedChatEvents, listenForPollEvents, listenForPresenceEvents, listenForPublicBitEvents, listenForPublicCheerEvents, listenForRadioEvents, listenForRaidEvents, listenForShieldModeEvents, listenForShoutoutEvents, listenForStreamChangeEvents, listenForStreamChatRoomEvents, listenForSubscriptionEvents, listenForUserBitsUpdateEvents, listenForUserCampaignEvents, listenForUserChannelPointsEvents, listenForUserChatroomEvents, listenForUserDropEvents, listenForUserImageUpdateEvents, listenForUserModerationNotificationEvents, listenForUserPredictionsEvents, listenForUserPropertiesUpdateEvents, listenForUserSubscribeEvents, listenForUserUnbanRequestEvents, listenForVideoPlaybackByNameEvents, listenForVideoPlaybackEvents, listenForWatchPartyEvents, listenForWhisperEvents, listenOnTopic, listenOnTopic, listenOnTopic

Felddetails

REQUIRED_THREAD_COUNT

public static final int REQUIRED_THREAD_COUNT

Siehe auch:

• Konstantenfeldwerte

queueTask

protected final Future<?> queueTask

Command Queue Thread

heartbeatTask

protected final Future<?> heartbeatTask

Heartbeat Thread

isClosed

protected volatile boolean isClosed

is Closed?

commandQueue

protected final BlockingQueue<String> commandQueue

Command Queue

subscribedTopics

protected final Set<PubSubRequest> subscribedTopics

Holds the subscribed topics in case we need to reconnect

lastPing

protected volatile long lastPing

Last Ping send (1 minute delay before sending the first ping)

lastPong

protected volatile long lastPong

Last Pong received

taskExecutor

protected final ScheduledExecutorService taskExecutor

Thread Pool Executor

Konstruktordetails

TwitchPubSub

public TwitchPubSub(WebsocketConnection websocketConnection,
 EventManager eventManager,
 ScheduledThreadPoolExecutor taskExecutor,
 ProxyConfig proxyConfig,
 Collection<String> botOwnerIds,
 int wsPingPeriod,
 IBackoffStrategy connectionBackoffStrategy,
 int wsCloseDelay,
 Consumer<PubSubResponsePayload> fallbackTopicHandler)

Constructor

Parameter:

websocketConnection - WebsocketConnection

eventManager - EventManager

taskExecutor - ScheduledThreadPoolExecutor

proxyConfig - ProxyConfig

botOwnerIds - Bot Owner IDs

wsPingPeriod - WebSocket Ping Period

connectionBackoffStrategy - WebSocket Connection Backoff Strategy

wsCloseDelay - Websocket Close Delay

fallbackTopicHandler - Fallback Topic Handler

Methodendetails

connect

public void connect()

Connecting to IRC-WS

disconnect

public void disconnect()

Disconnecting from WebSocket

reconnect

public void reconnect()

Reconnecting to WebSocket

onPreConnect

protected void onPreConnect()

onConnected

protected void onConnected()

onTextMessage

protected void onTextMessage(String text)

listenOnTopic

public PubSubSubscription listenOnTopic(PubSubRequest request)

Beschreibung aus Schnittstelle kopiert: ITwitchPubSub

Send WS Message to subscribe to a topic

Angegeben von:

listenOnTopic in Schnittstelle ITwitchPubSub

Parameter:

request - Topic

Gibt zurück:

PubSubSubscription to be listened to

unsubscribeFromTopic

public boolean unsubscribeFromTopic(PubSubSubscription subscription)

Beschreibung aus Schnittstelle kopiert: ITwitchPubSub

Unsubscribe from a topic. Usage example:

      PubSubSubscription subscription = twitchPubSub.listenForCheerEvents(...);
      // ...
      twitchPubSub.unsubscribeFromTopic(subscription);
 

Angegeben von:

unsubscribeFromTopic in Schnittstelle ITwitchPubSub

Parameter:

subscription - PubSubSubscription to be unlistened from

Gibt zurück:

whether the subscription was previously subscribed to

getLatency

public long getLatency()

Angegeben von:

getLatency in Schnittstelle ITwitchPubSub

Gibt zurück:

the most recently measured round-trip latency for the socket(s) in milliseconds, or -1 if unknown

close

public void close()

Close

Angegeben von:

close in Schnittstelle AutoCloseable

Angegeben von:

close in Schnittstelle ITwitchPubSub

getEventManager

public EventManager getEventManager()

EventManager

Angegeben von:

getEventManager in Schnittstelle ITwitchPubSub