#Import des librairies
from modbusReader import CacheModBus

#On etablie une connexion, voir avec le buffer_size a renseiger peut etre ...
cx = CacheModBus(host="ip", port="port", buffer_size=None)

#On lit une valeur
cx.read("adresse")

#On peut tester en forcant le buffer
cx.read("adress", user_buffer=False)

##############################Modif Richard##########################################################


#!/usr/bin/env python
# -*- coding: utf-8 -*-
# (c)2010 Ph.E Conseil
import time
import stomp
import sys, glob
from modbusReader import CacheModBus

print("Modbus Collector is starting ...")

#host = sys.argv[2] if len(sys.argv) > 2 else 'localhost'
#port = sys.argv[3] if len(sys.argv) > 3 else 61613

#conn = stomp.Connection(host_and_ports=[(host, port)])

#conn.start()
#conn.connect()

#cx = CacheModBus('192.168.1.210')
cx = CacheModBus(host = '192.168.1.210', port = 502, buffer_size=None)

#lastPubDate = time.time()
try:
    while True:
        print time.time(), 'modbus query ...'

        v = cx.read('%MW10')
        print v
        '''for var in ('%MW10'):
        #for var in ('%MW400001'):
            v = cx.read(var)
            print time.time(), v, var
            dest = '/var/inject/V%i'
            #print '%s = %s' % (var, v)
            if (time.time() - lastPubDate) > 0:
                conn.send(v, destination=dest)
                conn.send('V%i=%s' % (ctrl, v), destination='/var/inject')
                #conn.send('V%i=%s' % (i, strVal), destination='/var/inject')
                #conn.send(strVal, destination='/var/inject/V%i' % i)
                lastPubDate = time.time()
        time.sleep(0.5)
        '''
except KeyboardInterrupt:
    print 'quitting ...'
    cx.close()
#    conn.disconnect()