0

首先感谢提供平台讨论问题。

我发现 qpid cpp 客户端程序有问题。

try{
cout << "Trying to open a connection" << endl;
connection.open("1.1.1.8", 10002);
session = connection.newSession();
SubscriptionManager subscriptions(session);
Listener listener(subscriptions);
subscriptions.subscribe(listener, receiver_queue);
//    subscriptions.run();
   subscriptions.start();
   sleep(10);
  }
 catch(const std::exception& error) {
  DEBUG(DBG_ERR, (char *)"AMQP-[%s]: Connection Error [%s].", __func__,error.what());
    connection.close();
   return RESULT_FAILURE;
 }

在 subscriptions.start 之后，如果我向客户端程序发送任何消息，我可以看到消息已收到，但它失败并出现以下异常。

terminate called after throwing an instance of 'qpid::Exception'
  what():  Invalid argument (../include/qpid/sys/posix/Mutex.h:116)
Aborted

堆栈说..

(gdb) bt
#0  0x0024b424 in __kernel_vsyscall ()
#1  0x00276af1 in raise () from /lib/libc.so.6
#2  0x002783ca in abort () from /lib/libc.so.6
#3  0x0026fdcb in __assert_fail_base () from /lib/libc.so.6
#4  0x0026fe86 in __assert_fail () from /lib/libc.so.6
#5  0x00b683b6 in unlock (this=0x88501fc, name="A.B.ToApplication")
at ../include/qpid/sys/posix/Mutex.h:120
#6  ~ScopedLock (this=0x88501fc, name="A.B.ToApplication") 
at        .    ./include/qpid/sys/Mutex.h:34
#7  qpid::client::Dispatcher::find (this=0x88501fc,  
  name="A.B.ToApplication")
 at qpid/client/Dispatcher.cpp:137
#8  0x00b68752 in qpid::client::Dispatcher::run (this=0x88501fc) at    
qpid/client/Dispatcher.cpp:83
#9  0x00d5b701 in qpid::sys::(anonymous namespace)::runRunnable (p=0x88501fc) at 
qpid/sys/posix/Thread.cpp:35
#10 0x00564a09 in start_thread () from /lib/libpthread.so.0
#11 0x0032915e in clone () from /lib/libc.so.6
(gdb)

我在这里错过了什么吗？

请帮我。

4

1 回答 1

2

不要使用 SubscriptionManager::start() - 它已损坏，因为它不允许处理异常 - 使用 SubscriptionManager::run() 代替，如果需要，会产生一个新线程来执行此操作。

我还强烈建议您改用 qpid::messaging API，而不是旧的现在已弃用的 qpid::client API。前者更简单，可以更轻松地过渡到 AMQP 1.0，这就是所有新开发的发生地。

于 2012-08-15T15:36:33.143 回答