danielkec

mp.messaging:
  connector:
    helidon-jms:
      jndi:
        # Connection factory jndi
        jms-factory: ConnectionFactory
        # Initial context properties
        env-properties:
          java.naming:
            factory.initial: org.apache.activemq.jndi.ActiveMQInitialContextFactory

danielkec

<dependency>
  <groupId>io.helidon.microprofile.messaging</groupId>
  <artifactId>helidon-microprofile-messaging</artifactId>
</dependency>
<dependency>
  <groupId>io.helidon.messaging.jms</groupId>
  <artifactId>helidon-messaging-jms</artifactId>
</dependency>
<dependency>
  <groupId>org.apache.activemq</groupId>

danielkec

@Outgoing("to-jms")
public PublisherBuilder<String> produceToJms() {
    return ReactiveStreams.of("test1", "test2")
                .map(s -> JmsMessage.builder(s)
                              .correlationId(UUID.randomUUID().toString())
                              .property("stringProp", "cool property")
                              .property("byteProp", 4)
                              .property("intProp", 5)
                              .onAck(() -> System.out.println("Acked!"))
                              .build());

danielkec

@Incoming("from-jms")
@Acknowledgment(Acknowledgment.Strategy.MANUAL)
public CompletionStage<?> consumeJms(JmsMessage<String> msg) {
    System.out.println("JMS says: " + msg.getPayload());
    return msg.ack();
}

danielkec

mp:
  messaging:
    connector:
      helidon-jms:
        named-factory: active-mq-factory

    outgoing.to-jms:
      connector: helidon-jms
      destination: messaging-test-queue-1
      type: queue

danielkec

@Produces
@ApplicationScoped
@Named("active-mq-factory")
public ConnectionFactory connectionFactory() {
    return new ActiveMQConnectionFactory("tcp://127.0.0.1:61616");
}

danielkec

<dependency>
   <groupId>io.helidon.messaging</groupId>
   <artifactId>helidon-messaging</artifactId>
</dependency>
<dependency>
   <groupId>io.helidon.messaging.kafka</groupId>
   <artifactId>helidon-messaging-kafka</artifactId>
</dependency>

danielkec

deployment.yaml

apiVersion: apps/v1
kind: Deployment
metadata:
  name: quickstart-mp-deployment
  labels:
    app: quickstart-mp
spec:
 selector:

danielkec

kubectl get pods --all-namespaces
kubectl get svc --all-namespaces
kubectl logs --tail=100 -l app=order -n msdataworkshop
kubectl logs --tail=100 -l app=inventory -n msdataworkshop
kubectl logs -f -l app=order -n msdataworkshop
kubectl logs -f -l app=inventory -n msdataworkshop

kubectl cluster-info dump

kubectl delete pod,service order 

danielkec

#############################################
# PROVIDE THESE VALUES NEEDED FOR WORKSHOP...
#############################################


export GRAALVM_HOME=~/graalvm-ce-java11-20.1.0
export JAEGER_QUERY_ADDRESS=http://130.61.207.39:80
#for example export JAEGER_QUERY_ADDRESS=http://123.123.123.123:8080
export OCI_REGION=eu-frankfurt-1
# for example export OCI_REGION=us-phoenix-1