danielkec

 <dependency>
     <groupId>io.helidon.microprofile.messaging</groupId>
     <artifactId>helidon-microprofile-messaging</artifactId>
 </dependency>
 <dependency>
     <groupId>io.helidon.messaging.aq</groupId>
     <artifactId>helidon-messaging-aq</artifactId>
 </dependency>
 <dependency>
     <groupId>io.helidon.integrations.cdi</groupId>

danielkec

javax:
  sql:
    DataSource:
      local-example-ds:
        connectionFactoryClassName: oracle.jdbc.pool.OracleDataSource
        URL: jdbc:oracle:thin:@localhost:1521:XE
        user: frank
        password: frank

mp:

danielkec

 // Setup connector
 JmsConnector seConn = JmsConnector.create();

 // Prepare channels
 Channel<String> toJms = Channel.create("to-jms");
 Channel<String> fromJms = Channel.create("from-jms");

 // Prepare emitter for interaction with non-reactive code
 Emitter<String> emitter = Emitter.create(toJms);

danielkec

 <dependency>
     <groupId>io.helidon.messaging.jms</groupId>
     <artifactId>helidon-messaging-jms</artifactId>
 </dependency>
 <!-- JMS client implenting JMS api of your choice-->
 <dependency>
     <groupId>org.apache.activemq</groupId>
     <artifactId>activemq-client</artifactId>
 </dependency>

danielkec

 // Setup connector
 JmsConnector seConn = JmsConnector.create();

 // Prepare channels
 Channel<String> toJms = Channel.<String>builder()
         .name("to-jms")
         .subscriberConfig(JmsConnector.configBuilder()
                 .queue("example_queue_1")
                 .jndiInitialFactory(ActiveMQInitialContextFactory.class)
                 .jndiProviderUrl("tcp://192.168.0.123:61616")

danielkec

 // Manually define JMS connection factory
 ActiveMQConnectionFactory connectionFactory =
         new ActiveMQConnectionFactory("tcp://192.168.0.123:61616");
 
 // Setup connector
 JmsConnector seConn = JmsConnector.builder()
         .connectionFactory("jms-con-1", connectionFactory)
         .build();

 // Prepare channels

danielkec

 PoolDataSource pds = PoolDataSourceFactory.getPoolDataSource();
 pds.setConnectionFactoryClassName("oracle.jdbc.pool.OracleDataSource");
 pds.setURL("jdbc:oracle:thin:@localhost:1521:XE");
 pds.setUser("frank");
 pds.setPassword("frank");

 AqConnector seConn = AqConnector.builder()
         .dataSource("test-ds", pds)
         .build();

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>custom.com.oracle</groupId>

danielkec

# Install wlthint3client.jar to local msv repo
mvn install:install-file \
-Dfile=./wlthint3client.jar \
-DgeneratePom=true \
-DgroupId=custom.com.oracle \
-DartifactId=wlthint3client \
-Dversion=12.2.1.3 \
-Dpackaging=jar

danielkec

mp:
  messaging:
    connector:
      helidon-jms:
        jndi:
          jms-factory: jms/TestConnectionFactory
          env-properties:
            java.naming.factory.initial: weblogic.jndi.WLInitialContextFactory
            java.naming.provider.url: t3://localhost:7001
    incoming: