When you say thrift over amqp, do you mean sending thrift objects as amqp messages? In this case, you just need to figure out how to {de,}serialize thrift objects, which can be done by writing an object to a TMemoryBuffer and grabbing the contents, or writing a serialized string to a TMemoryBuffer and reading in the contents to an object. I've done this in ruby, but not in java, but I assume the details are pretty much the same (unless there's a simpler way to do it in java).

If you're trying to make thrift calls, using amqp as the transport, I could see you writing a transport where the client waits on a result exchange, and sends a message to an exchange for the specific call. For example, the service could bind to serviceName.methodName.* and the client could send a message to serviceName.methodName with a random nonce, and the serialized call params, then wait on serviceName.methodName.results.nonce or something like that for the result. Of course, this seems a bit overengineered, and I'm not quite sure what it would accomplish that couldn't be accomplished through a simpler mechanism.

Regards,
Ben

| Hi,
|
| i am doing a Java Project having to use existing Thrift-over-AMQP | resources. Sadly i was unable | to find any documentation on how to get Thrift and AMQP working on Java | (1.6).
|
| If someone could gimme a link or something, that would enough to figure | out the rest by mysqlf. :)
|
| I am using thrift 0.2.0 (libjar) on rabbitmq 1.7.0 (and rabbitmq's amqp | java lib).
|
| Thanks in advance!
|
|
| best regards,
|
| franz

Reply via email to