Using C example basic pub and sub with "wmw"


Mark Perkin <mark@...>
 

Hi,

I'm trying to get the examples mamapublisherc and mamasubscriberc to talk to each other over "wmw". They work fine with "avis". I've tried the following:

./c/mamapublisherc  -s "FEED.BASIC" -tport pub -m wmw -v -v -v
./c/mamasubscriberc -s "FEED.BASIC" -tport sub -m wmw -v -v -v

Where mama.properties contains:

mama.wmw.transport.sub.subscribe_address_0=localhost
mama.wmw.transport.sub.subscribe_port_0=5050

mama.wmw.transport.pub.publish_port=5050

And I have LD_LIBRARY_PATH set to point to the lib directory from the MAMA 6.0 release.

The two appear to connect as I see the publisher logs the following periodically:

Publishing message 58 to FEED.BASIC.2013-03-20 16:38:59: Transport 0x1b70c10 [mama.wmw.transport.pub]: 1 clients connected.
2013-03-20 16:38:59:
    Client IP      : 127.0.0.1
    Client Port    : 41691
    Client AppName : lt-mamasubscriberc
    Connect Time   : 26
    Subsc Count    : 0
    Q items/size   : 0/131072

The publisher logs that it is publishing messages every second but the subscriber never receives anything. As noted above, the same test with avis shows the subscriber logging receipt of messages.

I notice that the Subsc Count is 0 so the publisher doesn't think the connected client is subscribing to anything. The subscriber clearly appears to subscribe:

2013-03-20 16:41:11: (21dcc740) : setupBasic(): FEED.BASIC: subscription (0x1687370)
2013-03-20 16:41:11: (21dcc740) : wmwBridgeMamaSubscription_create (): Subscribe topic [FEED.BASIC]
2013-03-20 16:41:11: (21dcc740) : NamingService::sendHeartbeat failed to send for client 0x0100007f000055e1
2013-03-20 16:41:11: (21dcc740) : Subscription 0x0x1687370 is now at state MAMA_SUBSCRIPTION_ACTIVATED.
mamasubscriberc: Created inbound subscription.

Any help appreciated.

thanks,

Mark

Join Openmama-users@lists.openmama.org to automatically receive all group messages.