by

Where communities thrive


  • Join over 1.5M+ people
  • Join over 100K+ communities
  • Free without limits
  • Create your own community
People
Repo info
Activity
  • Aug 04 16:33
    TheFellow opened #668
  • Jul 30 00:06
    TheFellow opened #667
  • Jul 30 00:01
    TheFellow edited #666
  • Jul 28 21:42
    TheFellow opened #666
  • Jul 21 00:33
    TheFellow opened #665
  • Jul 20 22:06

    jeremydmiller on master

    Apply configurations when updat… Pulsar allows native scheduled … Rename classes to be specific t… and 5 more (compare)

  • Jul 20 22:06
    jeremydmiller closed #664
  • Jul 20 22:04

    jeremydmiller on master

    Make exception_message and exce… Prepend all jasper tables with … Fix typo (compare)

  • Jul 20 22:04
    jeremydmiller closed #659
  • Jun 30 13:41
    JarrodJ83 review_requested #664
  • Jun 24 15:11
    JarrodJ83 opened #664
  • Jun 23 11:14

    JarrodJ83 on pulsar-cleanup

    Add Kafka readme and example (compare)

  • Jun 23 00:32

    JarrodJ83 on pulsar-cleanup

    Ignore tests not applicabale to… Implement KafkaCallbackChannel (compare)

  • Jun 22 23:39

    JarrodJ83 on pulsar-cleanup

    Update pkg details Implement DotPulsar channel cal… (compare)

  • Jun 22 17:53

    JarrodJ83 on pulsar-cleanup

    Apply configurations when updat… Pulsar allows native scheduled … Rename classes to be specific t… (compare)

  • Jun 15 12:15

    jeremydmiller on master

    Optional Parallel Rabbit MQ lis… (compare)

  • Jun 04 20:51
    JarrodJ83 commented #629
  • Jun 04 20:51
    JarrodJ83 commented #629
  • Jun 04 20:51
    JarrodJ83 commented #629
  • Jun 04 20:51
    JarrodJ83 commented #629
Jeremy D. Miller
@jeremydmiller
:thumbsup:
Got it
or will very soon
Mark Warpool
@CodingGorilla
Thanks, we have a big release of a different product next week, so I have a little breathing room on this particular issue, so no rush.
That and I put a bunch of locking on the handler to make sure it can't run twice at the same time for the short term =)
Svein Ellingsen
@lovmoen
Is there a way to perform a remote async "request/response" in the same way as Invoke<TResponse>()?
Jeremy D. Miller
@jeremydmiller
I don’t remember if that got yanked out or not, but there used to be an Request() method for that. I think I eliminated that in the thinking that you’d just use HTTP. That was some significant complexity
Svein Ellingsen
@lovmoen
OK, thanks for your quick response! I'll just have to figure a way around that then.
Svein Ellingsen
@lovmoen
On another note: The documentation doesn't really explain well the difference between SendAndExpectResponseFor, Send and Publish. Reading the section on "Send Message with Eventual Reply" it just shows a call to SendAndExpectResponseFor which looks just like a call to Send or Publish. A section explaining how these behave differently would be very helpful.
Svein Ellingsen
@lovmoen
@jeremydmiller I refer you to our discussions back in june; I had some trouble with scheduled messages. Since then I have been on vacation and later busy with other projects, but now I have this project on the top of my priority list again. I was wondering if you'd had any more time to look into the issues I raised wrt ScheduleSend and durable/non-durable queues. Also, I have now come a bit further in my project, and have implemented a saga whose Starts() method returns messages for future processing. I return an IEnumerable<object> of ScheduledResponse objects which should be sent out at a future time. But the behaviour I'm getting is immediate processing of these messages.
Svein Ellingsen
@lovmoen
Would I be better off using IMessageContext.ScheduleSend directly instead, injecting the IMessageContext into my saga object?
Svein Ellingsen
@lovmoen
I tried that approach, but ScheduleSend with a time in the future still sends the messages immediately.
Svein Ellingsen
@lovmoen
Sorry, not so! When converting correctly between local and UTC, Jasper does exactly what it says on the tin! My bad. Will check and report back on whether all my woes with scheduled messages have been due to poor timezone management on my part.
Svein Ellingsen
@lovmoen
Yep. That makes it work equally well when returning ScehduledResponse objects from the saga start handler.
Svein Ellingsen
@lovmoen
The problem I mentioned back in june remains, however: If I do Schedule to a queue, nothing happens. If I do ScheduleSend, it gets processed immediately if the queue is durable, and at the expected time if ithe queue is non-durable.
The behaviour can be reproduced with the example code I put on github: https://github.com/lovmoen/myjaspertest/tree/schedule-durable-queue
Jeremy D. Miller
@jeremydmiller
There was a bug about the scheduled messages going to a loopback queue, that was real.
I remember this conversation from back then. Are you on the latest now?
Svein Ellingsen
@lovmoen
Just tested on 0.9.13.
Jeremy D. Miller
@jeremydmiller
Nevermind that, I don’t see anything in the commit history for that.
I’ll try to get into that this weekend. I was just about to do some other work on Jasper anyway
Svein Ellingsen
@lovmoen
That's great! I just pushed my updated code to the above git repo if that's of any help.
Jeremy D. Miller
@jeremydmiller
Okay, thanks. I’ll definitely try to take a look soon
ddivita
@ddivita
What does the roadmap look like for .net Core 3?
Jeremy D. Miller
@jeremydmiller
Wait for aspnetcore 3.0 to come out, convert over to that, and finally kick out a 1.0
Mark Warpool
@CodingGorilla
@jeremydmiller Any word on #532 ?
Jeremy D. Miller
@jeremydmiller
Sigh, no. I could I guess actually sneak in some OSS time this afternoon though
Or tomorrow maybe
Svein Ellingsen
@lovmoen
Has there been a recent change in how Jasper uses Marten/database? When I started my project back in May, I set up marten backed persistence and everything worked falwlessly until I recently deployed my project with a fresh/empty database. Now I keep getting these exeptions: '[ERR] Running Recover persisted outgoing messages
Npgsql.PostgresException (0x80004005): 42P01: relation "public.jasper_outgoing_envelopes" does not exist' and 'Npgsql.PostgresException (0x80004005): 42P01: relation "public.jasper_incoming_envelopes" does not exist'. I set the marten option AutoCreateSchemaObjects to AutoCreate.All. Are there other (new?) initialization procedures that need to be performed?
Svein Ellingsen
@lovmoen
If I manually restore the tables from my old database, the exceptions go away.
Jeremy D. Miller
@jeremydmiller
Yeah, there has. I did a lot of work this spring to put the Sql Server backed persistence and Postgresql backed persistence on the same common core, so it got much less Marten-centric. Slightly different table structure now
The docs are up to date on how to seed your database, but I didn’t do anything for conversion:(
Svein Ellingsen
@lovmoen
Should have seen that Thanks! :)
Svein Ellingsen
@lovmoen
Any idea what could cause this on startup:
[11:09:25 FTL] An error occurred stopping the application
System.AggregateException: One or more errors occurred. (A task was canceled.) ---> System.Threading.Tasks.TaskCanceledException: A task was canceled.
at Jasper.Messaging.Durability.DurabilityAgent.StopAsync(CancellationToken cancellationToken)
at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.ExecuteAsync(Func2 callback) --- End of inner exception stack trace --- at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.ExecuteAsync(Func2 callback)
at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.StopAsync(CancellationToken token)
---> (Inner Exception #0) System.Threading.Tasks.TaskCanceledException: A task was canceled.
at Jasper.Messaging.Durability.DurabilityAgent.StopAsync(CancellationToken cancellationToken)
at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.ExecuteAsync(Func`2 callback)<--- 
[11:09:25 FTL] An error occurred stopping the application                                                                                             
System.AggregateException: One or more errors occurred. (A task was canceled.) ---> System.Threading.Tasks.TaskCanceledException: A task was canceled.
   at Jasper.Messaging.Durability.DurabilityAgent.StopAsync(CancellationToken cancellationToken)                                                      
   at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.ExecuteAsync(Func`2 callback)                                                       
   --- End of inner exception stack trace ---                                                                                                         
   at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.ExecuteAsync(Func`2 callback)                                                       
   at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.StopAsync(CancellationToken token)                                                  
---> (Inner Exception #0) System.Threading.Tasks.TaskCanceledException: A task was canceled.                                                          
   at Jasper.Messaging.Durability.DurabilityAgent.StopAsync(CancellationToken cancellationToken)                                                      
   at Microsoft.AspNetCore.Hosting.Internal.HostedServiceExecutor.ExecuteAsync(Func`2 callback)<---
Everything works great when I run locally, but when deploying to my test environment with docker containers, this is all I get from my headless jasper service.
Jeremy D. Miller
@jeremydmiller
Yeah, I do, and it’s already fixed in master. Bad ordering of when a CancellationToken was cancelled. I wanted to do a little more, but this and a couple other things makes it worth pushing out a new batch of Nugets today
Svein Ellingsen
@lovmoen
Sounds great! :)
Mark Warpool
@CodingGorilla
@jeremydmiller Do you think you will get some new nugets out tonight or maybe tomorrow morning?
Jeremy D. Miller
@jeremydmiller
Yes. I’ve got this yet to go: JasperFx/jasper#531
If that doesn’t go fast, I’ll just push nugets
Next thing up though is going to be converting to .Net Core 3.0 if that’s okay with you and @lovmoen
Mark Warpool
@CodingGorilla
yea, do you plan that for a "1.0"?
or do you think it will still be in pre-release mode for a couple more releases
Jeremy D. Miller
@jeremydmiller
Yes. Have to look at what else we’d wanna do for a 1.0. Biggest thing was waiting a bit for 3.0. Then having time to do a big blog push for it.
Nah, I’d rather get to 1.0 sooner, then follow up w/ 2.0 if I need to.
Mark Warpool
@CodingGorilla
Do you plan to support both netcoreapp2 and netcoreapp3 at the same time? Or just the latest?
Jeremy D. Miller
@jeremydmiller
I was hoping to only have to do one, but we could probably get away with dual support.
Jeremy D. Miller
@jeremydmiller
@CodingGorilla I’ve pushed 0.9.14, but it’ll take a bit for Nuget to catch up. What was your call on netcoreapp3.0 only vs supporting both that and netcoreapp2.0?