Re: AMQP client does not deque messages !!

2016-09-21 Thread jporras 
Hi , thanks for your answer. Find below log trace from the process .. 

Best regards, Javier 

javier@draco $ cat log.txt
[0x7911e0]:  -> AMQP
[0x7911e0]:  <- AMQP
[0x7911e0]:0 -> @open(16)
[container-id="62b1050c-8b62-412c-9c68-30574005db10", channel-max=32767,
properties={:"qpid.client_process"=:"hello_world", :"qpid.client_pid"=2319,
:"qpid.client_ppid"=1865}]
[0x7911e0]:0 <- @open(16) [container-id="localhost",
max-frame-size=4294967295, channel-max=32767, idle-time-out=15000,
offered-capabilities=@PN_SYMBOL[:"ANONYMOUS-RELAY"],
properties={:product="ActiveMQ", :"topic-prefix"="topic://",
:"queue-prefix"="queue://", :version="5.14.0", :platform="Java/1.8.0_101"}]
[0x7911e0]:0 -> @begin(17) [next-outgoing-id=0, incoming-window=2147483647,
outgoing-window=2147483647]
[0x7911e0]:0 <- @begin(17) [remote-channel=0, next-outgoing-id=1,
incoming-window=2147483647, outgoing-window=2147483647, handle-max=65535]
[0x7911e0]:0 -> @attach(18)
[name="REQ.SV1.TIMEOUT_1_f01b8af4-23b4-41e1-a999-23433b3464e6", handle=0,
role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0, dynamic=false],
target=@target(41) [address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0,
dynamic=false], initial-delivery-count=0]
[0x7911e0]:0 <- @attach(18)
[name="REQ.SV1.TIMEOUT_1_f01b8af4-23b4-41e1-a999-23433b3464e6", handle=0,
role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="REQ.SV1.TIMEOUT_1"], target=@target(41)
[address="REQ.SV1.TIMEOUT_1"], incomplete-unsettled=false,
initial-delivery-count=0]
[0x7911e0]:0 -> @attach(18)
[name="REQ.SV1.TIMEOUT_1_92297aa4-3062-432a-9570-2bd51d1546f8", handle=1,
role=false, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0, dynamic=false],
target=@target(41) [address="REQ.SV1.TIMEOUT_1", durable=0, timeout=0,
dynamic=false], initial-delivery-count=0]
[0x7911e0]:0 <- @attach(18)
[name="REQ.SV1.TIMEOUT_1_92297aa4-3062-432a-9570-2bd51d1546f8", handle=1,
role=true, snd-settle-mode=2, rcv-settle-mode=0, source=@source(40)
[address="REQ.SV1.TIMEOUT_1"], target=@target(41)
[address="REQ.SV1.TIMEOUT_1"]]
[0x7911e0]:0 <- @flow(19) [next-incoming-id=0, incoming-window=2147483647,
next-outgoing-id=1, outgoing-window=2147483647, handle=1, delivery-count=0,
link-credit=1000]
[0x7911e0]:0 -> @transfer(20) [handle=1, delivery-id=0,
delivery-tag=b"\x00\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=1,
delivery-tag=b"\x01\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=2,
delivery-tag=b"\x02\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=3,
delivery-tag=b"\x03\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=4,
delivery-tag=b"\x04\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=5,
delivery-tag=b"\x05\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=6,
delivery-tag=b"\x06\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=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)

AMQP client does not deque messages !!

2016-09-20 Thread jporras 
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.