Ayende @ Rahien

My name is Oren Eini
Founder of Hibernating Rhinos LTD and RavenDB.
You can reach me by phone or email:


+972 52-548-6969

, @ Q c

Posts: 6,131 | Comments: 45,568

filter by tags archive

RavenMQ update

time to read 2 min | 372 words

It wasn’t planned so much as it happened, but RavenMQ just slipped into private beta stage. The API is still in a the somewhat clumsy state, but it it is working quite nicely Smile

You can see an example of the client API below:

using(var connection = RavenMQConnection.Connect("http://reduction:8181"))
    connection.Subscribe("/queues/abc", (context, message) => 

    connection.PublishAsync(new IncomingMessage
        Queue = "/queues/abc",
        Data = Encoding.UTF8.GetBytes("Hello Ravens")


Please note that this is likely to be subject to many changes.

This is written about 10 minutes after I posted the code above:

using(var connection = RavenMQConnection.Connect("http://localhost:8181"))
        Subscribe<User>("/queues/abc", (context, message) => Console.WriteLine(message.Name));

        .Add("/queues/abc", new User {Name = "Ayende"})


I told you it would change… Open-mouthed smile



I like the subscribe, don't like the publish.

Does it run on mono?


I don't like the publish either. It should be connection.PublishAsync("/queues/abc", new User { Name = "Ayende" });

Why do you need connection.StartPublishing?

Johannes Gustafsson

Is RavenMQ transactional?

Or a bit more specific: Would you recommend RavenMQ as an nservicebus transport?

Bryan Murphy

I agree with configurator. Anything more than that and it's too much.


Is this going to work with the DTC? How does Ravenmq compare to rabbitmq? If it wil work on the DTC then it will be possible to integrate with nservicebus.

Frank Quednau

You don't have to go into a fit for API. If I'd be using it in the client, I'd probably stick MemBus on top of it and...

bus.Publish(new User {Name = "Ayende"});


void Handle(User user) {

RavenMQConnection w/queuename etc.etc.


Just wondering how much logic goes into the queue name, if I remember correctly it can be a pretty dynamic thing...

Ayende Rahien

Bryan & configurator,

Yes, it runs on Mono.

And the reason that it needs the StartPublishing code is that we want to make the API very explicit about the way we support sending multiple messages in a single batch

Ayende Rahien


Yes, it is transactional.

And while you could use it as a NSB transport, its main usage scenario is being expose to the actual clients

Mike Brown

Hats off to you man! Every time I visit you've got something amazing going. So did you steal Dumbledore's time turner or just figured out the cloning process. It's hard to believe that it's just you doing all of this.

Comment preview

Comments have been closed on this topic.


  1. RavenDB Conference 2016–Slides - 2 hours from now
  2. Proposed solution to the low level interview question - about one day from now

There are posts all the way to Jun 02, 2016


  1. The design of RavenDB 4.0 (14):
    26 May 2016 - The client side
  2. RavenDB 3.5 whirl wind tour (14):
    25 May 2016 - Got anything to declare, ya smuggler?
  3. Tasks for the new comer (2):
    15 Apr 2016 - Quartz.NET with RavenDB
  4. Code through the looking glass (5):
    18 Mar 2016 - And a linear search to rule them
  5. Find the bug (8):
    29 Feb 2016 - When you can't rely on your own identity
View all series



Main feed Feed Stats
Comments feed   Comments Feed Stats