These are chat archives for akkadotnet/AkkaStreams

17th
Jul 2018
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 10:21
I am trying to implement the AmqpSourceStageLogic, where I am converting Message to T. That could break, how do I get a decider to enter failed state, or just eat the exception and continue?
private void OnMessageReceived(IReceiverLink receiver, Message message)
        {
            try
            {
                Emit(outlet, ampqSourceSettings.Convert(message));
                receiver.Accept(message);
            } catch (Exception e)
            {

            }
        }
Marc Piechura
@marcpiechura
Jul 17 2018 10:34
You can probably copy/paste most of it
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 10:45
I am using 1.3.8 akka, the inheritedAttributes.GetDeciderOrDefault is not there anymore, or do I need an extra using?
Marc Piechura
@marcpiechura
Jul 17 2018 10:55
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 10:56
Ah thx I missed that part.
Marc Piechura
@marcpiechura
Jul 17 2018 10:57
hard to see without opening it in an ide ;-)
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 11:56
Just one test test class and I will have a pull request done for amqp v1.0
Marc Piechura
@marcpiechura
Jul 17 2018 12:55
👍
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 13:36
Humm, I am having an issue with the source. I am using the async/ callback method of the ReceiverLink in Amqp. But Akka wants to have a Handler set. Is there a way to get it done without a handler?
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 13:51
Never mind, I am using the Handler. I am having a successful test. It's quite basic. But I am going to make a pull request now.
AndreSteenbergen
@AndreSteenbergen
Jul 17 2018 13:57
Pull request done. I haven't made a nuspec file. Right now I am curious what people think