B C D F G I K L M N O P R S U V W

B

BATCH_SIZE - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

C

CamelMongoDbException - Exception in org.apache.camel.component.mongodb

CamelMongoDbException(String, Throwable) - Constructor for exception org.apache.camel.component.mongodb.CamelMongoDbException

CamelMongoDbException(String) - Constructor for exception org.apache.camel.component.mongodb.CamelMongoDbException

CamelMongoDbException(Throwable) - Constructor for exception org.apache.camel.component.mongodb.CamelMongoDbException

COLLECTION - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

collection - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

See MongoDbEndpoint.setTailTrackCollection(String)

createConsumer(Processor) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

createEndpoint(String, String, Map<String, Object>) - Method in class org.apache.camel.component.mongodb.MongoDbComponent

Should access a singleton of type Mongo

createMongoDbExchange(DBObject) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

createProducer() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

D

DATABASE - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

db - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

See MongoDbEndpoint.setTailTrackDb(String)

DEFAULT_COLLECTION - Static variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

DEFAULT_FIELD - Static variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

doCount(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doFindAll(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doFindById(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doFindOneByQuery(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doGetStats(Exchange, char) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doInsert(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doRemove(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doSave(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

doStart() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Applies validation logic specific to this endpoint type.

doStart() - Method in class org.apache.camel.component.mongodb.MongoDbTailableCursorConsumer

doStop() - Method in class org.apache.camel.component.mongodb.MongoDbTailableCursorConsumer

doUpdate(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

F

field - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

See MongoDbEndpoint.setTailTrackField(String)

FIELDS_FILTER - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

FROM_TAILABLE - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

fromAnyObjectToDBObject(Object) - Static method in class org.apache.camel.component.mongodb.converters.MongoDbBasicConverters

fromBasicDBObjectToMap(BasicDBObject) - Static method in class org.apache.camel.component.mongodb.converters.MongoDbBasicConverters

fromMapToDBObject(Map<?, ?>) - Static method in class org.apache.camel.component.mongodb.converters.MongoDbBasicConverters

fromStringToDBObject(String) - Static method in class org.apache.camel.component.mongodb.converters.MongoDbBasicConverters

G

getCollection() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getConsumerType() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getCursor() - Method in class org.apache.camel.component.mongodb.MongoDbTailingProcess

getCursorRegenerationDelay() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getDatabase() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getDb() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getDbCollection() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getIncreasingFieldName() - Method in class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

getMongoConnection() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getOperation() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getPersistentId() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getReadPreference() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getTailTrackCollection() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getTailTrackDb() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getTailTrackField() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getTailTrackIncreasingField() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getTailTrackingConfig() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getWriteConcern() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

getWriteConcernRef() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

I

increasingField - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

See MongoDbEndpoint.setTailTrackIncreasingField(String)

initialize() - Method in class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

initializeConnection() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Initialises the MongoDB connection using the Mongo object provided to the endpoint

initializeProcess() - Method in class org.apache.camel.component.mongodb.MongoDbTailingProcess

Initialise the tailing process, the cursor and if persistent tail tracking is enabled, recover the cursor from the persisted point.

initTailTracking() - Method in class org.apache.camel.component.mongodb.MongoDbTailableCursorConsumer

INSERT_RECORDS_AFFECTED - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

invokeOperation(MongoDbOperation, Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

Entry method that selects the appropriate MongoDB operation and executes it

isCreateCollection() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

isDynamicity() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

isInvokeGetLastError() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

isPersistentTailTracking() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

isSingleton() - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

K

keepRunning - Variable in class org.apache.camel.component.mongodb.MongoDbTailingProcess

L

LAST_ERROR - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

lastVal - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

LIMIT - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

M

MongoDbBasicConverters - Class in org.apache.camel.component.mongodb.converters

MongoDbComponent - Class in org.apache.camel.component.mongodb

Represents the component that manages MongoDbEndpoint.

MongoDbComponent() - Constructor for class org.apache.camel.component.mongodb.MongoDbComponent

MongoDbConstants - Class in org.apache.camel.component.mongodb

MongoDbConsumerType - Enum in org.apache.camel.component.mongodb

MongoDbEndpoint - Class in org.apache.camel.component.mongodb

Represents a MongoDb endpoint.

MongoDbEndpoint() - Constructor for class org.apache.camel.component.mongodb.MongoDbEndpoint

MongoDbEndpoint(String, MongoDbComponent) - Constructor for class org.apache.camel.component.mongodb.MongoDbEndpoint

MongoDbEndpoint(String) - Constructor for class org.apache.camel.component.mongodb.MongoDbEndpoint

MongoDbOperation - Enum in org.apache.camel.component.mongodb

MongoDbProducer - Class in org.apache.camel.component.mongodb

The MongoDb producer.

MongoDbProducer(MongoDbEndpoint) - Constructor for class org.apache.camel.component.mongodb.MongoDbProducer

MongoDbTailableCursorConsumer - Class in org.apache.camel.component.mongodb

The MongoDb consumer.

MongoDbTailableCursorConsumer(MongoDbEndpoint, Processor) - Constructor for class org.apache.camel.component.mongodb.MongoDbTailableCursorConsumer

MongoDbTailingProcess - Class in org.apache.camel.component.mongodb

MongoDbTailingProcess(MongoDbEndpoint, MongoDbTailableCursorConsumer, MongoDbTailTrackingManager) - Constructor for class org.apache.camel.component.mongodb.MongoDbTailingProcess

MongoDbTailTrackingConfig - Class in org.apache.camel.component.mongodb

MongoDbTailTrackingConfig(boolean, String, String, String, String, String) - Constructor for class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

MongoDbTailTrackingManager - Class in org.apache.camel.component.mongodb

MongoDbTailTrackingManager(Mongo, MongoDbTailTrackingConfig) - Constructor for class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

MULTIUPDATE - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

N

NUM_TO_SKIP - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

O

OPERATION_HEADER - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

org.apache.camel.component.mongodb - package org.apache.camel.component.mongodb

org.apache.camel.component.mongodb.converters - package org.apache.camel.component.mongodb.converters

P

persistent - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

See MongoDbEndpoint.setPersistentTailTracking(boolean)

persistentId - Variable in class org.apache.camel.component.mongodb.MongoDbTailTrackingConfig

See MongoDbEndpoint.setPersistentId(String)

persistToStore() - Method in class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

process(Exchange) - Method in class org.apache.camel.component.mongodb.MongoDbProducer

R

RECORDS_AFFECTED - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

recoverFromStore() - Method in class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

RESULT_PAGE_SIZE - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

RESULT_TOTAL_SIZE - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

run() - Method in class org.apache.camel.component.mongodb.MongoDbTailingProcess

The heart of the tailing process.

S

setCollection(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Sets the name of the MongoDB collection to bind to this endpoint

setConsumerType(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Reserved for future use, when more consumer types are supported.

setCreateCollection(boolean) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Create collection during initialisation if it doesn't exist.

setCursorRegenerationDelay(long) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

MongoDB tailable cursors will block until new data arrives.

setDatabase(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Sets the name of the MongoDB database to target

setDynamicity(boolean) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Sets whether this endpoint will attempt to dynamically resolve the target database and collection from the incoming Exchange properties.

setInvokeGetLastError(boolean) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Instructs this endpoint to invoke WriteResult.getLastError() with every operation.

setLastVal(DBObject) - Method in class org.apache.camel.component.mongodb.MongoDbTailTrackingManager

setMongoConnection(Mongo) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Sets the Mongo instance that represents the backing connection

setOperation(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Sets the operation this endpoint will execute against MongoDB.

setPersistentId(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

One tail tracking collection can host many trackers for several tailable consumers.

setPersistentTailTracking(boolean) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Enable persistent tail tracking, which is a mechanism to keep track of the last consumed message across system restarts.

setReadPreference(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Sets a MongoDB ReadPreference on the Mongo connection.

setTailTrackCollection(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Collection where tail tracking information will be persisted.

setTailTrackDb(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Indicates what database the tail tracking mechanism will persist to.

setTailTrackField(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Field where the last tracked value will be placed.

setTailTrackIncreasingField(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

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.

setWriteConcern(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Set the WriteConcern for write operations on MongoDB using the standard ones.

setWriteConcernRef(String) - Method in class org.apache.camel.component.mongodb.MongoDbEndpoint

Set the WriteConcern for write operations on MongoDB, passing in the bean ref to a custom WriteConcern which exists in the Registry.

SORT_BY - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

stop() - Method in class org.apache.camel.component.mongodb.MongoDbTailingProcess

stopped - Variable in class org.apache.camel.component.mongodb.MongoDbTailingProcess

U

UPSERT - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

V

valueOf(String) - Static method in enum org.apache.camel.component.mongodb.MongoDbConsumerType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.camel.component.mongodb.MongoDbOperation

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.camel.component.mongodb.MongoDbConsumerType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.camel.component.mongodb.MongoDbOperation

Returns an array containing the constants of this enum type, in the order they are declared.

W

wrapInCamelMongoDbException(Throwable) - Static method in class org.apache.camel.component.mongodb.MongoDbComponent

WRITECONCERN - Static variable in class org.apache.camel.component.mongodb.MongoDbConstants

B C D F G I K L M N O P R S U V W