This is an automated email from the ASF dual-hosted git repository. nfilotto pushed a commit to branch CAMEL-17792/doc-message-headers in repository https://gitbox.apache.org/repos/asf/camel.git
commit 63ee0fec22ed8f8e703f486029d23069daf1376a Author: Nicolas Filotto <[email protected]> AuthorDate: Thu Mar 31 19:02:41 2022 +0200 CAMEL-17792: Add doc about the message headers of camel-mongodb-gridfs --- .../component/mongodb/gridfs/mongodb-gridfs.json | 13 +++++++++ .../src/main/docs/mongodb-gridfs-component.adoc | 4 ++- .../component/mongodb/gridfs/GridFsConstants.java | 26 +++++++++++++++++ .../component/mongodb/gridfs/GridFsConsumer.java | 8 ++--- .../component/mongodb/gridfs/GridFsEndpoint.java | 9 ++---- .../component/mongodb/gridfs/GridFsProducer.java | 34 +++++++++++----------- .../gridfs/integration/GridFsConsumerIT.java | 8 ++--- .../integration/GridFsProducerOperationsIT.java | 11 ++++--- 8 files changed, 74 insertions(+), 39 deletions(-) diff --git a/components/camel-mongodb-gridfs/src/generated/resources/org/apache/camel/component/mongodb/gridfs/mongodb-gridfs.json b/components/camel-mongodb-gridfs/src/generated/resources/org/apache/camel/component/mongodb/gridfs/mongodb-gridfs.json index eb2d0bd..700ce6a 100644 --- a/components/camel-mongodb-gridfs/src/generated/resources/org/apache/camel/component/mongodb/gridfs/mongodb-gridfs.json +++ b/components/camel-mongodb-gridfs/src/generated/resources/org/apache/camel/component/mongodb/gridfs/mongodb-gridfs.json @@ -26,6 +26,19 @@ "lazyStartProducer": { "kind": "property", "displayName": "Lazy Start Producer", "group": "producer", "label": "producer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "description": "Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during star [...] "autowiredEnabled": { "kind": "property", "displayName": "Autowired Enabled", "group": "advanced", "label": "advanced", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": true, "description": "Whether autowiring is enabled. This is used for automatic autowiring options (the option must be marked as autowired) by looking up in the registry to find if there is a single instance of matching type, which t [...] }, + "headers": { + "CamelFileContentType": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The content type of the file." }, + "CamelFileLength": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "long", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The size of the file." }, + "CamelFileLastModified": { "kind": "header", "displayName": "", "group": "consumer", "label": "consumer", "required": false, "javaType": "Date", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The size of the file." }, + "CamelFileName": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The name of the file." }, + "Content-Type": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The content type of the file." }, + "CamelFileNameProduced": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The file name produced." }, + "gridfs.metadata": { "kind": "header", "displayName": "", "group": "common", "label": "", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Any additional metadata stored along with the file in JSON format." }, + "gridfs.operation": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The operation to perform." }, + "gridfs.chunksize": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "Integer", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The number of bytes per chunk for the uploaded file." }, + "gridfs.fileid": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "org.bson.types.ObjectId", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The ObjectId of the file produced" }, + "gridfs.objectid": { "kind": "header", "displayName": "", "group": "producer", "label": "producer", "required": false, "javaType": "org.bson.types.ObjectId", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The ObjectId of the file." } + }, "properties": { "connectionBean": { "kind": "path", "displayName": "Connection Bean", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "Name of com.mongodb.client.MongoClient to use." }, "bucket": { "kind": "parameter", "displayName": "Bucket", "group": "common", "label": "", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "defaultValue": "fs", "description": "Sets the name of the GridFS bucket within the database. Default is fs." }, diff --git a/components/camel-mongodb-gridfs/src/main/docs/mongodb-gridfs-component.adoc b/components/camel-mongodb-gridfs/src/main/docs/mongodb-gridfs-component.adoc index 9f8bc08..a8d79e1 100644 --- a/components/camel-mongodb-gridfs/src/main/docs/mongodb-gridfs-component.adoc +++ b/components/camel-mongodb-gridfs/src/main/docs/mongodb-gridfs-component.adoc @@ -44,7 +44,9 @@ include::partial$component-endpoint-options.adoc[] // endpoint options: START // endpoint options: END - +// component headers: START +include::partial$component-endpoint-headers.adoc[] +// component headers: END == Configuration of database in Spring XML diff --git a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConstants.java b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConstants.java index fea34be..f05dde5 100644 --- a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConstants.java +++ b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConstants.java @@ -16,14 +16,40 @@ */ package org.apache.camel.component.mongodb.gridfs; +import org.apache.camel.Exchange; +import org.apache.camel.spi.Metadata; + public final class GridFsConstants { + @Metadata(label = "consumer", description = "The content type of the file.", javaType = "String") + public static final String FILE_CONTENT_TYPE = Exchange.FILE_CONTENT_TYPE; + @Metadata(label = "consumer", description = "The size of the file.", javaType = "long") + public static final String FILE_LENGTH = Exchange.FILE_LENGTH; + @Metadata(label = "consumer", description = "The size of the file.", javaType = "Date") + public static final String FILE_LAST_MODIFIED = Exchange.FILE_LAST_MODIFIED; + @Metadata(label = "producer", description = "The name of the file.", javaType = "String") + public static final String FILE_NAME = Exchange.FILE_NAME; + @Metadata(label = "producer", description = "The content type of the file.", javaType = "String") + public static final String CONTENT_TYPE = Exchange.CONTENT_TYPE; + @Metadata(label = "producer", description = "The file name produced.", javaType = "String") + public static final String FILE_NAME_PRODUCED = Exchange.FILE_NAME_PRODUCED; + public static final String GRIDFS_FILE_ATTRIBUTE_DONE = "done"; public static final String GRIDFS_FILE_ATTRIBUTE_PROCESSING = "processing"; public static final String GRIDFS_FILE_KEY_CONTENT_TYPE = "contentType"; public static final String GRIDFS_FILE_KEY_FILENAME = "filename"; public static final String GRIDFS_FILE_KEY_UPLOAD_DATE = "uploadDate"; public static final String PERSISTENT_TIMESTAMP_KEY = "timestamp"; + @Metadata(description = "Any additional metadata stored along with the file in JSON format.", javaType = "String") + public static final String GRIDFS_METADATA = "gridfs.metadata"; + @Metadata(label = "producer", description = "The operation to perform.", javaType = "String") + public static final String GRIDFS_OPERATION = "gridfs.operation"; + @Metadata(label = "producer", description = "The number of bytes per chunk for the uploaded file.", javaType = "Integer") + public static final String GRIDFS_CHUNKSIZE = "gridfs.chunksize"; + @Metadata(label = "producer", description = "The ObjectId of the file produced", javaType = "org.bson.types.ObjectId") + public static final String GRIDFS_FILE_ID_PRODUCED = "gridfs.fileid"; + @Metadata(label = "producer", description = "The ObjectId of the file.", javaType = "org.bson.types.ObjectId") + public static final String GRIDFS_OBJECT_ID = "gridfs.objectid"; private GridFsConstants() { } diff --git a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConsumer.java b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConsumer.java index fe7639e..69941a7 100644 --- a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConsumer.java +++ b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsConsumer.java @@ -152,13 +152,13 @@ public class GridFsConsumer extends DefaultConsumer implements Runnable { if (metadata != null) { String contentType = metadata.get(GRIDFS_FILE_KEY_CONTENT_TYPE, String.class); if (contentType != null) { - exchange.getIn().setHeader(Exchange.FILE_CONTENT_TYPE, contentType); + exchange.getIn().setHeader(GridFsConstants.FILE_CONTENT_TYPE, contentType); } - exchange.getIn().setHeader(GridFsEndpoint.GRIDFS_METADATA, metadata.toJson()); + exchange.getIn().setHeader(GridFsConstants.GRIDFS_METADATA, metadata.toJson()); } - exchange.getIn().setHeader(Exchange.FILE_LENGTH, file.getLength()); - exchange.getIn().setHeader(Exchange.FILE_LAST_MODIFIED, file.getUploadDate()); + exchange.getIn().setHeader(GridFsConstants.FILE_LENGTH, file.getLength()); + exchange.getIn().setHeader(GridFsConstants.FILE_LAST_MODIFIED, file.getUploadDate()); exchange.getIn().setBody(downloadStream, InputStream.class); try { getProcessor().process(exchange); diff --git a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java index 3b47f8f..517ec63 100644 --- a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java +++ b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsEndpoint.java @@ -41,15 +41,10 @@ import org.slf4j.LoggerFactory; * Interact with MongoDB GridFS. */ @UriEndpoint(firstVersion = "2.18.0", scheme = "mongodb-gridfs", title = "MongoDB GridFS", - syntax = "mongodb-gridfs:connectionBean", category = { Category.DATABASE, Category.NOSQL }) + syntax = "mongodb-gridfs:connectionBean", category = { Category.DATABASE, Category.NOSQL }, + headersClass = GridFsConstants.class) public class GridFsEndpoint extends DefaultEndpoint { - public static final String GRIDFS_OPERATION = "gridfs.operation"; - public static final String GRIDFS_METADATA = "gridfs.metadata"; - public static final String GRIDFS_CHUNKSIZE = "gridfs.chunksize"; - public static final String GRIDFS_FILE_ID_PRODUCED = "gridfs.fileid"; - public static final String GRIDFS_OBJECT_ID = "gridfs.objectid"; - private static final Logger LOG = LoggerFactory.getLogger(GridFsEndpoint.class); @UriPath diff --git a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsProducer.java b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsProducer.java index 3481a46..1d68bcf 100644 --- a/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsProducer.java +++ b/components/camel-mongodb-gridfs/src/main/java/org/apache/camel/component/mongodb/gridfs/GridFsProducer.java @@ -45,18 +45,18 @@ public class GridFsProducer extends DefaultProducer { public void process(Exchange exchange) throws Exception { String operation = endpoint.getOperation(); if (operation == null) { - operation = exchange.getIn().getHeader(GridFsEndpoint.GRIDFS_OPERATION, String.class); + operation = exchange.getIn().getHeader(GridFsConstants.GRIDFS_OPERATION, String.class); } if (operation == null || "create".equals(operation)) { - final String filename = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class); - Integer chunkSize = exchange.getIn().getHeader(GridFsEndpoint.GRIDFS_CHUNKSIZE, Integer.class); + final String filename = exchange.getIn().getHeader(GridFsConstants.FILE_NAME, String.class); + Integer chunkSize = exchange.getIn().getHeader(GridFsConstants.GRIDFS_CHUNKSIZE, Integer.class); GridFSUploadOptions options = new GridFSUploadOptions(); if (chunkSize != null && chunkSize > 0) { options.chunkSizeBytes(chunkSize); } - String metaData = exchange.getIn().getHeader(GridFsEndpoint.GRIDFS_METADATA, String.class); + String metaData = exchange.getIn().getHeader(GridFsConstants.GRIDFS_METADATA, String.class); if (metaData != null) { Document document = Document.parse(metaData); if (document != null) { @@ -64,7 +64,7 @@ public class GridFsProducer extends DefaultProducer { } } - final String ct = exchange.getIn().getHeader(Exchange.CONTENT_TYPE, String.class); + final String ct = exchange.getIn().getHeader(GridFsConstants.CONTENT_TYPE, String.class); if (ct != null) { Document metadata = options.getMetadata(); if (metadata == null) { @@ -78,38 +78,38 @@ public class GridFsProducer extends DefaultProducer { ObjectId objectId = endpoint.getGridFsBucket().uploadFromStream(filename, ins, options); //add headers with the id and file name produced by the driver. - exchange.getIn().setHeader(Exchange.FILE_NAME_PRODUCED, filename); - exchange.getIn().setHeader(GridFsEndpoint.GRIDFS_FILE_ID_PRODUCED, objectId); - exchange.getIn().setHeader(GridFsEndpoint.GRIDFS_OBJECT_ID, objectId); + exchange.getIn().setHeader(GridFsConstants.FILE_NAME_PRODUCED, filename); + exchange.getIn().setHeader(GridFsConstants.GRIDFS_FILE_ID_PRODUCED, objectId); + exchange.getIn().setHeader(GridFsConstants.GRIDFS_OBJECT_ID, objectId); } else if ("remove".equals(operation)) { - final ObjectId objectId = exchange.getIn().getHeader(GridFsEndpoint.GRIDFS_OBJECT_ID, ObjectId.class); + final ObjectId objectId = exchange.getIn().getHeader(GridFsConstants.GRIDFS_OBJECT_ID, ObjectId.class); if (objectId != null) { endpoint.getGridFsBucket().delete(objectId); } else { - final String filename = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class); + final String filename = exchange.getIn().getHeader(GridFsConstants.FILE_NAME, String.class); GridFSFile file = endpoint.getGridFsBucket().find(eq(GRIDFS_FILE_KEY_FILENAME, filename)).first(); if (file != null) { endpoint.getGridFsBucket().delete(file.getId()); } } } else if ("findOne".equals(operation)) { - final String filename = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class); + final String filename = exchange.getIn().getHeader(GridFsConstants.FILE_NAME, String.class); GridFSDownloadStream downloadStream = endpoint.getGridFsBucket().openDownloadStream(filename); GridFSFile file = downloadStream.getGridFSFile(); Document metadata = file.getMetadata(); if (metadata != null) { - exchange.getIn().setHeader(GridFsEndpoint.GRIDFS_METADATA, metadata.toJson()); + exchange.getIn().setHeader(GridFsConstants.GRIDFS_METADATA, metadata.toJson()); Object contentType = metadata.get(GRIDFS_FILE_KEY_CONTENT_TYPE); if (contentType != null) { - exchange.getIn().setHeader(Exchange.FILE_CONTENT_TYPE, contentType); + exchange.getIn().setHeader(GridFsConstants.FILE_CONTENT_TYPE, contentType); } } - exchange.getIn().setHeader(Exchange.FILE_LENGTH, file.getLength()); - exchange.getIn().setHeader(Exchange.FILE_LAST_MODIFIED, file.getUploadDate()); + exchange.getIn().setHeader(GridFsConstants.FILE_LENGTH, file.getLength()); + exchange.getIn().setHeader(GridFsConstants.FILE_LAST_MODIFIED, file.getUploadDate()); exchange.getIn().setBody(downloadStream, InputStream.class); } else if ("listAll".equals(operation)) { - final String filename = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class); + final String filename = exchange.getIn().getHeader(GridFsConstants.FILE_NAME, String.class); MongoCursor<GridFSFile> cursor; if (filename == null) { cursor = endpoint.getGridFsBucket().find().cursor(); @@ -119,7 +119,7 @@ public class GridFsProducer extends DefaultProducer { exchange.getIn().setBody(new DBCursorFilenameReader(cursor), Reader.class); } else if ("count".equals(operation)) { long count; - final String filename = exchange.getIn().getHeader(Exchange.FILE_NAME, String.class); + final String filename = exchange.getIn().getHeader(GridFsConstants.FILE_NAME, String.class); if (filename == null) { count = endpoint.getFilesCollection().countDocuments(); } else { diff --git a/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsConsumerIT.java b/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsConsumerIT.java index a8e6af1..5a0ce71 100644 --- a/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsConsumerIT.java +++ b/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsConsumerIT.java @@ -25,7 +25,7 @@ import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mock.MockEndpoint; -import org.apache.camel.component.mongodb.gridfs.GridFsEndpoint; +import org.apache.camel.component.mongodb.gridfs.GridFsConstants; import org.bson.types.ObjectId; import org.junit.jupiter.api.Test; @@ -91,7 +91,7 @@ public class GridFsConsumerIT extends AbstractMongoDbITSupport { exchange.getMessage().setHeaders(headers); } }); - ObjectId objectId = result.getMessage().getHeader(GridFsEndpoint.GRIDFS_OBJECT_ID, ObjectId.class); + ObjectId objectId = result.getMessage().getHeader(GridFsConstants.GRIDFS_OBJECT_ID, ObjectId.class); assertNotNull(objectId); MockEndpoint mock = getMockEndpoint("mock:test"); @@ -100,7 +100,7 @@ public class GridFsConsumerIT extends AbstractMongoDbITSupport { template.requestBodyAndHeader( "mongodb-gridfs:myDb?database={{mongodb.testDb}}&operation=remove&bucket=customFileFilterTest", null, - GridFsEndpoint.GRIDFS_OBJECT_ID, objectId); + GridFsConstants.GRIDFS_OBJECT_ID, objectId); Integer count = template.requestBodyAndHeaders( "mongodb-gridfs:myDb?database={{mongodb.testDb}}&operation=count&bucket=customFileFilterTest", null, headers, @@ -111,7 +111,7 @@ public class GridFsConsumerIT extends AbstractMongoDbITSupport { public void runTest(String target, GridFSBucket gridfs) throws Exception { MockEndpoint mock = getMockEndpoint("mock:test"); mock.expectedBodiesReceived(FILE_DATA); - mock.expectedHeaderReceived(GridFsEndpoint.GRIDFS_METADATA, "{\"contentType\": \"text/plain\"}"); + mock.expectedHeaderReceived(GridFsConstants.GRIDFS_METADATA, "{\"contentType\": \"text/plain\"}"); Map<String, Object> headers = new HashMap<>(); assertFalse(gridfs.find(eq(GRIDFS_FILE_KEY_FILENAME, FILE_NAME)).cursor().hasNext()); diff --git a/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsProducerOperationsIT.java b/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsProducerOperationsIT.java index 54e42b2..08218e8 100644 --- a/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsProducerOperationsIT.java +++ b/components/camel-mongodb-gridfs/src/test/java/org/apache/camel/component/mongodb/gridfs/integration/GridFsProducerOperationsIT.java @@ -25,7 +25,6 @@ import org.apache.camel.Exchange; import org.apache.camel.Processor; import org.apache.camel.builder.RouteBuilder; import org.apache.camel.component.mongodb.gridfs.GridFsConstants; -import org.apache.camel.component.mongodb.gridfs.GridFsEndpoint; import org.bson.types.ObjectId; import org.junit.jupiter.api.Test; @@ -50,7 +49,7 @@ public class GridFsProducerOperationsIT extends AbstractMongoDbITSupport { from("direct:listAll") .to("mongodb-gridfs:myDb?database={{mongodb.testDb}}&operation=listAll&bucket=" + getBucket()); from("direct:count") - .setHeader(GridFsEndpoint.GRIDFS_OPERATION, constant("count")) + .setHeader(GridFsConstants.GRIDFS_OPERATION, constant("count")) .to("mongodb-gridfs:myDb?database={{mongodb.testDb}}&bucket=" + getBucket()); } }; @@ -77,8 +76,8 @@ public class GridFsProducerOperationsIT extends AbstractMongoDbITSupport { assertEquals(FILE_DATA, new String(b, 0, i, StandardCharsets.UTF_8)); headers.put(Exchange.FILE_NAME, "2-" + FILE_NAME); - headers.put(GridFsEndpoint.GRIDFS_CHUNKSIZE, 10); - headers.put(GridFsEndpoint.GRIDFS_METADATA, "{'foo': 'bar'}"); + headers.put(GridFsConstants.GRIDFS_CHUNKSIZE, 10); + headers.put(GridFsConstants.GRIDFS_METADATA, "{'foo': 'bar'}"); template.requestBodyAndHeaders("direct:create", FILE_DATA + "data2", headers); assertEquals(1, template.requestBodyAndHeaders("direct:count", null, headers, Long.class).longValue()); @@ -105,11 +104,11 @@ public class GridFsProducerOperationsIT extends AbstractMongoDbITSupport { exchange.getMessage().setHeaders(headers); } }); - ObjectId objectId = result.getMessage().getHeader(GridFsEndpoint.GRIDFS_OBJECT_ID, ObjectId.class); + ObjectId objectId = result.getMessage().getHeader(GridFsConstants.GRIDFS_OBJECT_ID, ObjectId.class); assertNotNull(objectId); template.requestBodyAndHeader("mongodb-gridfs:myDb?database={{mongodb.testDb}}&operation=remove&bucket=" + getBucket(), - null, GridFsEndpoint.GRIDFS_OBJECT_ID, objectId); + null, GridFsConstants.GRIDFS_OBJECT_ID, objectId); Integer count = template.requestBodyAndHeaders( "mongodb-gridfs:myDb?database={{mongodb.testDb}}&operation=count&bucket=" + getBucket(), null, headers,
