diff --git a/lib/Alchemy/Phrasea/WorkerManager/Provider/QueueWorkerServiceProvider.php b/lib/Alchemy/Phrasea/WorkerManager/Provider/QueueWorkerServiceProvider.php
index bc98560fed..7de8ef2604 100644
--- a/lib/Alchemy/Phrasea/WorkerManager/Provider/QueueWorkerServiceProvider.php
+++ b/lib/Alchemy/Phrasea/WorkerManager/Provider/QueueWorkerServiceProvider.php
@@ -11,6 +11,7 @@
 
 namespace Alchemy\Phrasea\WorkerManager\Provider;
 
+use Alchemy\Phrasea\Core\LazyLocator;
 use Alchemy\Phrasea\Model\Manipulator\WebhookEventManipulator;
 use Alchemy\Phrasea\Plugin\PluginProviderInterface;
 use Alchemy\Phrasea\Application as PhraseaApplication;
@@ -61,9 +62,7 @@ class QueueWorkerServiceProvider implements PluginProviderInterface
             $app->extend('dispatcher', function (EventDispatcherInterface $dispatcher, Application $app) {
 
                 $dispatcher->addSubscriber(
-                    (new RecordSubscriber($app)
-                    )->setApplicationBox($app['phraseanet.appbox'])
-
+                    new RecordSubscriber($app, new LazyLocator($app, 'phraseanet.appbox'))
                 );
                 $dispatcher->addSubscriber(new ExportSubscriber($app['alchemy_worker.message.publisher']));
                 $dispatcher->addSubscriber(new AssetsIngestSubscriber($app['alchemy_worker.message.publisher']));
diff --git a/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php b/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
index bfd383ad2f..fb4ef41ba5 100644
--- a/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
+++ b/lib/Alchemy/Phrasea/WorkerManager/Subscriber/RecordSubscriber.php
@@ -3,7 +3,6 @@
 namespace Alchemy\Phrasea\WorkerManager\Subscriber;
 
 use Alchemy\Phrasea\Application;
-use Alchemy\Phrasea\Application\Helper\ApplicationBoxAware;
 use Alchemy\Phrasea\Core\Event\Record\DeletedEvent;
 use Alchemy\Phrasea\Core\Event\Record\DeleteEvent;
 use Alchemy\Phrasea\Core\Event\Record\MetadataChangedEvent;
@@ -23,8 +22,6 @@ use Symfony\Component\EventDispatcher\EventSubscriberInterface;
 
 class RecordSubscriber implements EventSubscriberInterface
 {
-    use ApplicationBoxAware;
-
     /** @var MessagePublisher $messagePublisher */
     private $messagePublisher;
 
@@ -34,33 +31,40 @@ class RecordSubscriber implements EventSubscriberInterface
     /** @var  Application */
     private $app;
 
-    public function __construct(Application $app)
+    /**
+     * @var callable
+     */
+    private $appboxLocator;
+
+    public function __construct(Application $app, callable $appboxLocator)
     {
         $this->messagePublisher    = $app['alchemy_worker.message.publisher'];
         $this->workerResolver      = $app['alchemy_worker.type_based_worker_resolver'];
         $this->app                 = $app;
+        $this->appboxLocator       = $appboxLocator;
     }
 
     public function onSubdefinitionCreate(SubdefinitionCreateEvent $event)
     {
-        $record = $this->findDataboxById($event->getRecord()->getDataboxId())->get_record($event->getRecord()->getRecordId());
+        $record = $this->getApplicationBox()->get_databox($event->getRecord()->getDataboxId())->get_record($event->getRecord()->getRecordId());
 
-        $subdefs = $record->getDatabox()->get_subdef_structure()->getSubdefGroup($record->getType());
+        if (!$record->isStory()) {
+            $subdefs = $record->getDatabox()->get_subdef_structure()->getSubdefGroup($record->getType());
 
-        foreach ($subdefs as $subdef) {
-            $payload = [
-                'message_type' => MessagePublisher::SUBDEF_CREATION_TYPE,
-                'payload' => [
-                    'recordId'      => $event->getRecord()->getRecordId(),
-                    'databoxId'     => $event->getRecord()->getDataboxId(),
-                    'subdefName'    => $subdef->get_name(),
-                    'status'        => $event->isNewRecord() ? MessagePublisher::NEW_RECORD_MESSAGE : ''
-                ]
-            ];
+            foreach ($subdefs as $subdef) {
+                $payload = [
+                    'message_type' => MessagePublisher::SUBDEF_CREATION_TYPE,
+                    'payload' => [
+                        'recordId'      => $event->getRecord()->getRecordId(),
+                        'databoxId'     => $event->getRecord()->getDataboxId(),
+                        'subdefName'    => $subdef->get_name(),
+                        'status'        => $event->isNewRecord() ? MessagePublisher::NEW_RECORD_MESSAGE : ''
+                    ]
+                ];
 
-            $this->messagePublisher->publishMessage($payload, MessagePublisher::SUBDEF_QUEUE);
+                $this->messagePublisher->publishMessage($payload, MessagePublisher::SUBDEF_QUEUE);
+            }
         }
-
     }
 
     public function onDelete(DeleteEvent $event)
@@ -116,7 +120,7 @@ class RecordSubscriber implements EventSubscriberInterface
         $mediaSubdefRepository = $this->getMediaSubdefRepository($databoxId);
         $mediaSubdefs = $mediaSubdefRepository->findByRecordIdsAndNames([$recordId]);
 
-        $databox = $this->findDataboxById($databoxId);
+        $databox = $this->getApplicationBox()->get_databox($databoxId);
         $record  = $databox->get_record($recordId);
         $type    = $record->getType();
 
@@ -205,7 +209,7 @@ class RecordSubscriber implements EventSubscriberInterface
             $databoxId = $event->getRecord()->getDataboxId();
             $recordId = $event->getRecord()->getRecordId();
 
-            $databox = $this->findDataboxById($databoxId);
+            $databox = $this->getApplicationBox()->get_databox($databoxId);
             $record  = $databox->get_record($recordId);
             $type    = $record->getType();
 
@@ -231,11 +235,11 @@ class RecordSubscriber implements EventSubscriberInterface
     public static function getSubscribedEvents()
     {
         return [
-            RecordEvents::CREATED                                   => 'onRecordCreated',
-            RecordEvents::SUBDEFINITION_CREATE                      => 'onSubdefinitionCreate',
-            RecordEvents::DELETE                                    => 'onDelete',
+            RecordEvents::CREATED                             => 'onRecordCreated',
+            RecordEvents::SUBDEFINITION_CREATE                => 'onSubdefinitionCreate',
+            RecordEvents::DELETE                              => 'onDelete',
             WorkerEvents::SUBDEFINITION_CREATION_FAILURE      => 'onSubdefinitionCreationFailure',
-            RecordEvents::METADATA_CHANGED                          => 'onMetadataChanged',
+            RecordEvents::METADATA_CHANGED                    => 'onMetadataChanged',
             WorkerEvents::STORY_CREATE_COVER                  => 'onStoryCreateCover',
             WorkerEvents::SUBDEFINITION_WRITE_META            => 'onSubdefinitionWritemeta'
         ];
@@ -265,4 +269,14 @@ class RecordSubscriber implements EventSubscriberInterface
 
         return false;
     }
+
+    /**
+     * @return \appbox
+     */
+    private function getApplicationBox()
+    {
+        $callable = $this->appboxLocator;
+
+        return $callable();
+    }
 }
diff --git a/tests/Alchemy/Tests/Phrasea/WorkerManager/Subscriber/SubscriberTest.php b/tests/Alchemy/Tests/Phrasea/WorkerManager/Subscriber/SubscriberTest.php
index 574699ee3c..789a77e72b 100644
--- a/tests/Alchemy/Tests/Phrasea/WorkerManager/Subscriber/SubscriberTest.php
+++ b/tests/Alchemy/Tests/Phrasea/WorkerManager/Subscriber/SubscriberTest.php
@@ -19,9 +19,6 @@ class SubscriberTest extends \PhraseanetTestCase
 
         $sexportSubscriber = new ExportSubscriber($app['alchemy_worker.message.publisher']->reveal());
         $this->assertInstanceOf('Symfony\\Component\\EventDispatcher\\EventSubscriberInterface', $sexportSubscriber);
-
-        $recordSubscriber = new RecordSubscriber($app);
-        $this->assertInstanceOf('Symfony\\Component\\EventDispatcher\\EventSubscriberInterface', $recordSubscriber);
     }
 
     public function testIfPublisheMessageOnSubscribeEvent()
diff --git a/tests/Alchemy/Tests/Phrasea/WorkerManager/Worker/WorkerServiceTest.php b/tests/Alchemy/Tests/Phrasea/WorkerManager/Worker/WorkerServiceTest.php
index 691696607d..5c15285df0 100644
--- a/tests/Alchemy/Tests/Phrasea/WorkerManager/Worker/WorkerServiceTest.php
+++ b/tests/Alchemy/Tests/Phrasea/WorkerManager/Worker/WorkerServiceTest.php
@@ -44,8 +44,8 @@ class WorkerServiceTest extends \PHPUnit_Framework_TestCase
 
         $writemetadatasWorker = new WriteMetadatasWorker(
             $writer,
-            $app['alchemy_service.logger'],
-            $app['alchemy_service.message.publisher'],
+            $app['alchemy_worker.logger'],
+            $app['alchemy_worker.message.publisher'],
             $app['repo.worker-running-job']
         );
         $this->assertInstanceOf('Alchemy\\Phrasea\\WorkerManager\\Worker\\WorkerInterface', $writemetadatasWorker);