| 436 | } |
| 437 | |
| 438 | void Channel::ChannelImpl::AddToFrameQueue(const amqp_frame_t &frame) { |
| 439 | m_frame_queue.push_back(frame); |
| 440 | |
| 441 | if (CheckForQueuedMessageOnChannel(frame.channel)) { |
| 442 | boost::array<amqp_channel_t, 1> channel = {{frame.channel}}; |
| 443 | Envelope::ptr_t envelope; |
| 444 | if (!ConsumeMessageOnChannelInner(channel, envelope, -1)) { |
| 445 | throw std::logic_error( |
| 446 | "ConsumeMessageOnChannelInner returned false unexpectedly"); |
| 447 | } |
| 448 | |
| 449 | m_delivered_messages.push_back(envelope); |
| 450 | } |
| 451 | } |
| 452 | |
| 453 | bool Channel::ChannelImpl::GetNextFrameFromBroker( |
| 454 | amqp_frame_t &frame, boost::chrono::microseconds timeout) { |
nothing calls this directly
no outgoing calls
no test coverage detected