Help running openmama qpid examples


Sahir Hoda
 

Hello,

I'm having trouble getting the openmama sample applications to talk to each other when using the qpid bridge. I am running the mamapublisherc and mamasubscriberc sample applications, however I do not seem to receive any messages.

I have downloaded and build the qpid-proton-0.4 library from qpid.apache.org.
I have cloned the openmama-git repo and built it.

I am using mama.properties from the source tree: mama/c_cpp/src/examples/mama.properties

I am starting 'mamasubscriberc -m qpid -v -v -v' and 'mamapublisherc -m qpid -v -v -v' on the same host, however I do not appear to get any messages.

Do I need to modify mama.properties? Do I need to have a qpid broker running? What do I need to set in mama.properties to point it to the broker? Appreciate any assistance.

Here qpid section of mama.properties:
# Source which you are going to consume from
mama.qpid.transport.pub.outgoing_url=amqp://localhost:6666/SOURCENAME
# Where qpid is going to listen to for data to be pushed to
mama.qpid.transport.pub.incoming_url=amqp://~localhost:7777/SOURCENAME
# Where qpid publisher is to send data to once subscription is created
mama.qpid.transport.pub.reply_url=amqp://localhost:7777/SOURCENAME

# Source which you are going to consume from
mama.qpid.transport.sub.outgoing_url=amqp://localhost:7777/SOURCENAME
# Where qpid is going to listen to for data to be pushed to
mama.qpid.transport.sub.incoming_url=amqp://~localhost:6666/SOURCENAME
# Where qpid publisher is to send data to once subscription is created
mama.qpid.transport.sub.reply_url=amqp://localhost:6666/SOURCENAME

# The size of the buffer used for proton message (de)serialization
mama.qpid.transport.msg_buffer_size=102400
# The maximum number of messages which proton will place onto dispatch queues
mama.qpid.transport.msg_pool_size=32

Here is the output of mamasubscriberc:
[sahir@bohr bin]$ ./mamasubscriberc -m qpid -v -v -v
Starting Subscriber with:
topic: MAMA_TOPIC
transport: sub
2013-07-29 10:23:50: mama_loadBridge(): Sucessfully loaded qpid bridge from library [mamaqpidimpl]
2013-07-29 10:23:50: Using path specified in WOMBAT_PATH
2013-07-29 10:23:50: Using default properties file mama.properties
2013-07-29 10:23:50: Attempting to load MAMA properties from /home/shoda/usr-storm6/openmama-qpid/bin
2013-07-29 10:23:50: qpidBridge_open(): Successfully created QPID queue
2013-07-29 10:23:50:
********************************************************************************
Warning: This is a developer release and has only undergone basic sanity checks.
It is for testing only and should not be used in a production environment
**********************************************************************************
2013-07-29 10:23:50: Using path specified in WOMBAT_PATH
2013-07-29 10:23:50: Using default properties file mama.properties
2013-07-29 10:23:50: Attempting to load MAMA properties from /home/shoda/usr-storm6/openmama-qpid/bin
2013-07-29 10:23:50: mama_loadPayloadBridge(): Sucessfully loaded qpidmsg payload bridge from library [mamaqpidmsgimpl]
2013-07-29 10:23:50: openmama DEVRELEASE2.2.1.1 (not entitled)
2013-07-29 10:23:50: 0.0.1
2013-07-29 10:23:50:
********************************************************************************
Note: This build of the MAMA API is not enforcing entitlement checks.
Please see the Licensing file for details
**********************************************************************************
2013-07-29 10:23:50: Entering mamaTransport_create for transport (0xc7fa00) with name sub
2013-07-29 10:23:50: Creating transport: [sub]
2013-07-29 10:23:50: Number of load balanced sub transports defined: [0]
2013-07-29 10:23:50: Not using load balancing
2013-07-29 10:23:50: qpidBridgeMamaTransport_create(): Initializing Qpid Transport sub
2013-07-29 10:23:50: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.sub.incoming_url]: [amqp://~localhost:6666/SOURCENAME] (User Defined)
2013-07-29 10:23:50: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.sub.outgoing_url]: [amqp://localhost:7777/SOURCENAME] (User Defined)
2013-07-29 10:23:50: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.sub.reply_url]: [amqp://localhost:6666/SOURCENAME] (User Defined)
2013-07-29 10:23:50: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.msg_pool_size]: [32] (User Defined)
2013-07-29 10:23:50: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.msg_pool_inc_size]: [128] (Default)
2013-07-29 10:23:50: sub: Using default preinitial strategy: ON_GAP
2013-07-29 10:23:50: sub: Using default dq strategy: DQ_SCHEME_DELIVER_ALL
2013-07-29 10:23:50: sub: Using default ft strategy: DQ_FT_DO_NOT_WAIT_FOR_RECAP
2013-07-29 10:23:50: sub: Pre-Recap cache disabled
2013-07-29 10:23:50: setupBasic(): MAMA_TOPIC: subscription (0xcea900)
mamasubscriberc: Created inbound subscription.
2013-07-29 10:23:50: qpidBridge_start(): Entering
2013-07-29 10:23:50: qpidBridge_start(): retrieved bridge
2013-07-29 10:23:50: qpidBridge_start(): Preparing to leave
2013-07-29 10:23:50: qpidBridgeMamaTransportImpl_dispatchThread(): Waiting on message...
2013-07-29 10:24:04: Starting refresh message mini-cycle
2013-07-29 10:24:04: No refreshes to send
2013-07-29 10:24:18: Starting refresh message mini-cycle
2013-07-29 10:24:18: No refreshes to send
^C

And the publisher output:
[sahir@bohr bin]$ ./mamapublisherc -m qpid -v -v -v
Starting Publisher with:
topic: MAMA_TOPIC
inbound topic: MAMA_INBOUND_TOPIC
interval 0.500000
transport: pub
2013-07-29 10:24:27: mama_loadBridge(): Sucessfully loaded qpid bridge from library [mamaqpidimpl]
2013-07-29 10:24:27: Using path specified in WOMBAT_PATH
2013-07-29 10:24:27: Using default properties file mama.properties
2013-07-29 10:24:27: Attempting to load MAMA properties from /home/shoda/usr-storm6/openmama-qpid/bin
2013-07-29 10:24:27: qpidBridge_open(): Successfully created QPID queue
2013-07-29 10:24:27:
********************************************************************************
Warning: This is a developer release and has only undergone basic sanity checks.
It is for testing only and should not be used in a production environment
**********************************************************************************
2013-07-29 10:24:27: Using path specified in WOMBAT_PATH
2013-07-29 10:24:27: Using default properties file mama.properties
2013-07-29 10:24:27: Attempting to load MAMA properties from /home/shoda/usr-storm6/openmama-qpid/bin
2013-07-29 10:24:27: mama_loadPayloadBridge(): Sucessfully loaded qpidmsg payload bridge from library [mamaqpidmsgimpl]
2013-07-29 10:24:27: openmama DEVRELEASE2.2.1.1 (not entitled)
2013-07-29 10:24:27: 0.0.1
2013-07-29 10:24:27:
********************************************************************************
Note: This build of the MAMA API is not enforcing entitlement checks.
Please see the Licensing file for details
**********************************************************************************
2013-07-29 10:24:27: Entering mamaTransport_create for transport (0x17c8a00) with name pub
2013-07-29 10:24:27: Creating transport: [pub]
2013-07-29 10:24:27: Number of load balanced sub transports defined: [0]
2013-07-29 10:24:27: Not using load balancing
2013-07-29 10:24:27: qpidBridgeMamaTransport_create(): Initializing Qpid Transport pub
2013-07-29 10:24:27: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.pub.incoming_url]: [amqp://~localhost:7777/SOURCENAME] (User Defined)
2013-07-29 10:24:27: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.pub.outgoing_url]: [amqp://localhost:6666/SOURCENAME] (User Defined)
2013-07-29 10:24:27: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.pub.reply_url]: [amqp://localhost:7777/SOURCENAME] (User Defined)
2013-07-29 10:24:27: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.msg_pool_size]: [32] (User Defined)
2013-07-29 10:24:27: qpidBridgeMamaTransportImpl_getParameter: parameter [mama.qpid.transport.msg_pool_inc_size]: [128] (Default)
2013-07-29 10:24:27: pub: Using default preinitial strategy: ON_GAP
2013-07-29 10:24:27: pub: Using default dq strategy: DQ_SCHEME_DELIVER_ALL
2013-07-29 10:24:27: pub: Using default ft strategy: DQ_FT_DO_NOT_WAIT_FOR_RECAP
2013-07-29 10:24:27: pub: Pre-Recap cache disabled
2013-07-29 10:24:27: setupBasic(): MAMA_INBOUND_TOPIC: subscription (0x18339c0)
Created inbound subscription.
2013-07-29 10:24:27: mamaPublisher_create(): Creating publisher for ..MAMA_TOPIC
2013-07-29 10:24:27: qpidBridge_start(): Entering
2013-07-29 10:24:27: qpidBridge_start(): retrieved bridge
2013-07-29 10:24:27: qpidBridge_start(): Preparing to leave
2013-07-29 10:24:27: qpidBridgeMamaTransportImpl_dispatchThread(): Waiting on message...

Publishing message 0 to MAMA_TOPIC.2013-07-29 10:24:27: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,0},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 1 to MAMA_TOPIC.2013-07-29 10:24:28: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,1},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 2 to MAMA_TOPIC.2013-07-29 10:24:28: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,2},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 3 to MAMA_TOPIC.2013-07-29 10:24:29: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,3},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 4 to MAMA_TOPIC.2013-07-29 10:24:29: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,4},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 5 to MAMA_TOPIC.2013-07-29 10:24:30: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,5},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 6 to MAMA_TOPIC.2013-07-29 10:24:30: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,6},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 7 to MAMA_TOPIC.2013-07-29 10:24:31: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
msg=({{MdMsgStatus,2,0},{MdSeqNum,10,7},{PublisherTopic,10002,MAMA_TOPIC}})
Publishing message 8 to MAMA_TOPIC.2013-07-29 10:24:31: qpidBridgeMamaPublisher_send(): No one subscribed to subject 'MAMA_TOPIC', not publishing
^C
[sahir@bohr bin]$

Thanks
Sahir

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