diff --git a/schainpy/model/io/bltrIO_param.py b/schainpy/model/io/bltrIO_param.py
index 546fc99..7048346 100644
--- a/schainpy/model/io/bltrIO_param.py
+++ b/schainpy/model/io/bltrIO_param.py
@@ -13,7 +13,7 @@ import datetime
 
 import numpy
 
-from schainpy.model.proc.jroproc_base import ProcessingUnit
+from schainpy.model.proc.jroproc_base import ProcessingUnit, Operation, MPDecorator
 from schainpy.model.data.jrodata import Parameters
 from schainpy.model.io.jroIO_base import JRODataReader, isNumber
 from schainpy.utils import log
@@ -83,7 +83,7 @@ DATA_STRUCTURE = numpy.dtype([
     ('sea_algorithm', '<u4')
 ])
 
-
+@MPDecorator
 class BLTRParamReader(JRODataReader, ProcessingUnit):
     '''
     Boundary Layer and Tropospheric Radar (BLTR) reader, Wind velocities and SNR from *.sswma files
@@ -91,9 +91,9 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
 
     ext = '.sswma'
 
-    def __init__(self, **kwargs):
+    def __init__(self):
 
-        ProcessingUnit.__init__(self, **kwargs)
+        ProcessingUnit.__init__(self)
 
         self.dataOut = Parameters()
         self.counter_records = 0
@@ -246,7 +246,7 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
         self.nranges = header_rec['nranges'][0]
         self.fp.seek(pointer)
         self.height = numpy.empty((self.nmodes, self.nranges))
-        self.snr = numpy.empty((self.nmodes, self.nchannels, self.nranges))
+        self.snr = numpy.empty((self.nmodes, int(self.nchannels), self.nranges))
         self.buffer = numpy.empty((self.nmodes, 3, self.nranges))
         self.flagDiscontinuousBlock = 0
 
@@ -268,9 +268,9 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
 
         header_structure = numpy.dtype(
             REC_HEADER_STRUCTURE.descr + [
-                ('antenna_coord', 'f4', (2, self.nchannels)),
-                ('rx_gains', 'u4', (self.nchannels,)),
-                ('rx_analysis', 'u4', (self.nchannels,))
+                ('antenna_coord', 'f4', (2, int(self.nchannels))),
+                ('rx_gains', 'u4', (int(self.nchannels),)),
+                ('rx_analysis', 'u4', (int(self.nchannels),))
             ]
         )
 
@@ -296,6 +296,7 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
             status_value - Array data is set to NAN for values that are not equal to status_value
 
         '''
+        self.nchannels = int(self.nchannels)
 
         data_structure = numpy.dtype(
             DATA_STRUCTURE.descr + [
@@ -366,4 +367,5 @@ class BLTRParamReader(JRODataReader, ProcessingUnit):
 
         self.set_output()
 
-        return 1
\ No newline at end of file
+        return 1
+        
\ No newline at end of file
diff --git a/schainpy/model/proc/bltrproc_parameters.py b/schainpy/model/proc/bltrproc_parameters.py
index 6a63540..a043562 100644
--- a/schainpy/model/proc/bltrproc_parameters.py
+++ b/schainpy/model/proc/bltrproc_parameters.py
@@ -12,11 +12,13 @@ from time import gmtime
 
 from numpy import transpose
 
-from .jroproc_base import ProcessingUnit, Operation
+from .jroproc_base import ProcessingUnit, MPDecorator, Operation
 from schainpy.model.data.jrodata import Parameters
 
+@MPDecorator
+class BLTRParametersProc(ProcessingUnit):
 
-class BLTRParametersProc(ProcessingUnit):    
+    METHODS = {}    
     '''
     Processing unit for BLTR parameters data (winds)
 
@@ -39,11 +41,12 @@ class BLTRParametersProc(ProcessingUnit):
         self.dataOut.year - Experiment year
     '''
 
-    def __init__(self, **kwargs):
+    def __init__(self):
         '''
         Inputs: None           
         '''
-        ProcessingUnit.__init__(self, **kwargs)
+        ProcessingUnit.__init__(self)
+        self.setupReq = False
         self.dataOut = Parameters()
         self.isConfig = False
 
@@ -77,12 +80,13 @@ class BLTRParametersProc(ProcessingUnit):
                 self.dataOut.data_param[i][SNRavgdB <= snr_threshold] = numpy.nan
 
 # TODO
+@MPDecorator
 class OutliersFilter(Operation):
 
-    def __init__(self, **kwargs):
+    def __init__(self):
         '''
         '''
-        Operation.__init__(self, **kwargs)
+        Operation.__init__(self)
 
     def run(self, svalue2, method, factor, filter, npoints=9):
         '''