DS-2831 connections cleanup and context reuse

This commit is contained in:
Arnaud de Bossoreille
2015-10-22 17:28:41 +02:00
parent a3a5f562c9
commit c01c3af153
2 changed files with 16 additions and 7 deletions

View File

@@ -284,14 +284,23 @@ public class EventManager
{ {
Context ctx = new Context(); Context ctx = new Context();
for (Iterator ci = ((Dispatcher) dispatcher).getConsumers() try {
.iterator(); ci.hasNext();)
{ for (Iterator ci = ((Dispatcher) dispatcher).getConsumers()
ConsumerProfile cp = (ConsumerProfile) ci.next(); .iterator(); ci.hasNext();)
if (cp != null)
{ {
cp.getConsumer().finish(ctx); ConsumerProfile cp = (ConsumerProfile) ci.next();
if (cp != null)
{
cp.getConsumer().finish(ctx);
}
} }
ctx.complete();
} catch (Exception e) {
ctx.abort();
throw e;
} }
return; return;

View File

@@ -355,7 +355,7 @@ public class CollectionsResource extends Resource
workspaceItem.update(); workspaceItem.update();
// Index item to browse. // Index item to browse.
org.dspace.browse.IndexBrowse browse = new org.dspace.browse.IndexBrowse(); org.dspace.browse.IndexBrowse browse = new org.dspace.browse.IndexBrowse(context);
browse.indexItem(dspaceItem); browse.indexItem(dspaceItem);
log.trace("Installing item to collection(id=" + collectionId + ")."); log.trace("Installing item to collection(id=" + collectionId + ").");