You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@beam.apache.org by kasper <ka...@krondorsoft.com> on 2019/09/18 08:34:36 UTC
Beam AmqpIO
Hello,
AmqpIO seems to have a dependency on the
org.apache.qpid.proton.messenger package in usage but I do not seem to
find that package anywhere in a public nexus repository. The net effect
seems to be a classdefnotfound concerning
org.apache.qpid.proton.messenger.Messenger$Factory. Any hints?
Kasper
Re: Beam AmqpIO
Posted by Alexey Romanenko <ar...@gmail.com>.
For reference:
https://issues.apache.org/jira/browse/BEAM-8282 <https://issues.apache.org/jira/browse/BEAM-8282>
> On 18 Sep 2019, at 13:58, Jean-Baptiste Onofré <jb...@nanthrax.net> wrote:
>
> Hi,
>
> As the original author of AmqpIO, I can update, but it requires some
> internal changes to the IO (especially the way we are dealing with
> checkpoint).
>
> I will create a Jira and work on an update.
>
> Regards
> JB
>
> On 18/09/2019 12:50, Alexey Romanenko wrote:
>> It seems that we use pretty outdated version of proton-j, current version is 0.33.2.
>>
>> In the same time, Messenger API was deprecated and removed a while ago. So, updating to new version won’t be so easy. What can be as alternative for this?
>>
>>> On 18 Sep 2019, at 10:47, Jean-Baptiste Onofré <jb...@nanthrax.net> wrote:
>>>
>>> Hi,
>>>
>>> It's provided by Apache QPid proton-j: org.apache.qpid:proton-j:0.13.1
>>>
>>> Regards
>>> JB
>>>
>>> On 18/09/2019 10:34, kasper wrote:
>>>> Hello,
>>>>
>>>> AmqpIO seems to have a dependency on the
>>>> org.apache.qpid.proton.messenger package in usage but I do not seem to
>>>> find that package anywhere in a public nexus repository. The net effect
>>>> seems to be a classdefnotfound concerning
>>>> org.apache.qpid.proton.messenger.Messenger$Factory. Any hints?
>>>>
>>>> Kasper
>>>>
>>>
>>> --
>>> Jean-Baptiste Onofré
>>> jbonofre@apache.org
>>> http://blog.nanthrax.net
>>> Talend - http://www.talend.com
>>
>
> --
> Jean-Baptiste Onofré
> jbonofre@apache.org
> http://blog.nanthrax.net
> Talend - http://www.talend.com
Re: Beam AmqpIO
Posted by Jean-Baptiste Onofré <jb...@nanthrax.net>.
Hi,
As the original author of AmqpIO, I can update, but it requires some
internal changes to the IO (especially the way we are dealing with
checkpoint).
I will create a Jira and work on an update.
Regards
JB
On 18/09/2019 12:50, Alexey Romanenko wrote:
> It seems that we use pretty outdated version of proton-j, current version is 0.33.2.
>
> In the same time, Messenger API was deprecated and removed a while ago. So, updating to new version won’t be so easy. What can be as alternative for this?
>
>> On 18 Sep 2019, at 10:47, Jean-Baptiste Onofré <jb...@nanthrax.net> wrote:
>>
>> Hi,
>>
>> It's provided by Apache QPid proton-j: org.apache.qpid:proton-j:0.13.1
>>
>> Regards
>> JB
>>
>> On 18/09/2019 10:34, kasper wrote:
>>> Hello,
>>>
>>> AmqpIO seems to have a dependency on the
>>> org.apache.qpid.proton.messenger package in usage but I do not seem to
>>> find that package anywhere in a public nexus repository. The net effect
>>> seems to be a classdefnotfound concerning
>>> org.apache.qpid.proton.messenger.Messenger$Factory. Any hints?
>>>
>>> Kasper
>>>
>>
>> --
>> Jean-Baptiste Onofré
>> jbonofre@apache.org
>> http://blog.nanthrax.net
>> Talend - http://www.talend.com
>
--
Jean-Baptiste Onofré
jbonofre@apache.org
http://blog.nanthrax.net
Talend - http://www.talend.com
Re: Beam AmqpIO
Posted by Alexey Romanenko <ar...@gmail.com>.
It seems that we use pretty outdated version of proton-j, current version is 0.33.2.
In the same time, Messenger API was deprecated and removed a while ago. So, updating to new version won’t be so easy. What can be as alternative for this?
> On 18 Sep 2019, at 10:47, Jean-Baptiste Onofré <jb...@nanthrax.net> wrote:
>
> Hi,
>
> It's provided by Apache QPid proton-j: org.apache.qpid:proton-j:0.13.1
>
> Regards
> JB
>
> On 18/09/2019 10:34, kasper wrote:
>> Hello,
>>
>> AmqpIO seems to have a dependency on the
>> org.apache.qpid.proton.messenger package in usage but I do not seem to
>> find that package anywhere in a public nexus repository. The net effect
>> seems to be a classdefnotfound concerning
>> org.apache.qpid.proton.messenger.Messenger$Factory. Any hints?
>>
>> Kasper
>>
>
> --
> Jean-Baptiste Onofré
> jbonofre@apache.org
> http://blog.nanthrax.net
> Talend - http://www.talend.com
Re: Beam AmqpIO
Posted by Jean-Baptiste Onofré <jb...@nanthrax.net>.
Hi,
It's provided by Apache QPid proton-j: org.apache.qpid:proton-j:0.13.1
Regards
JB
On 18/09/2019 10:34, kasper wrote:
> Hello,
>
> AmqpIO seems to have a dependency on the
> org.apache.qpid.proton.messenger package in usage but I do not seem to
> find that package anywhere in a public nexus repository. The net effect
> seems to be a classdefnotfound concerning
> org.apache.qpid.proton.messenger.Messenger$Factory. Any hints?
>
> Kasper
>
--
Jean-Baptiste Onofré
jbonofre@apache.org
http://blog.nanthrax.net
Talend - http://www.talend.com