Adding trace Collector RM

[nepi.git] / src / nepi / resources / omf / channel.py

diff --git a/src/nepi/resources/omf/channel.py b/src/nepi/resources/omf/channel.py
index 1eaef05..8d8a5db 100644 (file)
--- a/src/nepi/resources/omf/channel.py
+++ b/src/nepi/resources/omf/channel.py
@@ -11,18 +11,18 @@
     but WITHOUT ANY WARRANTY; without even the implied warranty of
     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
     GNU General Public License for more details.
-c
+
     You should have received a copy of the GNU General Public License
     along with this program.  If not, see <http://www.gnu.org/licenses/>.
 
 """
 
-from nepi.execution.resource import ResourceManager, clsinit, ResourceState
+from nepi.execution.resource import ResourceManager, clsinit, ResourceState, \
+        reschedule_delay
 from nepi.execution.attribute import Attribute, Flags 
 
 from nepi.resources.omf.omf_api import OMFAPIFactory
 
-reschedule_delay = "0.5s"
 
 @clsinit
 class OMFChannel(ResourceManager):
@@ -153,7 +153,7 @@ class OMFChannel(ResourceManager):
                 self._state = ResourceState.FAILED
                 msg = "Credentials are not initialzed. XMPP Connections impossible"
                 self.debug(msg)
-                return
+                raise
         else :
             msg = "Channel's value is not initialized"
             self.error(msg)
@@ -170,7 +170,7 @@ class OMFChannel(ResourceManager):
 
     def stop(self):
         """Stop the RM. It means nothing special for a channel for now
-           It becomes STOPPED as soon as this method stops
+           It becomes STOPPED as soon as this method is called
 
         """
         super(OMFChannel, self).stop()