/** * Created by hidden on 2017/2/14. */ public class PriorityProducer { public static final String ip = "xx.xx.xx.73"; public static final int port = 5672; public static final String username = "root"; public static final String password = "root";
public static void main(String[] arggs) throws IOException, TimeoutException { ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setPassword(password); connectionFactory.setUsername(username); connectionFactory.setPort(port); connectionFactory.setHost(ip);
/** * Created by hidden on 2017/2/14. */ public class PriorityConsumer { public static final String ip = "xx.xx.xx.73"; public static final int port = 5672; public static final String username = "root"; public static final String password = "root";
public static void main(String[] args) throws IOException, TimeoutException, InterruptedException { ConnectionFactory connectionFactory = new ConnectionFactory(); connectionFactory.setPassword(password); connectionFactory.setUsername(username); connectionFactory.setPort(port); connectionFactory.setHost(ip);