Hello

I managed to run Dmaap locally with code from master branch.

I am able to list existing queues:

Request:
curl --request GET localhost:3904/topics/listAll
Response:
{"topics": [
    {
        "owner": "",
        "txenabled": false,
        "topicName": "msgrtr.apinode.metrics.dmaap"
    },
    {
        "owner": "",
        "txenabled": false,
        "topicName": "testTopic"
    }
]}


Also sending messages to quese seems to work fine:
Request:

curl --header "Content-type: application/json" --request POST --data 
'{"message":"messageContent"}' http://localhost:3904/events/testTopic


Response:

{
    "serverTimeMs": 2,
    "count": 1
}


Also in logs there are entries that message has been published:


""2018-04-06 12:59:09,875 [qtp1555093762-2808] INFO  
com.att.nsa.dmaap.service.EventsRestService - Publishing message to topic 
testTopic
""2018-04-06 12:59:09,879 [qtp1555093762-2808] INFO  
com.att.nsa.cambria.service.impl.EventsServiceImpl - Published 1 msgs in 2ms 
for topic testTopic


Now target is to read messages from topic named testTopic


According to:

http://onap.readthedocs.io/en/amsterdam/submodules/dmaap/messagerouter/messageservice.git/docs/Installation/Installation.html

below request should work fine:

curl -H “Content-Type:text/plain” -GET 
http://localhost:3904/events/testTopic/CG1/C1?timeout=1000

But it does not work. Also logs confirm that:
2018-04-06 13:03:25.608:WARN:oejh.HttpParser:qtp1555093762-2885: badMessage: 
400 for HttpChannelOverHttp@7a1b89e8{r=0,c=false,a=IDLE,uri=-}

>From EventsRestService implementation I can see that request should look like 
>as below one:
curl  --request GET localhost:3904/events/testTopic/{consumerGroup}/{consumerId}
But I do not know consumerGroup and ConsumerID.

So question how to read messages from DMaap using DMaap REST API?

Best regards,
Marcin Migdal
_______________________________________________
onap-discuss mailing list
onap-discuss@lists.onap.org
https://lists.onap.org/mailman/listinfo/onap-discuss

Reply via email to