Daniel Kec danielkec
🚀
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <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
/ injected-factory.java
Created
November 24, 2020 13:40
Manually prepared ConnectionFactory
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @Produces | |
| @ApplicationScoped | |
| @Named("active-mq-factory") | |
| public ConnectionFactory connectionFactory() { | |
| return new ActiveMQConnectionFactory("tcp://127.0.0.1:61616"); | |
| } |
danielkec
/ reference-bean-cong.yaml
Last active
December 3, 2020 13:53
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| mp: | |
| messaging: | |
| connector: | |
| helidon-jms: | |
| named-factory: active-mq-factory | |
| outgoing.to-jms: | |
| connector: helidon-jms | |
| destination: messaging-test-queue-1 | |
| type: queue |
danielkec
/ incoming-jms.java
Created
November 24, 2020 14:03
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @Incoming("from-jms") | |
| @Acknowledgment(Acknowledgment.Strategy.MANUAL) | |
| public CompletionStage<?> consumeJms(JmsMessage<String> msg) { | |
| System.out.println("JMS says: " + msg.getPayload()); | |
| return msg.ack(); | |
| } |
danielkec
/ outgoing-jms.java
Created
November 24, 2020 19:45
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| @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
/ mp-jms-pom.xml
Created
November 24, 2020 20:38
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <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
/ jndi-conf.yaml
Last active
December 3, 2020 12:37
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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
/ wls-application.yaml
Created
November 26, 2020 13:04
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 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: |
danielkec
/ install-wlthint3client.sh
Created
November 26, 2020 13:07
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| # 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
/ wls-jms-pom.xml
Created
November 26, 2020 13:22
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| <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> |