diff --git a/RTCP/Storage/src/MSWriterLDA.cc b/RTCP/Storage/src/MSWriterLDA.cc
index bb071ae499f505b2e8fdaa365840dfd12de1a699..c7c67c421a24933273402ff2da05e81c308f16cd 100644
--- a/RTCP/Storage/src/MSWriterLDA.cc
+++ b/RTCP/Storage/src/MSWriterLDA.cc
@@ -251,6 +251,7 @@ namespace LOFAR
 
       BF_BeamGroup beam = sap.beam(beamNr);
 
+      beam.create();
       beam.groupType()   .set("Beam");
       beam.nofStations() .set(parset.nrStations());
       beam.stationsList().set(parset.allStationNames()); // TODO: SS beamformer, support subsets of allStations
diff --git a/RTCP/Storage/src/OutputThread.cc b/RTCP/Storage/src/OutputThread.cc
index d77172ea071c33984b3bf9be8bef9e1d13c6bf98..d31a9cbafcd7e3bfe9bd23590ba136b69f480bef 100644
--- a/RTCP/Storage/src/OutputThread.cc
+++ b/RTCP/Storage/src/OutputThread.cc
@@ -151,15 +151,15 @@ void OutputThread::createMS()
   LOG_INFO_STR(itsLogPrefix << "Writing to " << path);
 
   try {
-#ifdef USE_DAL  
+#ifdef USE_LDA
     if (path.rfind(".h5") == path.length() - strlen(".h5")) {
       // HDF5 writer requested
       switch (itsOutputType) {
         case COHERENT_STOKES:
-          itsWriter = new MSWriterDAL<float,3>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
+          itsWriter = new MSWriterLDA<float,3>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
           break;
         case BEAM_FORMED_DATA:
-          itsWriter = new MSWriterDAL<float,4>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
+          itsWriter = new MSWriterLDA<float,4>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
           break;
         default:
           THROW(StorageException, "HDF5 not supported for this data type");
@@ -167,15 +167,15 @@ void OutputThread::createMS()
     } else {
       itsWriter = new MSWriterFile(path, itsOutputType == COHERENT_STOKES || itsOutputType == BEAM_FORMED_DATA || itsOutputType == INCOHERENT_STOKES);
     }
-#elif defined USE_LDA
+#elif defined USE_DAL  
     if (path.rfind(".h5") == path.length() - strlen(".h5")) {
       // HDF5 writer requested
       switch (itsOutputType) {
         case COHERENT_STOKES:
-          itsWriter = new MSWriterLDA<float,3>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
+          itsWriter = new MSWriterDAL<float,3>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
           break;
         case BEAM_FORMED_DATA:
-          itsWriter = new MSWriterLDA<float,4>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
+          itsWriter = new MSWriterDAL<float,4>(path.c_str(), itsParset, itsOutputType, itsStreamNr, itsIsBigEndian);
           break;
         default:
           THROW(StorageException, "HDF5 not supported for this data type");