minor fixes

Author: paullatzelsperger

extensions/transfer/transfer-store-cosmos/src/main/java/com/microsoft/dagx/transfer/store/cosmos/CosmosTransferProcessStore.java

@@ -204,7 +204,7 @@ private void handleResponse(CosmosItemResponse<?> response) {
     }
 
     private TransferProcessDocument convertObject(Object databaseDocument) {
-        return typeManager.readValue(typeManager.writeValueAsBytes(databaseDocument), TransferProcessDocument.class);
+        return typeManager.readValue(typeManager.writeValueAsString(databaseDocument), TransferProcessDocument.class);
     }
 
     private void release(String processId, Object connectorId) {

extensions/transfer/transfer-store-cosmos/src/main/java/com/microsoft/dagx/transfer/store/cosmos/CosmosTransferProcessStoreExtension.java

@@ -43,7 +43,7 @@ public class CosmosTransferProcessStoreExtension implements ServiceExtension {
     @DagxSetting
     private final static String COSMOS_PARTITION_KEY_SETTING = "dagx.cosmos.partitionkey";
     private final static String DEFAULT_PARTITION_KEY = "dagx";
-    private final static String CONTAINER_NAME = "dagx-transferprocess";
+    private final static String CONTAINER_NAME = "transferprocess";
 
     private Monitor monitor;
 
@@ -107,6 +107,11 @@ public Set<String> requires() {
         return Set.of("dagx:blobstoreapi");
     }
 
+    @Override
+    public Set<String> provides() {
+        return Set.of("dagx:transferprocessstore");
+    }
+
     @Override
     public void start() {
         monitor.info("Started Initialized Cosmos Transfer Process Store extension");

extensions/transfer/transfer-store-memory/src/main/java/com/microsoft/dagx/transfer/store/memory/InMemoryTransferProcessStoreExtension.java

@@ -10,6 +10,8 @@
 import com.microsoft.dagx.spi.system.ServiceExtensionContext;
 import com.microsoft.dagx.spi.transfer.store.TransferProcessStore;
 
+import java.util.Set;
+
 /**
  * Provides an in-memory implementation of the {@link com.microsoft.dagx.spi.transfer.store.TransferProcessStore} for testing.
  */
@@ -23,6 +25,11 @@ public void initialize(ServiceExtensionContext context) {
         monitor.info("Initialized In-Memory Transfer Process Store extension");
     }
 
+    @Override
+    public Set<String> provides() {
+        return Set.of("dagx:transferprocessstore");
+    }
+
     @Override
     public void start() {
         monitor.info("Started Initialized In-Memory Transfer Process Store extension");