Revision 37927
Added by Andrea Mannocci over 9 years ago
modules/dnet-openaireplus-workflows/trunk/src/main/java/eu/dnetlib/msro/openaireplus/workflows/nodes/dataFlowMonitoring/TriggerPrepublicMonitoringScenarioJobNode.java | ||
---|---|---|
45 | 45 |
/* Configuring SOLR sensor */ |
46 | 46 |
String actualCollection = evaluateCurrentSolrCollection(); |
47 | 47 |
log.info("At this round, the Pre-public monitoring scenario will check against " + actualCollection + "SOLR collection"); |
48 |
solrSensor = (SolrSensor) SensorFactory.createSensorWithConfiguration(SolrSensor.class, "solr"); |
|
48 |
solrSensor = (SolrSensor) SensorFactory.createSensorWithConfiguration(SolrSensor.class, "prepublic", "solr");
|
|
49 | 49 |
solrSensor.getConfiguration().setParam("collection", actualCollection); |
50 | 50 |
|
51 | 51 |
/* Configuring Redis sensor */ |
52 |
redisSensor = (RedisSensor) SensorFactory.createSensorWithConfiguration(RedisSensor.class, "redis"); |
|
52 |
redisSensor = (RedisSensor) SensorFactory.createSensorWithConfiguration(RedisSensor.class, "prepublic", "redis");
|
|
53 | 53 |
|
54 | 54 |
/* Wrapping the two sensors together */ |
55 | 55 |
wrapper = (SensorWrapper) SensorFactory.createSensor(SensorWrapper.class); |
Also available in: Unified diff
updated signature for sensor configuration request