diff --git a/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/OperatorId.java b/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/OperatorId.java
index f8b5dbf..cb8b0ae 100644
--- a/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/OperatorId.java
+++ b/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/OperatorId.java
@@ -14,7 +14,8 @@ public enum OperatorId {
 	LISTDBNAMES("org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mappedclasses.transducerers.LISTDBNAMES"), 
 	LISTDBSCHEMA("org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mappedclasses.transducerers.LISTDBSCHEMA"), 
 	LISTTABLES("org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mappedclasses.transducerers.LISTTABLES"), 
-	CMSY2("org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mappedclasses.transducerers.CMSY_2");
+	CMSY2("org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mappedclasses.transducerers.CMSY_2"),
+	RASTER_DATA_PUBLISHER("org.gcube.dataanalysis.wps.statisticalmanager.synchserver.mappedclasses.transducerers.RASTER_DATA_PUBLISHER");
 	
 	/**
 	 * @param text
diff --git a/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/RasterDataPublisherTest.java b/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/RasterDataPublisherTest.java
new file mode 100644
index 0000000..9a51c67
--- /dev/null
+++ b/src/test/java/org/gcube/data/analysis/dataminermanagercl/test/RasterDataPublisherTest.java
@@ -0,0 +1,206 @@
+package org.gcube.data.analysis.dataminermanagercl.test;
+
+import java.util.ArrayList;
+import java.util.List;
+
+import org.gcube.data.analysis.dataminermanagercl.server.DataMinerService;
+import org.gcube.data.analysis.dataminermanagercl.server.dmservice.SClient;
+import org.gcube.data.analysis.dataminermanagercl.server.monitor.DMMonitor;
+import org.gcube.data.analysis.dataminermanagercl.server.monitor.DMMonitorListener;
+import org.gcube.data.analysis.dataminermanagercl.shared.Constants;
+import org.gcube.data.analysis.dataminermanagercl.shared.data.OutputData;
+import org.gcube.data.analysis.dataminermanagercl.shared.data.computations.ComputationId;
+import org.gcube.data.analysis.dataminermanagercl.shared.data.output.MapResource;
+import org.gcube.data.analysis.dataminermanagercl.shared.data.output.Resource;
+import org.gcube.data.analysis.dataminermanagercl.shared.parameters.FileParameter;
+import org.gcube.data.analysis.dataminermanagercl.shared.parameters.ObjectParameter;
+import org.gcube.data.analysis.dataminermanagercl.shared.parameters.Parameter;
+import org.gcube.data.analysis.dataminermanagercl.shared.process.Operator;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import junit.framework.TestCase;
+
+/**
+ * 
+ * @author Giancarlo Panichi
+ *
+ *
+ */
+public class RasterDataPublisherTest extends TestCase {
+	private static Logger logger = LoggerFactory.getLogger(RasterDataPublisherTest.class);
+
+	public void testExecute() {
+
+		if (Constants.TEST_ENABLE) {
+			logger.debug("Test RasterDataPublisher");
+			try {
+				DataMinerService dataMinerService = new DataMinerService();
+				SClient sClient = dataMinerService.getClient();
+				Operator operator = sClient
+						.getOperatorById(OperatorId.RASTER_DATA_PUBLISHER.toString());
+
+				if (operator == null) {
+					logger.error("Operator not found");
+				} else {
+					logger.debug("Operator Name: " + operator.getName()
+							+ " (" + operator.getId() + ")");
+					logger.debug("Operator: " + operator);
+					List<Parameter> parameters = sClient
+							.getInputParameters(operator);
+					logger.debug("Parameters: " + parameters);
+					for (Parameter parameter : parameters) {
+						logger.debug("Parameter:[Name=" + parameter.getName()
+								+ ", Typology=" + parameter.getTypology() + "]");
+					}
+
+					createRequest(operator);
+					logger.debug("Start Computation");
+					ComputationId computationId = sClient
+							.startComputation(operator);
+					logger.debug("Started ComputationId: " + computationId);
+					monitoringComputation(computationId, sClient);
+				}
+
+				assertTrue("Success", true);
+
+			} catch (Throwable e) {
+				logger.error(e.getLocalizedMessage());
+				e.printStackTrace();
+				assertTrue("Error", false);
+			}
+
+		} else {
+			assertTrue("Success", true);
+		}
+	}
+
+	private void monitoringComputation(final ComputationId computationId,
+			final SClient sClient) {
+
+		DMMonitorListener listener = new DMMonitorListener() {
+
+			@Override
+			public void running(double percentage) {
+				logger.debug("Operation Running: " + percentage);
+
+			}
+
+			@Override
+			public void failed(String message, Exception exception) {
+				logger.error("Operation Failed");
+				logger.error(message, exception);
+
+			}
+
+			@Override
+			public void complete(double percentage) {
+				logger.debug("Operation Completed");
+				logger.debug("Perc: " + percentage);
+				retrieveOutput(computationId, sClient);
+
+			}
+
+			@Override
+			public void cancelled() {
+				logger.debug("Operation Cancelled");
+			}
+
+			@Override
+			public void accepted() {
+				logger.debug("Operation Accepted");
+
+			}
+		};
+
+		DMMonitor dmMonitor = new DMMonitor(computationId, sClient);
+		dmMonitor.add(listener);
+		dmMonitor.start();
+
+	}
+
+	private void retrieveOutput(ComputationId computationId, SClient sClient) {
+		try {
+			OutputData output = sClient
+					.getOutputDataByComputationId(computationId);
+			logger.debug("Output: " + output);
+			Resource resource = output.getResource();
+			if (resource.isMap()) {
+				MapResource mapResource = (MapResource) resource;
+				for (String key : mapResource.getMap().keySet()) {
+					logger.debug("Entry: " + key + " = "
+							+ mapResource.getMap().get(key));
+					
+				}
+				
+			} else {
+				
+			}
+			
+
+		} catch (Exception e) {
+			logger.error(e.getLocalizedMessage());
+			e.printStackTrace();
+		}
+
+	}
+
+	/**
+	 * 
+	 * @param operator Operator
+	 */
+	private void createRequest(Operator operator) {
+		logger.debug("Create Request");
+
+		ObjectParameter publicationLevel = new ObjectParameter();
+		publicationLevel.setName("PublicationLevel");
+		publicationLevel.setValue("PUBLIC");
+		
+		ObjectParameter datasetAbstract = new ObjectParameter();
+		datasetAbstract.setName("DatasetAbstract");
+		datasetAbstract.setValue("Abstract");
+
+		ObjectParameter datasetTitle = new ObjectParameter();
+		datasetTitle.setName("DatasetTitle");
+		datasetTitle.setValue("Generic Raster Layer Test3");
+		
+		FileParameter rasterFile=new FileParameter();
+		rasterFile.setName("RasterFile");
+		rasterFile.setValue("http://data.d4science.org/QTVNbXp5cmI0MG52TTE0K2paNzhXZWlCTHhweU8rUCtHbWJQNStIS0N6Yz0");
+		
+		ObjectParameter innerLayerName = new ObjectParameter();
+		innerLayerName.setName("InnerLayerName");
+		innerLayerName.setValue("analyzed_field");
+		
+		ObjectParameter fileNameOnInfra = new ObjectParameter();
+		fileNameOnInfra.setName("FileNameOnInfra");
+		fileNameOnInfra.setValue("raster-1465493226242.nc");
+		
+		ObjectParameter topics = new ObjectParameter();
+		topics.setName("Topics");
+		topics.setValue("analyzed_field");
+		
+		ObjectParameter spatialResolution = new ObjectParameter();
+		spatialResolution.setName("SpatialResolution");
+		spatialResolution.setValue("-1");
+		
+		
+		List<Parameter> parameters = new ArrayList<>();
+		
+		parameters.add(publicationLevel);
+		parameters.add(datasetAbstract);
+		parameters.add(datasetTitle);
+		parameters.add(rasterFile);
+		parameters.add(innerLayerName);
+		parameters.add(fileNameOnInfra);
+		parameters.add(topics);
+		parameters.add(spatialResolution);
+
+		logger.debug("Parameters set: " + parameters);
+		operator.setOperatorParameters(parameters);
+
+	}
+
+	
+
+}