[
Date Prev][
Date Next][
Thread Prev][
Thread Next][
Date Index][
Thread Index]
[
List Home]
Re: [messaging-dev] New API Requirements Was: Browsing / Streaming...
|
- From: Reza Rahman <reza_rahman@xxxxxxxx>
- Date: Fri, 14 Mar 2025 10:44:32 -0400
- Delivered-to: messaging-dev@xxxxxxxxxxx
- List-archive: <https://www.eclipse.org/mailman/private/messaging-dev/>
- List-help: <mailto:messaging-dev-request@eclipse.org?subject=help>
- List-subscribe: <https://www.eclipse.org/mailman/listinfo/messaging-dev>, <mailto:messaging-dev-request@eclipse.org?subject=subscribe>
- List-unsubscribe: <https://www.eclipse.org/mailman/options/messaging-dev>, <mailto:messaging-dev-request@eclipse.org?subject=unsubscribe>
- Thread-topic: Re: [messaging-dev] New API Requirements Was: Browsing / Streaming...
- Ui-outboundreport: notjunk:1;M01:P0:2AxWh6ek8a0=;80hCOtdfNg4HFgRIalLSCv8gx0S rpmU9UqvJgp20zPKUsSvNUyMHREvZezR+kfBBirL95I5mKBqWAOwbzX2GQ+RTk1BT803Yrjeb AbIy8WcxKy2ZvWZvYt0sMkMu/+K77RJg0j8/C1iwLPCWpQXRps9D/qzWYcu79wJjtuyysOIsZ 2PqlYfIzPvsh+pb6OAjQTVKjRwUK/L0AnP0sBwYPmJgh59d6nMfnAj4hAJ9X59nnpRcxGcSTl C3J+3R2ey2ou349DBDvxzC55kfQpT5P42834yOShspUMEg5GA0ARVfN0iGwrdXuqjadBkF+nv /aQ3SB8xdy3d6coqTxxkC0pKk5QLvzM5JqgNWCRvVvtdiWd+jMXKfNxaA2YiG/F8YWOeRvTCl D2ChLXs2LXd3jTwuK01rJmWE/C8vjVf72l+kcWbLGwCYM/avTz7g5Y6MHDrBFYrEIFpImoPRM E22lscy/ZHWzlk9ZFD7H0t+wL+O9gywlJfoIXL8xE+7vo0VadXwovm5cjgteLDG8wumOsZRhT 1iheYjZVCZzgugnZFxBJ06m2KwUC9yZIUzt66gCOBHvReKsgK+ZZvggI8ikwFpfeHmnyZZF68 9fpB2EheVTWz4+h6NGvmpXxCAEo6cLHQSBj3aGN65wrQjGqk0ICnQdUKXnTcntgahnHwiTV4s VuKbcXnJVlj3qcQcwtz8asiqSkHfADGNq+r00qMTiSYMhSEdHJOzFtS79yM+JTbIJwdLTOZ2I irmZsSOp1/YD4XCVk9DOe/87JylcbSbUntKNMrpyNejY15z6h1rCXCPidhRJgjX3nP218m5HB 8b4A6H0UymwMMdS64ynds5DRFufYkrgaJosa/GMc1dDGfvRWW19hegUja/OhBKY45VPKBkhHw +nmfV73E+oqAzIWCFP0XW3pPIK1JQ3SM2BTr0k8fKOXya+OmhbJicRnwopNLZDLS5xbP9jfGa bqHoJtY85v3AZZiH6MnD1Qkaq7nUoYoyLgnR5lRMDC6D+z0QQss6nlxfzx5/VCcvjHf859+cO OjDgIn4CfUyei/VxADixANpogaX/SM8YaPhkCJQwmOvi5xcvXv4/9b3izhPIjkLcW1k+oceec i7/B3yP1hK1KpLZKa8lsXFrDmXPOqimWpbu70IBwIw1DWwYGgZIbsEt3rZCgtuY6ZwzkEPDEK nw9Q2TJF6H1ZFQpk1RKklrkNoqrQelGat+saRx8iHhHJPZdzxdEcE7FgTwWVr5ch+on2SOokC Q+26SA8zjN6Sjs0LBTLSLQ6nTHH9DadWWck9kBBOyRg5hWhZ/JRzn0721TdA3PBTSvEADqO++ zACaD9D/w/s9a4+61Dbm3eIKXLtg5vKA7qSgpkwCfQNFcF9FBSrDVp5bWBtl42+MtPLgV1RZd /eDEEy/XQuGbKGNKkl0YEl/M2jDRdKEm7P9vr4MgIHslWKUuA2DWlXJ/SM1oAG1bEjXG0rsFJ ioT3i0g==
Yep. We came to that realization in the JMSContext conversation. To be honest it would be great to think about whether producer and consumer needs to separate APIs either.
From: messaging-dev <messaging-dev-bounces@xxxxxxxxxxx> on behalf of Clebert Suconic via messaging-dev <messaging-dev@xxxxxxxxxxx>
Sent: Friday, March 14, 2025 10:38 AM
To: EE4J Messaging project developer discussions <messaging-dev@xxxxxxxxxxx>
Cc: Clebert Suconic <csuconic@xxxxxxxxxx>
Subject: [messaging-dev] New API Requirements Was: Browsing / Streaming...
Another thing I would do on the new API: No need for Session.
Just Connection -> Consumers
Connection -> Producers
(notice: I'm not assuming we will call them Consumers and Producers yet).. the point I'm making here is I'm trying to not use the concept of a Session.
If needed I can list a number of reasons for removing the Session concept. At this point I think it's obvious and if someone disagrees I can list the reasoning here.
Having a single way to receive anything in terms of Messaging would be a dream come true :)
Love it! Let’s do it ;-)
At this point it seems to a good idea to have these two concepts differentiated... Queuing and Streaming..
Why do you think it should be differentiated? What is the difference to a coded application to handle this that couldn’t be handled in a configuration flag instead of a change in class used in the API? The original JMS API had this same type of paradigm that became an issue when using topic v queue. This approach required a code-change to switch destination types instead of being able to adjust a config value.
I think it would be better to have a simplified API that is a reader and the only difference if you want stream (no ack) or read (ack) is some sort of config flag or ack mode.
Thanks,
Matt Pavlovich
I would first need to understand more about the use case to be honest.
Is this the same as the existing browsing use case or is it actually consuming messages off a queue? If the latter, this would be an imperative alternative to MDB style declarative message consumption?
well.. you have things on a certain context...
you could maybe even reuse some of the Java Streams API, expand perhaps?
Naming is hard! The first thing that jumped out at me is that ’streaming’ is confused with the Java ’streams’ language feature. I lean towards ‘Event’ since it is shorter (and not as over loaded).
Matt Pavlovich
> On Mar 12, 2025, at 2:40 PM, Clebert Suconic via messaging-dev <
messaging-dev@xxxxxxxxxxx> wrote:
>
> I'm planning to spend some time next week writing some ideas...
>
>
> But before I spend time on it.. I wanted to ask something...
>
>
> There's the concept of a Browser in the current JMS API. What if we called it Streaming?
>
> You would have a differentiation between Queueing semantics (single destination polling messages between multiple endpoints) and Streaming semantics where all the messages from the destinations are received.
>
> It's the same concept in the end.. but maybe Streaming would be a better name for a newer API.
>
>
>
> _______________________________________________
> messaging-dev mailing list
>
messaging-dev@xxxxxxxxxxx
> To unsubscribe from this list, visit
https://accounts.eclipse.org