//串行队列
CCMQMessageQueue *searialQueue = [[CCMQMessageQueue alloc] initWithType:CCMQMessageQueueTypeSerial tag:@"serial"]

//并行队列
CCMQMessageQueue *concurrentQueue = [[CCMQMessageQueue alloc] initWithType:CCMQMessageQueueTypeConcurrent tag:@"concurrent"];
//设置并行发送的消息数量
concurrentQueue.maxConcurrentCount = 5;

CCMQMessage *message = [[CCMQMessage alloc] init];
//设置消息内容
message.message = "Datas";
[queue publish:message];

CCMQMessageSubscriber *subSerial = [[CCMQMessageSubscriber alloc] init];
//设置订阅者的port号
subSerial.port = @"sub1";
subSerial.subscribe = ^(CCMQMessage * _Nonnull message) {
    //订阅者可以在这里处理收到的消息
    ...
    //对于手动ACK的队列，需要手动进行ACK回复
    [queue finishMessage:message port:@"sub1"];
};
[queue addSubscriber:subSerial];