第 4 章 例子

package org.apache.qpid.protonj2.client.examples;

import org.apache.qpid.protonj2.client.Client;
import org.apache.qpid.protonj2.client.Connection;
import org.apache.qpid.protonj2.client.ConnectionOptions;
import org.apache.qpid.protonj2.client.Message;
import org.apache.qpid.protonj2.client.Sender;
import org.apache.qpid.protonj2.client.Tracker; 

public class Send {

    private static final int MESSAGE_COUNT = 100; 

    public static void main(String[] argv) throws Exception {
        final String serverHost = System.getProperty("HOST", "localhost"); 

        final int serverPort = Integer.getInteger("PORT", 5672); 

        final String address = System.getProperty("ADDRESS", "send-receive-example");

        final Client client = Client.create(); 

        final ConnectionOptions options = new ConnectionOptions(); 

        options.user(System.getProperty("USER"));
        options.password(System.getProperty("PASSWORD"));

        try (Connection connection = client.connect(serverHost, serverPort, options); 

             Sender sender = connection.openSender(address)) {  

            for (int i = 0; i < MESSAGE_COUNT; ++i) {
                Message<String> message = Message.create(String.format("Hello World! [%s]", i)); 

                Tracker tracker = sender.send(message); 

                tracker.awaitSettlement(); 

                System.out.println(String.format("Sent message to %s: %s", sender.address(), message.body()));
            }
        }
    }
}