阻止单元格被拖出UITableView边界(Stop cell from being dragged out of UITableView bounds)

 BasicQos = 10表示客户端一次只获取10条消息，但是当您使用它时，您将始终看到一条消息。 请阅读： https ： //www.rabbitmq.com/consumer-prefetch.html 
 
 
 
 AMQP指定basic.qos方法，允许您在使用时限制通道（或连接）上未确认的消息数（也称为“预取计数”）。 
 
 
 对于您的范围，您必须下载消息，将其放在临时列表中，然后插入到数据库中。 
 
 然后你可以使用： 
 
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: true);
 
 
 
 void basicAck（） 
 
 
 参数：deliveryTag - 收到的AMQP.Basic.GetOk或AMQP.Basic.Deliver中的标记 
 
 
 multiple - 如果所有消息都包含所提供的传递标记，则为true; false仅确认提供的交付标记。 
 
 
 例 
 
final List<String> myMessagges = new ArrayList<String>();
        channel.basicConsume("my_queue", false, new DefaultConsumer(channel) {

            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                myMessagges.add(new String(body));
                System.out.println("Received...");

                if (myMessagges.size() >= 10) {
                    System.out.println("insert into DB...");
                    channel.basicAck(envelope.getDeliveryTag(), true);
                    myMessagges.clear();
                }


            }
        });

BasicQos = 10 means that the client fetch only 10 messages at time, but when you consume it you will see always one message a time. Read here: https://www.rabbitmq.com/consumer-prefetch.html
 
 
 
AMQP specifies the basic.qos method to allow you to limit the number of unacknowledged messages on a channel (or connection) when consuming (aka "prefetch count").
 
 
for your scope you have to download the messages, put it inside a temporary list and then insert into the DB.
 
an then you can use:
 
channel.BasicAck(deliveryTag: ea.DeliveryTag, multiple: true);
 
 
 
void basicAck()
 
 
Parameters: deliveryTag - the tag from the received AMQP.Basic.GetOk or AMQP.Basic.Deliver 
 
 
multiple - true to acknowledge all messages up to and including the supplied delivery tag; false to acknowledge just the supplied delivery tag.
 
 
Example
 
final List<String> myMessagges = new ArrayList<String>();
        channel.basicConsume("my_queue", false, new DefaultConsumer(channel) {

            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {
                myMessagges.add(new String(body));
                System.out.println("Received...");

                if (myMessagges.size() >= 10) {
                    System.out.println("insert into DB...");
                    channel.basicAck(envelope.getDeliveryTag(), true);
                    myMessagges.clear();
                }


            }
        });