public class ChangeStreamEvent<T> extends Object
Message
implementation specific to MongoDB Change
Streams.Constructor and Description |
---|
ChangeStreamEvent(com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document> raw,
Class<T> targetType,
MongoConverter converter) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object o) |
T |
getBody()
Get the potentially converted
ChangeStreamDocument.getFullDocument() . |
org.bson.BsonTimestamp |
getBsonTimestamp()
Get the
cluster time . |
String |
getCollectionName()
Get the collection name the event was originated at.
|
String |
getDatabaseName()
Get the database name the event was originated at.
|
com.mongodb.client.model.changestream.OperationType |
getOperationType()
Get the
operation type for this event. |
com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document> |
getRaw()
Get the raw
ChangeStreamDocument as emitted by the driver. |
org.bson.BsonValue |
getResumeToken()
Get the
resume token for this event. |
Instant |
getTimestamp()
Get the
cluster time as Instant the event was emitted at. |
int |
hashCode() |
String |
toString() |
public ChangeStreamEvent(@Nullable com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document> raw, Class<T> targetType, MongoConverter converter)
raw
- can be null.targetType
- must not be null.converter
- must not be null.@Nullable public com.mongodb.client.model.changestream.ChangeStreamDocument<org.bson.Document> getRaw()
ChangeStreamDocument
as emitted by the driver.@Nullable public Instant getTimestamp()
cluster time
as Instant
the event was emitted at.@Nullable public org.bson.BsonTimestamp getBsonTimestamp()
cluster time
.@Nullable public org.bson.BsonValue getResumeToken()
resume token
for this event.@Nullable public com.mongodb.client.model.changestream.OperationType getOperationType()
operation type
for this event.@Nullable public String getDatabaseName()
@Nullable public String getCollectionName()
@Nullable public T getBody()
ChangeStreamDocument.getFullDocument()
.getRaw()
or ChangeStreamDocument.getFullDocument()
is
null.Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.