[openamq-dev] OpenAMQ 1.2c3 released

[Nick Levine]

   OpenAMQ 1.2c3 is now available.

I can't open more than one session. The code below bombs out thus:

  16:59:56: I: about to open first session
  16:59:56: I: opened first session
  16:59:56: I: about to open second session
  foo: amq_client_agent.c:22258: action_send_channel_open: Assertion `((amq_client_agent_channel_open_t *) thread->method->data)->channel_nbr == 1' failed.

This is on Linux/Ubuntu. Happens whether I link the libraries static
or dymamic.

Any thoughts?

- nick


#include <asl.h>
#include <amq_client_connection.h>
#include <amq_client_session.h>

int main(int argc, char** argv)
{
  int i, res;
  amq_client_connection_t *connection = NULL;
  amq_client_session_t *session = NULL;
  amq_client_session_t *session2 = NULL;
  amq_content_basic_t *content = NULL;

  icl_longstr_t *auth_data;
  icl_system_initialise(argc, argv);
  auth_data = amq_client_connection_auth_plain("guest","guest");
  connection = amq_client_connection_new("localhost", "/", auth_data,"test", 0, 30000);
  icl_longstr_destroy(&auth_data);
  if(!connection)
    {
      icl_console_print("E: could not open connection");
      return(1);
    }

  icl_console_print("I: about to open first session");
  session = amq_client_session_new(connection);
  if(!session)
    {
      icl_console_print("E: could not open session");
      return(1);
    }
  icl_console_print("I: opened first session");

  icl_console_print("I: about to open second session");
  session2 = amq_client_session_new(connection);
  if(!session2)
    {
      icl_console_print("E: could not open session");
      return(1);
    }
  icl_console_print("I: opened second session");


  //Shut down connection and sessions
  amq_client_session_destroy(&session);
  amq_client_session_destroy(&session2);
  amq_client_connection_destroy(&connection);
  //Terminate iCL system
  icl_system_terminate();
  return 0;

}