blob: 6ee498e2ab4f784ef151defa0f2ea574b15f3949 [file] [log] [blame] [view]
----------
## Api docs
### 1. Push Consumer
* consumer = CreatePushConsumer(consumerGroup) <br />
- function description<br />
create a push consumer instance, by setting consumer group<br />
- input <br />
consumerGroup: consumer group<br />
- return<br />
consumer: consumer instance
* SetPushConsumerNameServerAddress(consumer, namesrv) <br />
- function description<br />
set name srv address for the consumer instance<br />
- input <br />
consumer: consumer intance<br />
namesrv: name srv address. like : 127.0.0.1:9876
- return : no<br />
* Subscribe(consumer, topic, tag) <br />
- function description<br />
make consumer subscribe the topic and tag <br />
- input <br />
consumer: consumer intance<br />
topic: topic name
tag: topic tag
* RegisterMessageCallback(consumer, pyCallBack, pyArgs) <br />
- function description<br />
set callback for push consumer instance <br />
- input <br />
consumer: consumer intance<br />
pyCallBack: py callback method. when message pulled, they would be send to a pyCallback method<br />
pyArgs: the arguments will be passed to pyCallBack
* SetPushConsumerThreadCount(consumer, threadCount)
- function description<br />
set push consumer thread count<br />
- input <br />
consumer: consumer intance<br />
threadCount: thread count
* SetPushConsumerMessageBatchMaxSize(consumer, batchSize)
- function description<br />
set message count for one push<br />
- input <br />
consumer: consumer intance<br />
batchSize: message count
* SetPushConsumerInstanceName(consumer, instanceName)
- function description<br />
set consumer instance name<br />
- input <br />
consumer: consumer intance<br />
instanceName: consumer instance name
* SetPushConsumerSessionCredentials(consumer, accessKey, secretKey,channel)
- function description<br />
set consumer access keys<br />
- input <br />
consumer: consumer intance<br />
accessKey: accessKey<br />
secretKey: secretKey<br />
channel: channel<br />