https://www.home-assistant.io/integrations/rest_command/
rest_command:
hellstorm_stream_request:
url: http://192.168.10.148/api/v1/replaceAndPlay
method: POST
headers:
https://www.home-assistant.io/integrations/rest_command/
rest_command:
hellstorm_stream_request:
url: http://192.168.10.148/api/v1/replaceAndPlay
method: POST
headers:
kec@romulus:~$ cat /etc/NetworkManager/dispatcher.d/10-vpnupdown
#!/bin/bash
session_user="kec"
session_bus=unix:path=/run/user/$(id -u $session_user)/bus
session_display=$(who | grep $session_user | awk '{print $2}')
as_user="sudo -Hu kec DISPLAY=${session_display} DBUS_SESSION_BUS_ADDRESS=${session_bus}"
if [ "$2" = "vpn-up" ]; then
<dependency> | |
<groupId>io.helidon.microprofile.messaging</groupId> | |
<artifactId>helidon-microprofile-messaging</artifactId> | |
</dependency> | |
<dependency> | |
<groupId>io.helidon.messaging.kafka</groupId> | |
<artifactId>helidon-messaging-kafka</artifactId> | |
</dependency> | |
<dependency> | |
<groupId>io.cloudevents</groupId> |
connector: | |
helidon-kafka: | |
bootstrap.servers: ${oci.test-stream.endpoint}:${oci.test-stream.port} | |
... | |
key.serializer: org.apache.kafka.common.serialization.StringSerializer | |
key.deserializer: org.apache.kafka.common.serialization.StringDeserializer | |
value.serializer: io.cloudevents.kafka.CloudEventSerializer | |
value.deserializer: io.cloudevents.kafka.CloudEventDeserializer |
final SubmissionPublisher<CloudEvent> emitter = new SubmissionPublisher<>(); | |
@Outgoing("to-stream") | |
public PublisherBuilder<CloudEvent> registerEmitter() { | |
return ReactiveStreams.fromPublisher(FlowAdapters.toPublisher(emitter)); | |
} | |
@POST | |
@Path("/send/{msg}") | |
public void send(@PathParam("msg") String payload) { |
@Incoming("from-stream") | |
public void receive(CloudEvent event) { | |
String payload = new String(event.getData().toBytes()); | |
} |
@Incoming("from-wls-1") | |
public void receive1(String payld) { | |
sseBroadcaster.broadcast(new OutboundEvent.Builder().data("Q1: " + payld).build()); | |
} | |
@Incoming("from-wls-2") | |
public void receive2(String payld) { | |
sseBroadcaster.broadcast(new OutboundEvent.Builder().data("Q2: " + payld).build()); | |
} |
incoming: | |
from-wls-1: | |
connector: helidon-jms | |
destination: ./TestJMSModule!ms1@udd_queue | |
from-wls-2: | |
connector: helidon-jms | |
destination: ./TestJMSModule!ms2@udd_queue | |
outgoing: | |
to-wls: | |
connector: helidon-jms |
SubmissionPublisher<String> emitter = new SubmissionPublisher<>(); | |
SseBroadcaster sseBroadcaster; | |
@Incoming("from-wls") | |
public void receive(JmsMessage<String> msg) { | |
if (sseBroadcaster == null) { | |
System.out.println("No SSE client subscribed yet: " + msg.getPayload()); | |
return; | |
} |