Hi Mark, Proton started initially as a pure protocol engine that would be used by other components such as brokers/clients/routers/other to support AMQP 1.0, rather than itself being as any type of direct client etc. That is how proton-j continues to see most of its usage that I am familiar with, e.g within the Qpid JMS client, the ActiveMQ brokers. It hasn't had as much work on fleshing out other areas as there has been on proton-c and its various language bindings.
Over time and mostly on the proton-c side of things Messenger emerged as kind of message-oriented API, and eventualy a Java port of it was written which is what you are trying to use below. Messenger in general isnt getting as much developer attention these days, but the java port of Messenger in particular has never seen very much attention since it was written originally, we likely need to have a discussion in the community about its future (probably best reserved for the new year when folks are actually around). Since then, there has been more work in other areas such as the python bindings for proton-c around creating a reactive API for client (or other) usage, and a 'reactor' within proton-c for use by e.g those bindings as well as those in order languages, with C++ reactive API work ongoing now as well as bits for Go. A Java variant of the reactor was added too, I'm not particularly familiar with it but I believe there are some examples for it too, though I don't think its been quite as fleshed out for simple application usage as the others have. In terms of what you actually did below, one thing that springs to mind is that I'm not sure 'messenger-j' ever supported anything other than ANONYMOUS SASL. If thats still the case, the user/pass you mention below may not even be getting used, and if the broker isnt then offering ANONYMOUS suppport (which it doesnt by default) then that might be a reason things aren't working at all. Robbie On 18 December 2015 at 15:41, Mark Soderquist <soderquis...@ldschurch.org> wrote: > I am working on implementing an AMQP client with the proton-j 0.11.1 library. > I found the example Java code that comes with the project and have > implemented a simple send client. So far, however, I am unable send any > messages. The code executes and exits without exceptions. I am working with a > Qpid 6.0.0 Java broker using AMQPS and have also included the bouncycastle > library in my project to support TLS. Here is the code I have implemented to > see what I have missed: > > String uri = "amqps://" + username + ":" + password + "@" + host + ":" > + port + "/" + queue; > > try { > Messenger messenger = Proton.messenger(); > messenger.start(); > > Message message = Proton.message(); > message.setAddress( uri ); > message.setSubject( "test" ); > message.setBody( new AmqpValue( payload ) ); > > messenger.put( message ); > messenger.send(); > messenger.stop(); > } > catch( Exception exception ) { > exception.printStackTrace( System.err ); > } > > Here is a sample URI with the username and password changed: > amqps://username:passw...@qpid-test.ldschurch.org:5671/test > > --- > Mark Soderquist > Engineering Manager | Enterprise Integration > The Church of Jesus Christ of Latter-Day Saints --------------------------------------------------------------------- To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org