onUnsubscribe() — netty Function Reference

Architecture documentation for the onUnsubscribe() function in StompChatHandler.java from the netty codebase.

Function java Buffer Telemetry called by 1

Entity Profile

Buffer→ Telemetry→ onUnsubscribe() — netty Function Reference

Dependency Diagram

graph TD
  300a2492_839b_f301_5856_263dc6251275["onUnsubscribe()"]
  f937e446_8aba_2036_93fc_8020adb1953f["StompChatHandler"]
  300a2492_839b_f301_5856_263dc6251275 -->|defined in| f937e446_8aba_2036_93fc_8020adb1953f
  5ef12430_b789_c7f8_301d_8283d302e997["channelRead0()"]
  5ef12430_b789_c7f8_301d_8283d302e997 -->|calls| 300a2492_839b_f301_5856_263dc6251275
  style 300a2492_839b_f301_5856_263dc6251275 fill:#6366f1,stroke:#818cf8,color:#fff

Relationship Graph

Source Code

example/src/main/java/io/netty/example/stomp/websocket/StompChatHandler.java lines 126–138

    private void onUnsubscribe(ChannelHandlerContext ctx, StompFrame inboundFrame) {
        String subscriptionId = inboundFrame.headers().getAsString(SUBSCRIPTION);
        for (Entry<String, Set<StompSubscription>> entry : chatDestinations.entrySet()) {
            Iterator<StompSubscription> iterator = entry.getValue().iterator();
            while (iterator.hasNext()) {
                StompSubscription subscription = iterator.next();
                if (subscription.id().equals(subscriptionId) && subscription.channel().equals(ctx.channel())) {
                    iterator.remove();
                    return;
                }
            }
        }
    }