Hi Michael, My thoughts are that in the intercept method of PubSubClientIntroductionAdvice we can publish messages similar to Mqtt.
https://github.com/micronaut-projects/micronaut-mqtt/blob/230a6564344ceea21bcf244681d10b79763b2b19/mqtt-core/src/main/java/io/micronaut/mqtt/intercept/AbstractMqttIntroductionAdvice.java#L75 https://github.com/micronaut-projects/micronaut-mqtt/blob/230a6564344ceea21bcf244681d10b79763b2b19/mqttv3/src/main/java/io/micronaut/mqtt/v3/intercept/MqttIntroductionAdvice.java#L48 The publish method will call stmr.addData. Regards, Saikat On Sun, Nov 1, 2020 at 3:14 AM Denis Garus <garus....@gmail.com> wrote: > Hello, Saikat! > > I know that IgniteMessagin is used in the production environment and > I don't see any bugs in Jira with this feature. > I wrote some tests for IgniteMessaging in the security suite, and only one > confusing thing was noticed [1]. > > Why did we decide to deprecate IgniyeMessaging API in Ignite 3.0? > > 1. > http://apache-ignite-developers.2346864.n4.nabble.com/Inconsistent-behavior-of-IgniteMessaging-td47481.html > > вс, 1 нояб. 2020 г. в 04:43, Michael Pollind <mpoll...@gmail.com>: > >> I'm looking at this data stream api and I'm having a hard time working out >> how this scheme fits into the pub sub model that micronaut uses. Here is >> what I've kind of come up with and wonder if this would work. >> >> @PubSubClientpublic interface MultipleMessage { >> >> @Topic("animals") >> public void send(@key() String key, Animal o); >> >> @Topic("my_topic") >> public void send2(@key() Long key, Object o); >> } >> >> >> @PubSubListener >> >> public class SimpleSub { >> >> @Subscription("animals") >> >> public class Listener(@key() String key, Animal o) { >> >> } >> >> } >> >> >> On Tue, Oct 27, 2020 at 7:15 PM Saikat Maitra <saikat.mai...@gmail.com> >> wrote: >> >> > Hi Michael, Denis >> > >> > I did an initial review of the PR and wanted to share my thoughts. I >> > observed that currently the implementation is using Ignite messaging >> apis >> > and I am thinking if we should change the implementation to use Ignite >> data >> > streaming apis. The reason for change is to ensure that it will be >> better >> > aligned to Ignite 3.0 release as we are planning to deprecate Ignite >> > Messaging apis in Ignite 3.0 [1] >> > >> > My recommendation to use Ignite data streaming apis is also due to the >> > fact that we have multiple integration like Google Pub/Sub[2] and Kafka >> > Streamer[3] that uses Data streaming apis for integration and it will >> keep >> > micronaut implementation consistent with other extensions. >> > >> > Here is an example[4] of how Kafka Streamer can be used to stream data >> > into Ignite nodes. >> > >> > >> > [1] >> https://cwiki.apache.org/confluence/display/IGNITE/Apache+Ignite+3.0 >> > [2] >> > >> https://github.com/apache/ignite-extensions/blob/master/modules/pub-sub-ext/src/main/java/org/apache/ignite/stream/pubsub/PubSubStreamer.java >> > [3] >> > >> https://github.com/apache/ignite-extensions/blob/master/modules/kafka-ext/src/main/java/org/apache/ignite/stream/kafka/KafkaStreamer.java >> > [4] >> > >> https://github.com/samaitra/streamersk-extensions/blob/main/src/main/kotlin/com/example/streamerskextensions/kafka/KafkaStreamer.kt >> > >> > Please let me know your feedback. >> > >> > Regards, >> > Saikat >> > >> > On Tue, Oct 27, 2020 at 12:48 PM Denis Magda <dma...@apache.org> wrote: >> > >> >> Michael, glad to see you back! >> >> >> >> Could you please explain in a few words what this integration does and >> >> what >> >> it enables for Ignite and Micronaout? So that we are as a community >> are on >> >> the same page. >> >> >> >> - >> >> Denis >> >> >> >> >> >> On Sun, Oct 25, 2020 at 3:05 PM Michael Pollind <mpoll...@gmail.com> >> >> wrote: >> >> >> >> > I've started to work on adding some basic pubsub support for >> >> > Micronaut-ignite. I only have a draft PR in progress. There are a >> couple >> >> > modules that already implement pub-sub so those modules would be a >> good >> >> > start for reference: >> >> > https://github.com/micronaut-projects/micronaut-gcp >> >> > https://github.com/micronaut-projects/micronaut-kafka >> >> > https://github.com/micronaut-projects/micronaut-mqtt >> >> > >> >> > https://github.com/micronaut-projects/micronaut-ignite/pull/62 >> >> > >> >> > >> >> > >> >> >> > >> >
