----- Original Message -----
From: Hoda, Sahir [mailto:shoda@...]
Sent: Monday, July 29, 2013 06:31 PM
To: openmama-users@... <openmama-users@...>
Subject: [Openmama-users] Help running openmama qpid examples

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

_______________________________________________
Openmama-users mailing list
Openmama-users@...
https://lists.openmama.org/mailman/listinfo/openmama-users

________________________________

Please consider the environment before printing this e-mail.

This e-mail may contain confidential and/or privileged information. If you are not the intended recipient or have received this e-mail in error, please advise the sender immediately by reply e-mail and delete this message and any attachments without retaining a copy.

Any unauthorised copying, disclosure or distribution of the material in this e-mail is strictly forbidden.
Please consider the environment before printing this email.

Visit our website at http://www.nyse.com

****************************************************

Note: The information contained in this message and any attachment to it is privileged, confidential and protected from disclosure. If the reader of this message is not the intended recipient, or an employee or agent responsible for delivering this message to the intended recipient, you are hereby notified that any dissemination, distribution or copying of this communication is strictly prohibited. If you have received this communication in error, please notify the sender immediately by replying to the message, and please delete it from your system. Thank you. NYSE Euronext.