Skip to content

Commit 18b84bc

Browse files
committed
[KNOWAGE-8921] Java libraries pruning - deleted NotifierServlet
1 parent 6e8026e commit 18b84bc

24 files changed

Lines changed: 3 additions & 2292 deletions

knowage-core/src/main/java/it/eng/spagobi/tools/dataset/strategy/CachedEvaluationStrategy.java

Lines changed: 2 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -65,14 +65,12 @@ protected IDataStore execute(List<AbstractSelectionField> projections, Filter fi
6565
IDataStore dataStore;
6666
try {
6767
dataStore = cache.get(profile, dataSet, projections, filter, groups, sortings, summaryRowProjections, offset, fetchSize, maxRowCount, indexes);
68-
if (dataSet.isRealtime())
68+
if (dataSet.isRealtime()) {
6969
unsetNgsiConsumer();
70+
}
7071

7172
if (dataStore == null) {
7273
dataStore = manageDatasetNotInCache(projections, filter, groups, sortings, summaryRowProjections, offset, fetchSize, maxRowCount, indexes);
73-
} else {
74-
if (dataSet.isRealtime())
75-
subscribeNGSI();
7674
}
7775

7876
dataStore.adjustMetadata(dataSet.getMetadata());
@@ -128,11 +126,6 @@ private void unsetNgsiConsumer() {
128126
restDataSet.setRealtimeNgsiConsumer(false);
129127
}
130128

131-
private void subscribeNGSI() {
132-
RESTDataSet restDataSet = dataSet.getImplementation(RESTDataSet.class);
133-
restDataSet.subscribeNGSI();
134-
}
135-
136129
protected DatasetEvaluationStrategyType getEvaluationStrategy() {
137130
return DatasetEvaluationStrategyType.CACHED;
138131
}

knowage/src/main/webapp/WEB-INF/web.xml

Lines changed: 0 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -279,23 +279,6 @@
279279
<servlet-class>it.eng.spagobi.commons.services.ChangePwdServlet</servlet-class>
280280
</servlet>
281281

282-
<!-- Notifications and CometD servlets-->
283-
<servlet>
284-
<servlet-name>NotifierServlet</servlet-name>
285-
<servlet-class>it.eng.spagobi.tools.dataset.notifier.NotifierServlet</servlet-class>
286-
287-
<init-param>
288-
<param-name>notifyUrl</param-name>
289-
<param-value>http://192.168.28.183:8080/knowage/datasetNotifier</param-value>
290-
</init-param>
291-
<load-on-startup>1</load-on-startup>
292-
</servlet>
293-
<servlet-mapping>
294-
<servlet-name>NotifierServlet</servlet-name>
295-
<url-pattern>/datasetNotifier</url-pattern>
296-
</servlet-mapping>
297-
<!-- Notifications and CometD servlets end-->
298-
299282
<servlet>
300283
<servlet-name>ExtendSessionServlet</servlet-name>
301284
<servlet-class>it.eng.spagobi.utilities.servlet.session.ExtendSessionServlet</servlet-class>

knowageutils/src/main/java/it/eng/spagobi/tools/dataset/bo/RESTDataSet.java

Lines changed: 0 additions & 24 deletions
Original file line numberDiff line numberDiff line change
@@ -47,9 +47,7 @@
4747
import it.eng.spagobi.tools.dataset.exceptions.ParametersNotValorizedException;
4848
import it.eng.spagobi.tools.dataset.listener.DataSetListenerManager;
4949
import it.eng.spagobi.tools.dataset.listener.DataSetListenerManagerFactory;
50-
import it.eng.spagobi.tools.dataset.notifier.NotifierServlet;
5150
import it.eng.spagobi.tools.dataset.notifier.fiware.OAuth2Utils;
52-
import it.eng.spagobi.tools.dataset.notifier.fiware.OrionContextSubscriber;
5351
import it.eng.spagobi.tools.dataset.utils.ParametersResolver;
5452
import it.eng.spagobi.tools.datasource.bo.IDataSource;
5553
import it.eng.spagobi.user.UserProfileManager;
@@ -110,17 +108,6 @@ public RESTDataSet(JSONObject jsonConf) {
110108
public void loadData(int offset, int fetchSize, int maxResults) {
111109

112110
super.loadData(offset, fetchSize, maxResults);
113-
114-
if (isNgsi()) {
115-
// notify for all listeners
116-
notifyListeners();
117-
118-
// after the first datastore initialization
119-
if (NotifierServlet.isNotifiable()) {
120-
logger.info(String.format("Subscribe NGSI dataset with label %s to orion notifications.", getLabel()));
121-
subscribeNGSI();
122-
}
123-
}
124111
}
125112

126113
private void notifyListeners() {
@@ -142,17 +129,6 @@ private void notifyListeners() {
142129
logger.debug("OUT");
143130
}
144131

145-
public void subscribeNGSI() {
146-
try {
147-
OrionContextSubscriber subscriber = new OrionContextSubscriber(this, getCurrentUserProfile());
148-
subscriber.subscribeNGSI();
149-
notifiable = true;
150-
} catch (Exception e) {
151-
logger.error("Errror in Orion subscription", e);
152-
notifiable = false;
153-
}
154-
}
155-
156132
public boolean isNotifiable() {
157133
return notifiable;
158134
}

knowageutils/src/main/java/it/eng/spagobi/tools/dataset/notifier/INotifierOperator.java

Lines changed: 0 additions & 27 deletions
This file was deleted.

knowageutils/src/main/java/it/eng/spagobi/tools/dataset/notifier/NotifierManager.java

Lines changed: 0 additions & 76 deletions
This file was deleted.

knowageutils/src/main/java/it/eng/spagobi/tools/dataset/notifier/NotifierManagerFactory.java

Lines changed: 0 additions & 30 deletions
This file was deleted.

knowageutils/src/main/java/it/eng/spagobi/tools/dataset/notifier/NotifierServlet.java

Lines changed: 0 additions & 78 deletions
This file was deleted.

knowageutils/src/main/java/it/eng/spagobi/tools/dataset/notifier/UserSignatureId.java

Lines changed: 0 additions & 65 deletions
This file was deleted.

0 commit comments

Comments
 (0)