Re: Unexpected error from qpidd-cpp 1.39 when queue is faulty

2019-05-31 Thread Pavel Moravec
Not being such an expert to linearstore as Kim, I have two ideas: 1) in case you have thousands of durable queues, you can hit kernel's limit on AIO operations and need to increase fs.aio-max-nr parameter. For calculation: I recall on some systems (rhel6?) one durable queue required 33 AIO

Re: Misleading messages when starting up Qpid c++ 1.36.0 ?

2017-05-20 Thread Pavel Moravec
​Hello, ​ On Sat, May 20, 2017 at 1:14 PM, kristianraue wrote: > Hi, > > I have successfully compiled qpid-cpp-1.36.0, qpid-proton-0.17.0 and > qpid-python-1.36.0 on CentOS 7.1 x86_64. > > I want to run Qpid with AMQP 1.0 and Linear Store enabled. And I should be >

Re: Modification of queue arguments after declaration

2015-10-09 Thread Pavel Moravec
Hello, I guess you need that for C++ broker. There is no way of reconfiguring a queue like that, you would have to delete the queue and re-create again with the extra parameters added. Kind regards, Pavel - Original Message - > From: "Jerome O'Neil" > To:

Re: 'Error reading socket: Success(0)'

2015-03-06 Thread Pavel Moravec
- Original Message - From: Gordon Sim g...@redhat.com To: Andrew Stitcher astitc...@redhat.com, users@qpid.apache.org Sent: Friday, 6 March, 2015 1:56:23 PM Subject: 'Error reading socket: Success(0)' Has anyone ever seen the error message 'Error reading socket: Success(0)' from

Re: Check Exchange present or not in Qpid C++ broker ?

2014-11-24 Thread Pavel Moravec
...@gmail.com To: users@qpid.apache.org Sent: Monday, 24 November, 2014 1:46:12 PM Subject: Re: Check Exchange present or not in Qpid C++ broker ? Thank you * Pavel Moravec *With your program i am getting the total details of the queue.But, i am not able to get Exchange details. I tried

Re: qpid-stat/qpid-config and SSL connections

2014-11-06 Thread Pavel Moravec
Hello, you have to use qpid-stat options: --ssl-certificate=cert Client SSL certificate (PEM Format) --ssl-key=key Client SSL private key (PEM Format) to specify client SSL certificate and key. Self-signed certificate should not be a problem, afaik. Kind

Re: Question regarding durable exchanges

2014-11-01 Thread Pavel Moravec
some clients wanting to use the exchanges might already be trying to connect). Kind regards, Pavel Moravec Thanks Raphael - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h

Re: Duplicate Messages

2014-09-30 Thread Pavel Moravec
Hi, you can get more duplicated messages, depending on your client's capacity/prefetch. The higher capacity is, the more messages the broker can send to the client without getting acknowledgement to prior messages. I.e. the bigger message throughput you get (until some threshold). On the other

Re: Add qmf shutdown command to the broker [was Re: QPID C++ - Dynamically Managing Broker]

2014-09-23 Thread Pavel Moravec
Kind regards, Pavel - Original Message - From: Alan Conway acon...@redhat.com To: users@qpid.apache.org Cc: Chuck Rolke cro...@redhat.com, Gordon Sim g...@redhat.com Sent: Monday, September 22, 2014 10:10:12 PM Subject: Add qmf shutdown command to the broker [was Re: QPID C++ -

Re: REQEST FEEDBACK Re: How to test the performance quid c++ broker

2014-07-26 Thread Pavel Moravec
- Original Message - I think that RelWithDebInfo is more generally useful - it gives you nearly all the optimisation you want and debugging symbols for when you screw up! Works for me. Did some quick benchmarks and the perf differences between Release and RelWithDebInfo are

Re: Why performance of sending durable messages to qpid queue is really bad?

2014-06-18 Thread Pavel Moravec
Durable messages will be everytime (much) slower to process than transient, as disk I/O operations are much slower than keeping the message just in memory. I would rather attempt to improve general I/O performance of the filesystem/disk you use for journals. I.e. older versions of ext4

[C++ broker] Worth removing FTD related stats?

2014-06-18 Thread Pavel Moravec
Hi all, getting some queue statistics, I realized there are legacy stats like: byteFtdDepth byteFtdDequeues byteFtdEnqueues msgFtdDepth msgFtdDequeues msgFtdEnqueues that refer to already removed flow-to-disk queue limit policy. As far as I checked, the code changing the stats is a dead code.

Re: [HA] debug Backup Rejected connection - problem with setting up qpid HA

2014-05-25 Thread Pavel Moravec
Hi Radek, did you promote either of brokers to be a primary? See qpid-ha promote command. Kind regards, Pavel - Original Message - From: Radek Smigielski radek.smigiel...@ymail.com To: users@qpid.apache.org Sent: Friday, May 23, 2014 6:14:45 PM Subject: [HA] debug Backup Rejected

Re: Closing connection with broker is not releasing Memory ?

2014-05-12 Thread Pavel Moravec
Hi, do you refer to a memory issue in (C++) broker or in Java client? And what version of broker+client do you use? If you refer to Java client memory issue, did you check Garbage collector logs? Could you add JVM options: -Xloggc:/path/to/gc.log -XX:+PrintGCDateStamps -XX:+PrintGCDetails

Re: Qpid client crashes in heartbeat operation

2014-05-03 Thread Pavel Moravec
That sounds like https://issues.apache.org/jira/browse/QPID-3553 but that is fixed in 0.13.. - Original Message - From: trivedi_ravi13 trivedi_rav...@yahoo.co.in To: users@qpid.apache.org Sent: Friday, May 2, 2014 11:42:51 PM Subject: Re: Qpid client crashes in heartbeat operation

Purging a big queue backed by linear store postpones journal files to be returned to EFP

2014-04-18 Thread Pavel Moravec
it would be (compared to adding some complexity to the code). My own attitude is disk space is cheap, don't implement it, but if somebody has some solid use case where such feature would be much appreciated, please respond. Kind regards, Pavel Moravec

session.sync() on AMQP 1.0 does not notify broker

2014-04-15 Thread Pavel Moravec
Hello, I have spotted a performance-impacting lack in AMQP 1.0 implementation of session.sync() in C++ client. On AMQP 0-10, the method sends execution.sync frame to the broker, asking for prompt delivery status to be sent. But 1.0 client does not invoke any such command. For performance

[Dispatch router] addressing examples help

2014-03-24 Thread Pavel Moravec
Hi all, I am trying to play with Dispatch Router but dont understand its addressing. In particular: 1) Having a router listening on port say 1, how to point qdstat to it? $ tools/qdstat -a -b amqp://0.0.0.0:1/ Failed: MessengerException - [-2]: unable to connect to amqp:/#:

Message auditing in C++ broker

2014-03-10 Thread Pavel Moravec
Hi all, I raised QPID-5619 to implement message auditing in C++ broker. As a new feature with more options of implementation and mainly configuration, I would like to discuss it first. Quoting the JIRA for discussion: There is a reasonable request to have message enqueue/dequeue audited. It

Re: Questions of qpid-route usage

2014-02-24 Thread Pavel Moravec
retries. These are managed by operating system. Once OS gives up, I *suppose* qpid broker invokes another request to the OS (so another full TCP retry scheme is followed), and the broker does so forever. Hope that helps. Kind regards, Pavel Moravec - Original Message - From: Jie Gao (Kyrie

auto-delete in AMQP 1.0

2014-02-13 Thread Pavel Moravec
Hi all, there is an ambiguity how to interpret auto-delete x-declare option for a 1.0 producer. Assuming the producer uses address string like: autodel_q;{create:sender, node: {x-declare: {auto-delete: True}}} There are two possibilities when the producer disconnects (while there has not been

Re: how to bind exchange to exchange using C++ broker?

2014-02-12 Thread Pavel Moravec
Hi, this is not possible. In any case, messages from producers get to an exchange. The exchange checks what bindings match to the message and then it enqueues the message to all queues of the bindings that matched. Every consumer gets a message from queues only. You might to set up alternate

AMQP 1.0 dissector to Wireshark now available

2014-01-03 Thread Pavel Moravec
more internal logic than 0-10 is. Great work done by the AMQP 1.0 committee! Kind regards, Pavel Moravec [1] https://bugs.wireshark.org/bugzilla/show_bug.cgi?id=9612 - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org

Re: AMQP 1.0 tcpdumps wanted

2013-12-27 Thread Pavel Moravec
I can put the files? Regards, Bruno Matos On 12/23/2013 02:42 PM, Pavel Moravec wrote: Hi all, I am implementing AMQP 1.0 dissector to Wireshark, as I feel it is needed for debugging qpid-clients communication. Before I commit the code to Wireshark upstream, I would like to test

AMQP 1.0 tcpdumps wanted

2013-12-23 Thread Pavel Moravec
Hi all, I am implementing AMQP 1.0 dissector to Wireshark, as I feel it is needed for debugging qpid-clients communication. Before I commit the code to Wireshark upstream, I would like to test the implementation on as much various PDUs as possible. Therefore I am kindly asking you (as the

Re: Deadlock when using amqp-1-0 client to connect to amqp-0-9-1 broker

2013-12-06 Thread Pavel Moravec
Hi Brian, let raise it in upstream JIRA: https://issues.apache.org/jira/browse/QPID Kind regards, Pavel Moravec - Original Message - From: Brian acb.kyl...@hotmail.com To: users@qpid.apache.org Sent: Friday, December 6, 2013 3:40:24 AM Subject: Re: Deadlock when using amqp-1-0

How to debug AMQP 1.0?

2013-11-22 Thread Pavel Moravec
Hi all, playing with AMQP 1.0 in C++ broker and client, I realized I can't debug the broker like I was used in 0.10 protocol version, as: 1) broker traces contain logs like: 2013-11-22 12:44:19 [Broker] trace qpid.127.0.0.1:5672-127.0.0.1:58187 process() 2013-11-22 12:44:19 [Network] trace

Re: connection.close() in C++ client never returns after resource-limit-exceeded exception

2013-11-10 Thread Pavel Moravec
Hi Jakub, I expect Gordon can comment this much better, but can't it be resolved by QPID-5288? Kind regards, Pavel - Original Message - From: Jakub Scholz ja...@scholz.cz To: users@qpid.apache.org Sent: Saturday, November 9, 2013 1:46:51 AM Subject: connection.close() in C++ client

Re: Flow Control for JMS Durable Subscribers

2013-10-21 Thread Pavel Moravec
What version of qpid Java client do you use? I tried 0.24 and it created the queue with proper options: $ ./run_example.sh org.apache.qpid.example.Drain -f -c 1 amq.fanout; {link:{durable:True, name:'my-subscription', x-declare:{auto-delete:True, arguments:{'qpid.auto_delete_timeout':10 $

Re: Flow Control for JMS Durable Subscribers

2013-10-18 Thread Pavel Moravec
Hi Andrew, I recommend reading https://cwiki.apache.org/confluence/display/qpid/Addressing+Examples where one example covers your requirement. When declaring the topic, use {link:{x-declare:{arguments:{'qpid.max_count':500,'qpid.policy_type':'ring' in its address string to create auxiliary

QMF method queueMoveMessages can loose one message

2013-09-04 Thread Pavel Moravec
to fix this without performance impact, I guess). Any comments? Kind regards, Pavel Moravec - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org

Re: Reappearing messages with qpidc and bdb persistency store

2013-08-30 Thread Pavel Moravec
Hi Aleš, I haven't met this, but here are some hints to troubleshoot/investigate it: 1) Before each broker shutdown, run (and keep output of) commands: qpid-stat -q qpid-stat -u (to see subscriptions - you will see unacknowledged messages there) store_chk directory_with_journal_of_the_queue

Re: C++ client question

2013-06-27 Thread Pavel Moravec
Hi Petr, just a guess: aren't you destroying instance of your class meantime? I.e. having declared in a block and trying to use its Session outside the block or so? Can you access the instance of your class and its connection at the place when calling Send() method for the second time? Btw.

Re: Receiver fetch vs get

2013-06-27 Thread Pavel Moravec
Hi Bruno, I think you hit https://issues.apache.org/jira/browse/QPID-4595 that is fixed in qpid 0.21. Kind regards, Pavel - Original Message - From: Bruno Matos bruno.ma...@paradigmaxis.pt To: users@qpid.apache.org Sent: Thursday, June 27, 2013 5:19:38 PM Subject: Receiver fetch vs

Re: qpid-config issue

2013-06-11 Thread Pavel Moravec
Hi Rajesh, that appears when python-qpid package is not installed (but I have no experience how to install it on Windows). As this package implements qpid.messaging library. Kind regards, Pavel - Original Message - From: Rajesh Khan rajeshkhan...@gmail.com To: users@qpid.apache.org

Re: SASL Error

2013-05-29 Thread Pavel Moravec
Hi Jagan, see inline responses. Kind regards, Pavel - Original Message - From: Sree82 sys8...@hotmail.com To: users@qpid.apache.org Sent: Wednesday, May 29, 2013 2:04:11 PM Subject: Re: SASL Error Gordon, I m using qpid client and qpid messaging apis to open a connection.

Re: Exception when calling close - Java client/C++ broker.

2013-05-14 Thread Pavel Moravec
, though I'll need to build the persistence module 'cause I never use it myself. Frase On 07/05/13 11:58, Pavel Moravec wrote: Hi Fraser, I tried to reproduce it but havent succeeded. Having following code snippet: Properties properties = new Properties

Re: Exception when calling close - Java client/C++ broker.

2013-05-07 Thread Pavel Moravec
Hi Fraser, I tried to reproduce it but havent succeeded. Having following code snippet: Properties properties = new Properties(); properties.setProperty(java.naming.factory.initial, org.apache.qpid.jndi.PropertiesFileInitialContextFactory);

Re: JBoss AS 7 w/ qpid RA and RabbitMQ: NullPointerException when receiving a message

2013-02-26 Thread Pavel Moravec
or higher AMQP protocol version (currently in qpid client, 0.10). Kind regards, Pavel Moravec - Original Message - From: James Gilbertson james.gilbert...@bitsinglass.com To: users@qpid.apache.org Sent: Friday, February 22, 2013 5:40:34 PM Subject: JBoss AS 7 w/ qpid RA and RabbitMQ

Re: limit-policy question

2013-02-05 Thread Pavel Moravec
Hi Connor, this is not possible either C++ broker version. Default limit policy reject is hardcoded. Note that since qpid 0.20 there are only two limit policies, reject and ring, until a replacement of flow-to-disk is implemented (https://issues.apache.org/jira/browse/QPID-4339). Kind

Re: Could somebody *please* explain Java Connection URLs...:-)

2013-01-30 Thread Pavel Moravec
using the -a option in QpidRestAPI so that the GUI will use that as the default - rather than having to add a new connection on the GUI) Frase On 25/01/13 10:41, Pavel Moravec wrote: Hi Fraser, there is a bug in Java client disallowing no credentials option, see https

Re: Could somebody *please* explain Java Connection URLs...:-)

2013-01-25 Thread Pavel Moravec
Hi Fraser, there is a bug in Java client disallowing no credentials option, see https://issues.apache.org/jira/browse/QPID-3396. Kind regards, Pavel - Original Message - From: Fraser Adams fraser.ad...@blueyonder.co.uk To: users@qpid.apache.org Sent: Friday, January 25, 2013

Re: Retrieving specific messages from Last Value Queue

2013-01-10 Thread Pavel Moravec
Hi Rajesh, you are in fact asking for message selectors that work well in Java client but dont exist in C++ client or in broker (https://issues.apache.org/jira/browse/QPID-530). I *think* only Java / JMS client currently supports so. The only way to workaround is to have separate queues for

Re: How to run the hello world example? Or we may need a minimal and throughout Getting Started steps.

2012-12-31 Thread Pavel Moravec
Hi Robin, what Cyrus SASL libraries do you have installed? I.e. what is output of rpm -qa | grep sasl command? Per the qpidd traces: 2012-12-28 09:24:03 [Protocol] trace SENT [127.0.0.1:5672-127.0.0.1:54004]: Frame[BEbe; channel=0; {ConnectionStartBody:

Re: Last Value Queue - Information Required

2012-12-31 Thread Pavel Moravec
Hi Khan, no, one queue is enough. See my favourite example below: # create a LVQ named MyLVQ with values stored in header field stock-symbol qpid-config add queue MyLVQ --argument qpid.last_value_queue_key=stock-symbol # generate some messages with stock prices $ qpid-send -a MyLVQ --property

Re: limit policy on bound temporary queues

2012-12-18 Thread Pavel Moravec
-8ff0-7bb6a8fe0044 (exchange name, '_' and random UUID) and will bind it to the exchange. You can also specify routing key (that has no sense for fanout exchange, though) to be used in the binding, when using address string like amq.direct/routingKey. Kind regards, Pavel Moravec - Original

Re: Problem using a configuration file

2012-12-04 Thread Pavel Moravec
Hi Adam, try to put to the file just lines in parameter=value syntax, i.e.: auth=no Syntax qpidd --auth=no is used for command line parameters (like you used for --config option). Kind regards, Pavel - Original Message - From: Adam Zedan zedan...@gmail.com To:

Re: All cluster members die simultaneously with store state dirty

2012-11-29 Thread Pavel Moravec
. That is unwanted behavior but not planned to be fixed, as current cluster solution is being replaced by new one in upstream (https://issues.apache.org/jira/browse/QPID-3603). Kind regards, Pavel Moravec - Original Message - From: 3.lis...@adminlinux.com.br lis...@adminlinux.com.br

Re: How would you receive this C++ List in C#

2012-10-23 Thread Pavel Moravec
object in the message map, // create a .NET object and add it to the dictionary. (and TypeTranslator::ManagedToNative for reverse conversion) Kind regards, Pavel Moravec - Original Message - From: Rajesh Khan rajeshkhan...@gmail.com To: users@qpid.apache.org Sent: Tuesday

Re: Sending objects to receivers

2012-10-17 Thread Pavel Moravec
+1, I have seen this working already in a qpid project. - Original Message - From: Andy Goldstein andy.goldst...@redhat.com To: users@qpid.apache.org Sent: Tuesday, October 16, 2012 6:48:15 PM Subject: Re: Sending objects to receivers You could use something like Google Protocol

Re: active-passive cluster

2012-10-16 Thread Pavel Moravec
for the cluster to work? Thanks, Terance. On Mon, Oct 15, 2012 at 9:14 PM, Pavel Moravec pmora...@redhat.com wrote: That seems to be ok.. Source code of cman seems to be not straightforward at that stage, maybe the cman preconfig does not fit with DNS.. Let try to write

Re: active-passive cluster

2012-10-15 Thread Pavel Moravec
find node name in cluster.conf cman_tool: corosync daemon didn't start - Thanks, Terance. On Fri, Oct 12, 2012 at 7:38 PM, Pavel Moravec pmora...@redhat.com wrote: Hi Terance, could you paste here your cluster.conf file? (I

Re: Cannot start qpidd

2012-10-09 Thread Pavel Moravec
/html/Messaging_Installation_and_Configuration_Guide/sect-Determining_Journal_Size.html to properly determine your journal size. Kind regards, Pavel Moravec - Original Message - From: 3.lis...@adminlinux.com.br lis...@adminlinux.com.br To: users@qpid.apache.org Sent: Monday, October 8

Re: Log rolling in Qpid C++ broker?

2012-09-23 Thread Pavel Moravec
Hi Parkirat, C++ broker does not offer this feature. There is a workaround in logging to syslog that redirects the logs to a separate file, and use logrotate for the file. Kind regards, Pavel Moravec - Original Message - From: ParkiratBagga parkiratba...@gmail.com To: users

Re: Dynamic topic/queue creation

2012-08-31 Thread Pavel Moravec
Hi Andrew, qpid uses address string syntax for that, see Programming in Apache QPID (http://qpid.apache.org/books/0.16/Programming-In-Apache-Qpid/pdf/Programming-In-Apache-Qpid.pdf), section 2.4. For example, to create a queue and automatically delete it when the session is closed, use address

Re: Setting up Kerberos security

2012-08-09 Thread Pavel Moravec
Hi Davide, add to /etc/sasl2/qpidd.conf: mech_list: GSSAPI to stick qpid broker in enforcing just that type of SASL mechanism. If you require to set it in the client, then it depends on what client/tool do you use. I.e. qpid-config --sasl-mechanism=GSSAPI .. C++ spout/drain: ./drain

Writing wrong filter in a QMF method causes the filter is ignored

2012-07-31 Thread Pavel Moravec
, Pavel Moravec - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org

Re: Writing wrong filter in a QMF method causes the filter is ignored

2012-07-31 Thread Pavel Moravec
) Kind regards, Pavel Moravec - To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org For additional commands, e-mail: users-h...@qpid.apache.org

Chain of dynamic routes does not work?

2012-05-14 Thread Pavel Moravec
Hello qpid users, I am trying to send a message over multiple dynamic routes but I fail so. Trivial setup: * 3 nodes train1, train2 and train3 * create dynamic routes train1 - train2 - train3: qpid-route dynamic add train1 train2 amq.direct qpid-route dynamic add train2 train3 amq.direct * On

Re: Chain of dynamic routes does not work?

2012-05-14 Thread Pavel Moravec
Oops, a typo in the commands: qpid-route dynamic add train3 train2 amq.direct qpid-route dynamic add train2 train1 amq.direct (I.e. creating routes train1 - train2 - train3 and sending a message to train1). - Original Message - From: Pavel Moravec pmora...@redhat.com To: users

Re: Creation of Request and Response quese

2012-04-19 Thread Pavel Moravec
Hi Sumi, it is enough to set reply-to in the message request and have a subscriber of that response queue. See attached C++ example program (its purpose is to send a QMF query to get some queue details and requesting to get the response to the given queue). So the key commands are: //create a

Re: Reduce Sender traffic

2012-04-18 Thread Pavel Moravec
Hi Bruno, what broker (C++ / Java) and client (C++ / Java / Python / ..) are you using? Generally, I would recommend creating more AMQP sessions where messages to potentially blocked queues are sent on one session, time to time synchronize those sessions and use producer flow control that would

Re: 0.14 cluster never survives more than an hour or so.

2012-04-13 Thread Pavel Moravec
it to e.g. 2 hours, your qpid cluster will run for at least 2 hours without the error. But again, some QMF based services rely on the updates. Kind regards, Pavel Moravec - Original Message - From: Paul Colby p...@colby.id.au To: users@qpid.apache.org Sent: Friday, April 13, 2012

Re: Does the qpid-cluster command support SSL?

2012-04-12 Thread Pavel Moravec
Hi Paul, I think the answer is no, as all qpid-* tools are Python-based and SSL support in Python client is not resolved fully - see https://issues.apache.org/jira/browse/QPID-3175 for details. Kind regards, Pavel Moravec - Original Message - From: Paul Colby p...@colby.id.au

Re: 0.14 cluster never survives more than an hour or so.

2012-04-12 Thread Pavel Moravec
by broker shutdown.) Kind regards, Pavel Moravec - Original Message - From: Paul Colby p...@colby.id.au To: users@qpid.apache.org Sent: Thursday, April 12, 2012 5:08:01 AM Subject: 0.14 cluster never survives more than an hour or so. Hi guys, I'm having an issue with my new 0.14

Selective message acknowledgment in Java client (and C++ broker)?

2012-04-12 Thread Pavel Moravec
Hello, having Java client and C++ broker, I want to implement selective consumption of messages from a queue (something like JMS message selectors in Java broker). I.e.: 1) Having CLIENT_ACKNOWLEDGE mode, 2) In a loop through all messages of the queue: a) receive a message b) decide if to

Re: Default queues on qpid c++ broker

2012-04-03 Thread Pavel Moravec
-stat finishes. Let re-run the command and you will see a new bunch of queues (with different PID reffering to PID of the process running qpid-stat). Kind regards, Pavel Moravec - Original Message - From: sandeep sndee...@gmail.com To: users@qpid.apache.org Sent: Tuesday, April 3, 2012

Re: python QMF synchronization

2012-03-21 Thread Pavel Moravec
Hi Martin, you can set up ReplyTo address where qpid shall send its response. I.e. something like C++ code below (that invokes queue deletion and fetches response in 30seconds limit): Connection connection(url); try { connection.open(); Session session =

Re: python QMF synchronization

2012-03-21 Thread Pavel Moravec
: %s % m) except Empty: print No response received! except Exception, e: print e except ReceiverError, e: print e except KeyboardInterrupt: pass conn.close() - Original Message - From: Pavel Moravec pmora...@redhat.com To: users@qpid.apache.org Sent: Wednesday, March

Re: How to receive specific response

2012-03-12 Thread Pavel Moravec
Hi Todd, if you wish to non-destructively read messages in a queue, you can use browse mode, i.e. address string would be something like: queue-name; {mode:browse} If your question is extended by .. and how to consume the message I am interested in (and no other), then I don't know if it is

Re: How to know all the available topics

2012-03-07 Thread Pavel Moravec
Hi Davide, does the command: qpid-config exchanges amq.topic -b fulfill your needs? To have it implemented in a client, it is possible to invoke a QMF command to list all bindings. Something like the C++ program below (not sure how to write the query to filter bindings from just some

Re: Creating Comon single Queue

2012-03-01 Thread Pavel Moravec
Hi Sinduja, does replication event queue fulfills your requirements? See https://cwiki.apache.org/qpid/queue-state-replication.html for details. Kind regards, Pavel - Original Message - From: sinduja ramaraj sinduja.rama...@gmail.com To: users@qpid.apache.org Sent: Thursday, March

Re: maxprefecth / capacity concerns

2012-02-15 Thread Pavel Moravec
...@redhat.com To: users@qpid.apache.org Sent: Friday, February 10, 2012 8:47:33 PM Subject: Re: maxprefecth / capacity concerns On 02/03/2012 11:51 AM, Pavel Moravec wrote: Hello qpid users, I am somehow confused about difference between capacity and maxprefetch. Both define maximum number

Re: maxprefecth / capacity concerns

2012-02-07 Thread Pavel Moravec
that the train of thought is useful and perhaps someone who knows the code a bit better can confirm what I'm seeing. As an aside, the code base could do with a few more comments :-) Let us know how you get on Frase. On 03/02/12 11:51, Pavel Moravec wrote: Hello qpid users, I am

maxprefecth / capacity concerns

2012-02-03 Thread Pavel Moravec
Hello qpid users, I am somehow confused about difference between capacity and maxprefetch. Both define maximum number of messages that can be sent without receiving a response to the first msg, but maxprefetch is applicable to consumer part of the communication only. My questions: 1)

Re: QUERY ON LOG FILES

2012-02-03 Thread Pavel Moravec
Subject: RE: QUERY ON LOG FILES Hi, Can anyone tell me how to get the information about the list of queues available with a particular broker? Regards, Sinduja.R -Original Message- From: Pavel Moravec [mailto:pmora...@redhat.com] Sent: Thursday, February 02, 2012 6:09 PM

Re: QUERY ON LOG FILES

2012-02-03 Thread Pavel Moravec
complete, don't forget to create appropriate bindings to let exchanges route messages into relevant queues. Kind regards, Pavel Moravec - Original Message - From: Senthil Kumar, Sinduja (GE Healthcare) sinduja.senthilku...@ge.com To: users@qpid.apache.org Cc: pmora...@redhat.com Sent

Re: QUERY ON LOG FILES

2012-02-02 Thread Pavel Moravec
Hi Sinduja, see my response inline. Kind regards, Pavel - Original Message - From: Senthil Kumar, Sinduja (GE Healthcare) sinduja.senthilku...@ge.com To: users@qpid.apache.org Sent: Thursday, February 2, 2012 10:56:53 AM Subject: QUERY ON LOG FILES Hi, Can someone explain

QMF creating huge durable queue causes cluster desync

2012-01-30 Thread Pavel Moravec
Hi all, it seems to me that sending QMF methods to create a queue over-passes cluster error checking mechanism (if a sole node detects an error, it preventive leaves the cluster). Having a simple C++ client to create a huge durable queue: Connection connection(amqp:tcp:127.0.0.1:5672);

QMF raising event when defaut binding is created?

2012-01-03 Thread Pavel Moravec
Hi all, I realized that currently QMF does not raise an event when a default binding is created (by default binding I mean a binding of type {exchange:'', queue:queuename, key:queuename} that is created automatically when a queue is created). To check that behavior, let subscribe to

Re: Weird behavior of flow_to_disk policy

2011-12-15 Thread Pavel Moravec
Hi Gordon, - Original Message - From: Gordon Sim g...@redhat.com To: users@qpid.apache.org Sent: Thursday, December 15, 2011 3:33:22 PM Subject: Re: Weird behavior of flow_to_disk policy On 12/13/2011 03:33 PM, Pavel Moravec wrote: Hi all, I noticed a weird behavior of flow

Re: Trying to get persistence plugin for qpid 0.10 on REHL

2011-12-14 Thread Pavel Moravec
Hi Daryoush, RPM for persistence is named qpid-cpp-server-store, it should be of the same version as qpid-cpp-server package is. How have you installed qpid? As in both usual ways (compiling from source and installing via yum), store RPM shall be already present. Kind regards, Pavel -

Weird behavior of flow_to_disk policy

2011-12-13 Thread Pavel Moravec
Hi all, I noticed a weird behavior of flow-to-disk policy. When the relevant queue is utilized over its max-queue-count and when I am sending and receiving messages there, my sender gets Enqueue capacity threshold. One particular scenario: qpid-config add queue ToFillQueue --durable

Re: A JMS Connection failing with asynchronous exception doesn't seem to close cleanly.

2011-12-12 Thread Pavel Moravec
Hi Frase, the bug is already tracked under https://issues.apache.org/jira/browse/QPID-3575. In fact, there are two somehow joined issues: 1) the session and connection leak problem itself, where a session becomes into detached state but cant be used further any way. 2) any exception raised on

Re: Qpid clustering with cman

2011-12-08 Thread Pavel Moravec
) simply ignores the file at all, not providing an option to set it up within the conf file. Workaround: run qpidd under root (as root user has access to corosync CPG). Kind regards, Pavel Moravec - Original Message - From: David Zhou dayda...@gmail.com To: users@qpid.apache.org Sent

Re: how to delete queue from jms client

2011-12-06 Thread Pavel Moravec
Hi Gastón, you can use QMF method delete with parameters type (queue in our case) and name (name of the queue). Here is the code snippet from C++ program I use: Connection connection(url/*, connectionOptions*/); try { connection.open(); Session session =

Re: How to clear the Journal so I can restart C++ Broker?

2011-12-02 Thread Pavel Moravec
Hi, There is a tool for (even offline) journal resizing, see e.g. http://docs.redhat.com/docs/en-US/Red_Hat_Enterprise_MRG/2/html/Messaging_User_Guide/sect-Messaging_User_Guide-Determining_Journal_Size-Resizing_the_Journal.html (I hope also some qpid documentation covers that):

Re: How do I get Qpid's log messages?

2011-10-07 Thread Pavel Moravec
Hi Daryoush, you need to use option log-to-file: log-to-file=/tmp/qpidd.log See qpidd --help | grep log or man qpidd for more logging options. Esp. for log-enable that can define (different) verbosity of logs for different areas. Please note that by default logs are sent to syslog, so they are

Re: Is it possible to set authentication to only authenticate consumers?

2011-10-07 Thread Pavel Moravec
Hi Frase, qpidd chooses from the available mechanisms the most secure (from available) every time, when possible. I think SASL library itself does not have a priority list itself, the decision is made by qpidd only. Kind regards, Pavel - Original Message - From: Fraser Adams

ring queue needs max-queue-size specified?

2011-10-05 Thread Pavel Moravec
Hello, I noticed that declaring ring queue with just max-queue-count parameter prevents me sending messages with nonempty content: # qpid-config add queue Test2 --max-queue-count=100 --limit-policy=ring # ./spout -c 100 --content a Test2 2011-10-05 10:53:18 warning Exception received from

Re: ring queue needs max-queue-size specified?

2011-10-05 Thread Pavel Moravec
12:33:01 PM Subject: Re: ring queue needs max-queue-size specified? On 10/05/2011 10:08 AM, Pavel Moravec wrote: Hello, I noticed that declaring ring queue with just max-queue-count parameter prevents me sending messages with nonempty content: # qpid-config add queue Test2 --max-queue

Re: Priority queues with JMS Client/ Java Broker

2011-10-05 Thread Pavel Moravec
From: Alan Conway acon...@redhat.com To: users@qpid.apache.org Cc: Pavel Moravec pmora...@redhat.com Sent: Wednesday, October 5, 2011 3:35:14 PM Subject: Re: Priority queues with JMS Client/ Java Broker On 09/27/2011 03:37 AM, Pavel Moravec wrote: Hi Praveen and all, just an additional

Re: Logging

2011-09-13 Thread Pavel Moravec
, Pavel Moravec GSS SEG Red Hat - Original Message - From: Bradley Scalio brad.sca...@noaa.gov To: users@qpid.apache.org Sent: Tuesday, September 13, 2011 2:28:14 PM Subject: Logging Greetings, Trying to turn off logging to /var/log/messages and send qpidd logging to /var/log/qpidd.log

List of areas to log/debug/trace

2011-09-12 Thread Pavel Moravec
Hello, is there a list of areas we can modify logging level in cpp broker? I mean, when using --log-enable debug:framing option, list of verbosity levels is printed in qpidd help. But I can't find anywhere the list of areas to debug. (I suppose the list is list of directories in qpid source,

Unification of qpid tools authentication options

2011-08-19 Thread Pavel Moravec
Hello all, it has been noticed that qpid tools like qpid-config, qpid-cluster etc. use different options for setting authentication stuff (username, password, sasl mechanism). Moreover some tools don't have some options available. Plus few tools behave wrongly in some particular cases. I would

Re: How to set subject in Java spout?

2011-08-04 Thread Pavel Moravec
If you type -h or --help, it will tell you how to specify these properties. regards, Rajith On Wed, Aug 3, 2011 at 9:34 AM, Alan Conway acon...@redhat.com wrote: On 08/03/2011 06:47 AM, Pavel Moravec wrote: Hi all, comparing C++ and Java spout programs, I realized I am unable to set subject

Re: Configuration of CRAM-MD5 SASL method?

2011-08-04 Thread Pavel Moravec
? On 08/04/2011 09:47 AM, Pavel Moravec wrote: Hi all, does somebody know how to configure CRAM-MD5 SASL authentication method? I tried the following: # cat /etc/sasl2/qpidd.conf pwcheck_method: auxprop auxprop_plugin: sasldb sasldb_path: /var/lib/qpidd/qpidd.sasldb #following line stops

How to set subject in Java spout?

2011-08-03 Thread Pavel Moravec
Hi all, comparing C++ and Java spout programs, I realized I am unable to set subject of a message using Java Spout program. C++ has syntax: ./spout -b localhost:5672 -c 1 -P '{subject:Some_subject}' testQueue but trying the same in Java client does not work: # cd

Re: Too many open files

2011-08-02 Thread Pavel Moravec
, Sergey Zhemzhitsky Information Technology Division Troika Dialog, 4, Romanov lane, Moscow 125009, Russia Phone. +7 495 2580500 ext. 1246 -Original Message- From: Pavel Moravec [mailto:pmora...@redhat.com] Sent: Monday, August 01, 2011 3:42 PM To: users@qpid.apache.org Subject: Re: Too

qpid-config slow

2011-07-20 Thread Pavel Moravec
Hi all, I realised on every qpid version system I used a poor performance of qpid-config tool. It usually takes 2 to 3 seconds to execute a command, e.g.: # time qpid-config add queue test real 0m2.243s user 0m0.161s sys 0m0.027s # time qpid-config del queue test real 0m2.303s user

  1   2   >