[rabbitmq-discuss] php talking to ruby

[Robin Wood]

On 19 January 2011 16:41, Pieter de Zwart <pdezwart at rubiconproject.com> wrote:
> It unfortunately sounds like the PHP client is not conforming to the spec,
> or that the configuration isnt working. I am not familiar with the default
> routing mechanism (adding to my to do list now,) but I see no reason why we
> cant shoe horn your original code to work. First, you need to remove the
> queue declaration from your PHP code:
>
> // Create a connection
> $cnn = new AMQPConnection();
> $cnn->connect();
>
> // Declare a new exchange
> $ex = new AMQPExchange($cnn);
> $ex->declare('direct1', AMQP_EX_TYPE_DIRECT);
>
> // Publish a message to the exchange with a routing key
> $ex->publish('message', 'routing.key');
>
> The Ruby client should have already defined the queue and its binding on
> which it will be listening. Give that a shot and let us know how it works
> out.
>
> me

That has got rid of the errors but the Ruby consumer doesn't appear to
be receiving anything. The consumer I'm using is the one I sent at
10:24 which should display anything that it receives.

I remember having a very similar problem getting php to talk to .net
over SOAP. That took a lot of work to get php to talk nicely but once
it was there it worked fine.

Robin



>
> On 1/19/11 6:10 AM, "Robin Wood" <robin at digininja.org> wrote:
>
>> On 19 January 2011 13:39, Michael Klishin <michael.s.klishin at gmail.com> wrote:
>>> Robin,
>>> What happens here two of your apps declare queue with different attributes
>>> because default values for
>>> parameters like durability seems to differ between that php library and what
>>> amqp gem uses.
>>
>> I was hoping that that was the problem rather than a bug in my code.
>>
>>> Since you only want to consume messages on the Ruby side and publish them on
>>> the PHP side, you
>>> have an option of only declaring one queue in your Ruby app and one exchange
>>> in the PHP app. Then you
>>> can use default exchange that routes messages to queues when routing key
>>> matches queue name.
>>> When queue is declared only in one place, differences in library defaults
>>> won't get in the way. And, default exchange
>>> was added to AMQP spec exactly for simple
>>> cases like yours. This scenario is
>>> described at http://www.rabbitmq.com/tutorial-one-python.html.
>>> Hope this helps.
>>
>> I've had a look at the tutorial and from my original code I've removed
>> the exchange line from the Ruby consumer script which I assume means
>> it will go to the default one and changed the php exchange declare
>> line to:
>>
>> $ex->declare('');
>>
>> but when I run it I get
>>
>> PHP Fatal error:  Uncaught exception 'AMQPExchangeException' with
>> message 'Server channel error: 403, message: ACCESS_REFUSED -
>> operation not permitted on the default exchange' in
>> /home/robin/comms/a.php:9
>> Stack trace:
>> #0 /home/robin/comms/a.php(9): AMQPExchange->declare('')
>> #1 {main}
>>   thrown in /home/robin/comms/a.php on line 9
>>
>> If I change the empty string to default then I get the same
>> PRECONDITION_FAILED as before. I've not added any authentication
>> anywhere.
>>
>> I want this to be able to work both directions, php tell Ruby to do
>> something then Ruby tell php when it is finished through a different
>> message. Will this work with this setup once I get the actual code
>> working?
>>
>> Robin
>>
>>>
>>> 2011/1/19 Robin Wood <robin at digininja.org>
>>>>
>>>> When I run the php I get:
>>>>
>>>> PHP Fatal error:  Uncaught exception 'AMQPQueueException' with message
>>>> 'Server channel error: 406, message: PRECONDITION_FAILED - parameters
>>>> for queue 'queue1' in vhost '/' not equivalent' in
>>>> /home/robin/sched/a.php:13
>>>> Stack trace:
>>>> #0 /home/robin/sched/a.php(13): AMQPQueue->declare('queue1')
>>>> #1 {main}
>>>>  thrown in /home/robin/sched/a.php on line 13
>>>>
>>>
>>> --
>>> MK
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>