@Override
public void onSuccess(Void value) {
_logger.fine("on connect Success! in container " + container);
final AmqpSession session = conn.createSession();
Target rqtarget = new Target();
rqtarget.setAddress("rq-tgt");
final AmqpSender sender = session.createSender(rqtarget, QoS.AT_LEAST_ONCE, "request-yyy");
Source rqsource = new Source();
rqsource.setAddress("rs-src");
sender.getEndpoint().setSource(rqsource);
Source rssource = new Source();
rssource.setAddress("rs-src");
final AmqpReceiver receiver = session.createReceiver(rssource , QoS.AT_LEAST_ONCE, 10, "response-yyy");
Target rstarget = new Target();
final String address = "rs-tgt";
rstarget.setAddress(address);
receiver.getEndpoint().setTarget(rstarget);
sender.onRemoteClose(new Callback<ErrorCondition>() {
@Override
public void onSuccess(ErrorCondition value) {