-rmr_mbuf_t* rbuf = NULL;
-void* mrc = rmr_init( listen_port, MAX_BUF_SZ, RMRFL_NOFLAGS );
-
-while( TRUE ) {
- rbuf = rmr_rcv_msg( mrc, rbuf ); // reuse buffer on all but first loop
- if( rbuf == NULL || rbuf->state != RMR_OK ) {
- break;
- }
-
- fprintf( stdout, "mtype=%d sid=%d pay=%s\n",
- rbuf->mtype, rbuf->sub_id, rbuf->payload );
- sleep( delay_sec );
-}
-
-fprintf( stderr, "receive error\n" );
-rmr_close( mrc );
-