default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.AdvancedMongoDbEndpointProducerBuilder.basic() |
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.collection(String collection) |
Sets the name of the MongoDB collection to bind to this endpoint.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.collectionIndex(String collectionIndex) |
Sets the collection index (JSON FORMAT : { field1 : order1, field2 :
order2}).
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.createCollection(boolean createCollection) |
Create collection during initialisation if it doesn't exist.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.createCollection(String createCollection) |
Create collection during initialisation if it doesn't exist.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.database(String database) |
Sets the name of the MongoDB database to target.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.mongoConnection(Object mongoConnection) |
Sets the connection bean used as a client for connecting to a
database.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.mongoConnection(String mongoConnection) |
Sets the connection bean used as a client for connecting to a
database.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.operation(String operation) |
Sets the operation this endpoint will execute against MongoDB.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.operation(MongoDbEndpointBuilderFactory.MongoDbOperation operation) |
Sets the operation this endpoint will execute against MongoDB.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.outputType(String outputType) |
Convert the output of the producer to the selected type :
DocumentList Document or MongoIterable.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.outputType(MongoDbEndpointBuilderFactory.MongoDbOutputType outputType) |
Convert the output of the producer to the selected type :
DocumentList Document or MongoIterable.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.persistentId(String persistentId) |
One tail tracking collection can host many trackers for several
tailable consumers.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.persistentTailTracking(boolean persistentTailTracking) |
Enable persistent tail tracking, which is a mechanism to keep track
of the last consumed message across system restarts.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.persistentTailTracking(String persistentTailTracking) |
Enable persistent tail tracking, which is a mechanism to keep track
of the last consumed message across system restarts.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.streamFilter(String streamFilter) |
Filter condition for change streams consumer.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.tailTrackCollection(String tailTrackCollection) |
Collection where tail tracking information will be persisted.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.tailTrackDb(String tailTrackDb) |
Indicates what database the tail tracking mechanism will persist to.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.tailTrackField(String tailTrackField) |
Field where the last tracked value will be placed.
|
default MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder |
MongoDbEndpointBuilderFactory.MongoDbEndpointProducerBuilder.tailTrackIncreasingField(String tailTrackIncreasingField) |
Correlation field in the incoming record which is of increasing
nature and will be used to position the tailing cursor every time it
is generated.
|