jeans/core
jeans/core
1
0
Fork 0
mirror of https://github.com/home-assistant/core.git synced 2025-07-24 21:57:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add link to docs

Browse Source
This commit is contained in:
Fabian Affolter 2016-01-27 09:08:04 +01:00
parent 2c151c6db9
commit 70d95cb6aa
1 changed files with 5 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
homeassistant/components/mqtt_eventstream.py
View File

@ -1,20 +1,10 @@
""" """
homeassistant.components.mqtt_eventstream homeassistant.components.mqtt_eventstream
~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~ ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
Connect two Home Assistant instances via mqtt. Connect two Home Assistant instances via MQTT..
Configuration: For more details about this component, please refer to the documentation at
https://home-assistant.io/components/mqtt_eventstream.html
To use the mqtt_eventstream component you will need to add the following to
your configuration.yaml file.
If you do not specify a publish_topic you will not forward events to the queue.
If you do not specify a subscribe_topic then you will not receive events from
the remote server.
mqtt_eventstream:
publish_topic: MyServerName
subscribe_topic: OtherHaServerName
""" """
import json import json
from homeassistant.core import EventOrigin, State from homeassistant.core import EventOrigin, State
@ -38,13 +28,13 @@ DEPENDENCIES = ['mqtt']
def setup(hass, config): def setup(hass, config):
""" Setup our mqtt_eventstream component. """ """ Setup th MQTT eventstream component. """
mqtt = loader.get_component('mqtt') mqtt = loader.get_component('mqtt')
pub_topic = config[DOMAIN].get('publish_topic', None) pub_topic = config[DOMAIN].get('publish_topic', None)
sub_topic = config[DOMAIN].get('subscribe_topic', None) sub_topic = config[DOMAIN].get('subscribe_topic', None)
def _event_publisher(event): def _event_publisher(event):
""" Handle events by publishing them on the mqtt queue. """ """ Handle events by publishing them on the MQTT queue. """
if event.origin != EventOrigin.local: if event.origin != EventOrigin.local:
return return
if event.event_type == EVENT_TIME_CHANGED: if event.event_type == EVENT_TIME_CHANGED: