Using Proton 0.7 to work with Qpid 0.26

[Mark Soderquist]

I am struggling to get Proton 0.7 to send any messages to a Qpid 0.26 broker. I 
have been able to send and receive message using the Qpid Messaging API for 
AMQP 1.0 but would rather use Proton if I can. I'm sure I'm just missing 
something but I haven't found it yet. Here is my code:

Messenger messenger = Proton.messenger( proton );
try {
  messenger.start();

  Message message = Proton.message();
  message.setAddress( amqp://testuser@qpid/pocqueue );
  message.setBody( new AmqpValue( test message ) );

  messenger.put( message );
  messenger.send();
}
catch( Throwable throwable ) {
  throwable.printStackTrace( System.err );
}
finally {
  messenger.stop();
}

Any suggestions?


 NOTICE: This email message is for the sole use of the intended recipient(s) 
and may contain confidential and privileged information. Any unauthorized 
review, use, disclosure or distribution is prohibited. If you are not the 
intended recipient, please contact the sender by reply email and destroy all 
copies of the original message.

Re: Using Proton 0.7 to work with Qpid 0.26

[Rajith Attapattu]

Mark,

Nothing is wrong with your code.
The issue is down to a difference in how SASL is handled in the Proton java
side and the c++ broker.
If I comment out the SASL code in the messenger impl your example works
properly.
I have seen this issue before and will investigate it further.

Rajith


On Thu, May 22, 2014 at 1:29 PM, Mark Soderquist soderquis...@ldschurch.org
 wrote:

 I am struggling to get Proton 0.7 to send any messages to a Qpid 0.26
 broker. I have been able to send and receive message using the Qpid
 Messaging API for AMQP 1.0 but would rather use Proton if I can. I'm sure
 I'm just missing something but I haven't found it yet. Here is my code:

 Messenger messenger = Proton.messenger( proton );
 try {
   messenger.start();

   Message message = Proton.message();
   message.setAddress( amqp://testuser@qpid/pocqueue );
   message.setBody( new AmqpValue( test message ) );

   messenger.put( message );
   messenger.send();
 }
 catch( Throwable throwable ) {
   throwable.printStackTrace( System.err );
 }
 finally {
   messenger.stop();
 }

 Any suggestions?


  NOTICE: This email message is for the sole use of the intended
 recipient(s) and may contain confidential and privileged information. Any
 unauthorized review, use, disclosure or distribution is prohibited. If you
 are not the intended recipient, please contact the sender by reply email
 and destroy all copies of the original message.