parent
b38127253e
commit
dd20c48bd2
|
@ -121,13 +121,13 @@ def mqtt_publisher(universe):
|
||||||
print(str(get_eth0_ip()))
|
print(str(get_eth0_ip()))
|
||||||
receiver.start()
|
receiver.start()
|
||||||
|
|
||||||
@receiver.listen_on('universe', universe=universe)
|
|
||||||
@receiver.register_listener('universe', universe=universe, callback=callback)
|
|
||||||
def callback(packet): # packet type: sacn.DataPacket
|
def callback(packet): # packet type: sacn.DataPacket
|
||||||
print(packet.dmxData)
|
print(packet.dmxData)
|
||||||
global dmx_values
|
global dmx_values
|
||||||
dmx_values = packet.dmxData
|
dmx_values = packet.dmxData
|
||||||
receiver.join_multicast(universe)
|
receiver.join_multicast(universe)
|
||||||
|
receiver.listen_on('universe', universe=universe)
|
||||||
|
receiver.register_listener('universe', universe=universe, callback=callback)
|
||||||
|
|
||||||
while True:
|
while True:
|
||||||
if dmx_values is not None:
|
if dmx_values is not None:
|
||||||
|
|
Loading…
Reference in New Issue