Gateway Events

GatewayClient connects to the Fluxer WebSocket gateway for real-time events. It handles heartbeats, reconnection, and session resumption automatically.

Connecting

GatewayClient gateway = new GatewayClient("Bot YOUR_TOKEN", config);

// Register listeners before connecting
gateway.addReadyListener(ready -> {
    System.out.println("Connected as " + ready.getUser().getUsername());
});

// Connect (returns CompletableFuture)
gateway.connectAsync().join();

// When done:
gateway.close();

Registering Event Listeners

All listeners accept a Consumer<T> where T is the typed event data class. You can register multiple listeners for the same event.

// Lambda style
gateway.addMessageCreateListener(msg -> {
    System.out.println(msg.getContent());
});

// Method reference
gateway.addMessageCreateListener(this::handleMessage);

// Multiple listeners are supported
gateway.addMessageCreateListener(msg -> logMessage(msg));
gateway.addMessageCreateListener(msg -> processCommand(msg));

Session Events

Message Events

gateway.addMessageCreateListener(msg -> {
    if (msg.getAuthor() != null) {
        System.out.println(
            "[" + msg.getChannelId() + "] "
            + msg.getAuthor().getUsername() + ": "
            + msg.getContent()
        );
    }
});

gateway.addMessageDeleteListener(del -> {
    System.out.println("Message " + del.getMessageId() + " deleted");
});

Channel Events

Guild Events

Member Events

Role Events

Reaction Events

Voice Events

User & Presence Events

Other Events

Event Filtering

Reduce noise by ignoring specific events via configuration:

FluxerConfig config = FluxerConfig.builder()
    .ignoredGatewayEvents(List.of(
        "PRESENCE_UPDATE",
        "TYPING_START",
        "TYPING_STOP"
    ))
    .build();