Re: AMQP client does not deque messages !!
llo world!" > [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=7, > delivery-tag=b"\x07\x00\x00\x00", message-format=0, settled=false, > more=false] (32) > "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!" > [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=8, > delivery-tag=b"\x08\x00\x00\x00", message-format=0, settled=false, > more=false] (32) > "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!" > [0x7911e0]:0 -> @flow(19) [next-incoming-id=1, incoming-window=2147483647, > next-outgoing-id=9, outgoing-window=2147483647, handle=0, delivery-count=0, > link-credit=1, drain=false] > [0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=9, > delivery-tag=b"\x09\x00\x00\x00", message-format=0, settled=false, > more=false] (32) > "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!" > [0x7911e0]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=1, last=1, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=2, last=2, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=3, last=3, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=4, last=4, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=5, last=5, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=6, last=6, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=7, last=7, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @disposition(21) [role=true, first=8, last=8, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"0", > message-format=0] (32) > "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!" > [0x7911e0]:0 <- @disposition(21) [role=true, first=9, last=9, settled=true, > state=@accepted(36) []] > Hello world! > [0x7911e0]:0 -> @flow(19) [next-incoming-id=2, incoming-window=2147483647, > next-outgoing-id=10, outgoing-window=2147483647, handle=0, delivery-count=1, > link-credit=1, drain=false] > [0x7911e0]:0 -> @disposition(21) [role=true, first=0, last=0, settled=true, > state=@accepted(36) []] > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > [0x7911e0]:0 -> (EMPTY FRAME) > > > > > -- > View this message in context: > http://activemq.2283324.n4.nabble.com/AMQP-client-does-not-deque-messages-tp4716649p4716680.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: AMQP client does not deque messages !!
livery-id=9, delivery-tag=b"\x09\x00\x00\x00", message-format=0, settled=false, more=false] (32) "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!" [0x7911e0]:0 <- @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=1, last=1, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=2, last=2, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=3, last=3, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=4, last=4, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=5, last=5, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=6, last=6, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=7, last=7, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @disposition(21) [role=true, first=8, last=8, settled=true, state=@accepted(36) []] [0x7911e0]:0 <- @transfer(20) [handle=0, delivery-id=0, delivery-tag=b"0", message-format=0] (32) "\x00Sp\xc0\x04\x02BP\x00\x00St\xc1\x01\x00\x00Sw\xa1\x0cHello world!" [0x7911e0]:0 <- @disposition(21) [role=true, first=9, last=9, settled=true, state=@accepted(36) []] Hello world! [0x7911e0]:0 -> @flow(19) [next-incoming-id=2, incoming-window=2147483647, next-outgoing-id=10, outgoing-window=2147483647, handle=0, delivery-count=1, link-credit=1, drain=false] [0x7911e0]:0 -> @disposition(21) [role=true, first=0, last=0, settled=true, state=@accepted(36) []] [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) [0x7911e0]:0 -> (EMPTY FRAME) -- View this message in context: http://activemq.2283324.n4.nabble.com/AMQP-client-does-not-deque-messages-tp4716649p4716680.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: AMQP client does not deque messages !!
It would be helpful to see what the AMQP protocol level interactions
are, you can capture this by setting the environment variable
PN_TRACE_FRM before running the application: PN_TRACE_FRM=1
On 09/20/2016 05:18 AM, jporras wrote:
Hi All ..
I'm testing a small QPID C++ example with ActiveMq 5.14.0 (Java 8) , in a
Debian 8.x box, but unfortunelly it doesn't work . After the first message
has been dequed, the program blocks in the while loop. The same example
with QPID broker (6.0.4 java version) works fine ..
Any help will be appreciated ..
regards , Javier
#include
using namespace qpid::messaging;
int main(int argc, char** argv) {
std::string broker = argc > 1 ? argv[1] : "localhost:5672";
//std::string address = argc > 2 ? argv[2] : "amq.topic";
std::string address = argc > 2 ? argv[2] : "REQ.SV1.TIMEOUT_1";
std::string connectionOptions = argc > 3 ? argv[3] : "";
try {
Connection connection(broker, connectionOptions);
connection.open();
Session session = connection.createSession();
Receiver receiver = session.createReceiver(address);
Sender sender = session.createSender(address);
Message message;
for (int i=0; i<10;i++){
message.setContentObject("Hello world!");
message.getContentObject().setEncoding("utf8");
sender.send(message);
}
//message = receiver.fetch(Duration::SECOND * 1);
while (true){
message = receiver.fetch();
std::cout << message.getContent() << std::endl;
session.acknowledge();
}
connection.close();
return 0;
} catch(const std::exception& error) {
std::cerr << error.what() << std::endl;
return 1;
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQP-client-does-not-deque-messages-tp4716649.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
--
Tim Bish
twitter: @tabish121
blog: http://timbish.blogspot.com/
AMQP client does not deque messages !!
Hi All ..
I'm testing a small QPID C++ example with ActiveMq 5.14.0 (Java 8) , in a
Debian 8.x box, but unfortunelly it doesn't work . After the first message
has been dequed, the program blocks in the while loop. The same example
with QPID broker (6.0.4 java version) works fine ..
Any help will be appreciated ..
regards , Javier
#include
using namespace qpid::messaging;
int main(int argc, char** argv) {
std::string broker = argc > 1 ? argv[1] : "localhost:5672";
//std::string address = argc > 2 ? argv[2] : "amq.topic";
std::string address = argc > 2 ? argv[2] : "REQ.SV1.TIMEOUT_1";
std::string connectionOptions = argc > 3 ? argv[3] : "";
try {
Connection connection(broker, connectionOptions);
connection.open();
Session session = connection.createSession();
Receiver receiver = session.createReceiver(address);
Sender sender = session.createSender(address);
Message message;
for (int i=0; i<10;i++){
message.setContentObject("Hello world!");
message.getContentObject().setEncoding("utf8");
sender.send(message);
}
//message = receiver.fetch(Duration::SECOND * 1);
while (true){
message = receiver.fetch();
std::cout << message.getContent() << std::endl;
session.acknowledge();
}
connection.close();
return 0;
} catch(const std::exception& error) {
std::cerr << error.what() << std::endl;
return 1;
}
}
--
View this message in context:
http://activemq.2283324.n4.nabble.com/AMQP-client-does-not-deque-messages-tp4716649.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
