Class RealtimeHub.Attachment

java.lang.Object

com.kingsrook.qqq.middleware.javalin.realtime.RealtimeHub.Attachment

Enclosing class:

RealtimeHub

public static class RealtimeHub.Attachment
extends Object

A bounded transport queue; empty event is the internal close marker.

Method Summary

Modifier and Type	Method	Description
String	getConnectionId()	Connection identifier used by the subscription endpoint.
RealtimeHub.Frame	poll(long timeoutMillis)	Read the next wire frame without polling in a busy loop.

Methods inherited from class java.lang.Object

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

Method Details

poll

public RealtimeHub.Frame poll(long timeoutMillis)
                       throws InterruptedException

Read the next wire frame without polling in a busy loop.

Throws:

InterruptedException

getConnectionId

public String getConnectionId()

Connection identifier used by the subscription endpoint.