Attachment 890525 Details for Bug 1091558 – sender client

sender client

messaging_sender.cpp (text/x-c++src), 1.80 KB, created by mick on 2014-04-28 15:47:25 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: mick

Created: 2014-04-28 15:47:25 UTC

Size: 1.80 KB

patch

obsolete

>#include <stdio.h>
>#include <unistd.h>
>#include <sys/types.h>
>#include <stdlib.h>
>#include <time.h>
>#include <sys/time.h>
>#include <pthread.h>
>
>#include <iostream>
>
>#include <qpid/messaging/Connection.h>
>#include <qpid/messaging/Message.h>
>#include <qpid/messaging/Receiver.h>
>#include <qpid/messaging/Sender.h>
>#include <qpid/messaging/Session.h>
>
>
>
>using namespace qpid::messaging;
>
>
>void
>print_time ( )
>{
>  time_t rawtime;
>  struct tm * timeinfo;
>
>  time ( & rawtime );
>  timeinfo = localtime ( &rawtime );
>
>  int seconds_today = 3600 * timeinfo->tm_hour +
>                        60 * timeinfo->tm_min  +
>                             timeinfo->tm_sec;
>
>  fprintf ( stdout, "%d\n", seconds_today );
>}
>
>
>
>int 
>main ( ) 
>{
>  std::string router  = "192.168.10.80:20001";
>  // std::string sender_address = "x; {link:{reliability:unreliable}}";
>  std::string sender_address = "x";
>  std::string connectionOptions   = "{protocol:amqp1.0}";
>
>  Connection connection ( router, connectionOptions );
>  connection.open();
>
>  Session session = connection.createSession ( );
>  Sender sender = session.createSender ( sender_address );
>
>  sender.setCapacity ( 1000 );
>
>  char addr [ 1000 ];
>
>  Message msg;
>
>  int i;
>  try
>  {
>    for ( i = 0; i < 300; ++ i )
>    {
>      sprintf ( addr, "mick/%d", i );
>      msg.setProperty ( "x-amqp-to", addr );
>      sender.send ( msg );
>
>      // usleep ( 100000 );
>
>      fprintf ( stderr, "messenger_sender: sent |%s|\n", addr );
>    }
>  }
>  catch ( const std::exception & e ) 
>  {
>    std::cerr << "qpid-send: " << e.what() << "\n";
>  }
>
>  print_time ( );
>
>  fprintf ( stderr, "messenger_sender: closing session.\n" );
>  session.close ( );
>  fprintf ( stderr, "messenger_sender: closing cnx.\n" );
>  connection.close ( ); 
>
>  fprintf ( stderr, "messaging_sender done.  Sent %d messages.\n", i );
>
>  return 0;
>}
>
>
>
>
>

Actions: View

Attachments on bug 1091558: 890525 | 891195