Package org.restheart.mongodb.handlers.changestreams

Class ChangeStreamWorker

java.lang.Object

org.restheart.mongodb.handlers.changestreams.ChangeStreamWorker

All Implemented Interfaces:

Runnable

public class ChangeStreamWorker
extends Object
implements Runnable

ChangeStreamWorker initiates and monitors the MongoDB change stream and dispaches virtual threads to send change event to clients

Author:

Andrea Di Cesare <andrea@softinstigate.com>

Constructor Summary

Constructors

Constructor	Description
ChangeStreamWorker(ChangeStreamWorkerKey key, List<org.bson.BsonDocument> resolvedStages, String dbName, String collName)

Method Summary

Modifier and Type	Method	Description
String	getCollName()
String	getDbName()
ChangeStreamWorkerKey	getKey()
void	run()
Set<WebSocketSession>	websocketSessions()

Methods inherited from class java.lang.Object

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

Constructor Details

ChangeStreamWorker

public ChangeStreamWorker(ChangeStreamWorkerKey key,
 List<org.bson.BsonDocument> resolvedStages,
 String dbName,
 String collName)

Method Details

getKey

public ChangeStreamWorkerKey getKey()

getDbName

public String getDbName()

getCollName

public String getCollName()

run

public void run()

Specified by:

run in interface Runnable

websocketSessions

public Set<WebSocketSession> websocketSessions()