Hallo,
Is qpid c++ broker still alive? I see that last release reported on apache
page is 1.39.0 from 2018 and last redhat rpm package I can find is for
centos7/redhat7 only. When I try to build it on rocky9 it fails because
of missing python2 packages.
Best regards,
--
Michael Ivanov
text,
which was successfully delivered to receiver. He used this package to send
the message:
https://mvnrepository.com/artifact/org.apache.qpid/qpid-jms-client/2.0.0
Now what do I miss in my qpidd configuration?
qpidd version used is 1.39.0
Best regards,
--
Michael Ivanov
20 13:22, Gordon Sim wrote:
> On 14/05/2020 10:29 am, Michael Ivanov wrote:
>> Hallo,
>>
>> I observe strange thing when using temporary queues in client.py script.
>> I assign delete-on-close policy to temporary queue as follows:
>>
>> options=Dyna
Hallo,
I observe strange thing when using temporary queues in client.py script.
I assign delete-on-close policy to temporary queue as follows:
options=DynamicNodeProperties({"lifetime-policy" :
['amqp:delete-on-close:list', []], "exclusive" : True })
But when I check the trace I see that del
wrote:
> On 08/05/2020 3:57 pm, Michael Ivanov wrote:
>> I am using pn_messenger_t interface in my private select-based event loop.
>> I use pn_selectable_t to trigger actual i/o.
>>
>> As far as I have seen in proton/c source pn_transport_tick is invoked only
>> fro
?
Best regards,
On 08.05.2020 17:28, Gordon Sim wrote:
> On 08/05/2020 3:04 pm, Michael Ivanov wrote:
>> I attached proton trace with FRM added. Short messages as below are my
>> manual heartbeat messages, sent each 5 minutes:
>>
>> [0xbdb950]:0 -> @transfer(20) [handle=
timeout: runnings
With corresponding message in proton trace file:
CONNECTION ERROR connection aborted (remote)
I cannot identify anything like heartbeat inn trace file. Do I miss sthing?
Best regards,
On 08.05.2020 15:57, Gordon Sim wrote:
> On 08/05/2020 1:40 pm, Michael Ivanov wrote:
>
T be
useful?
What kind of frames are expected to be observed in tcpdump trace fpor
heartbeats?
Currently I see only messages that are explicitly sent.
Best regards,
On 08.05.2020 14:04, Gordon Sim wrote:
> On 08/05/2020 11:45 am, Michael Ivanov wrote:
>> No, this should not be the c
No, this should not be the case. I am sending messages from select-based event
loop
using pn_selectable_t objects.
On 08.05.2020 13:41, Gordon Sim wrote:
> On 08/05/2020 10:44 am, Michael Ivanov wrote:
>> When sending messages to rabbitmq broker, tha latter periodically closes the
>
03.03.2020 13:42, Robbie Gemmell wrote:
> On Tue, 3 Mar 2020 at 10:11, Gordon Sim wrote:
>>
>> On 03/03/2020 9:56 am, Michael Ivanov wrote:
>>> Hallo,
>>>
>>> Can proton library communicate with rabbitmq broker? I tried to use my
>>> existing
>
Hallo,
Can proton library communicate with rabbitmq broker? I tried to use my existing
program to rabbitmq but would not even complete the subscription. Are there any
specifics about it?
Best regards,
--
\ / | |
(OvO) | Mikhail Iwanow |
(
Hallo,
I hope this is the right place to ask about qpid jms.
I use qpid jms client 0.41.0 with qpidd broker 1.38.
I'm creating created a fanout exchange (qpid-config add exchange fan ABC)
and subscribe to it from java client using Topic and a MessageConsumer.
On server side a queue is created for
Greetings,
Does qpid/proton support tls 1.2 when using encryption?
How can I verify that tls 1.2 is actually used?
Best regards,
--
\ / | |
(OvO) | Mikhail Iwanow |
(^^^) | Voice: +7 (911) 223-1300 |
\^/ | E-mail: iv...@
YES!!!
Now temporary queues are deletes as expected!
Huge thanks for help!
Do you think the fix should be included in proton mainline?
Just in case the patch is attached.
Best regards,
On 01.08.2018 14:03, Gordon Sim wrote:
> On 01/08/18 11:44, Michael Ivanov wrote:
>> Currently I
=0,
timeout=0, dynamic=false], initial-delivery-count=0,
max-message-size=0]
delete-on-close is replaced by delete-on-no-links in response for some reason.
I'm using qpidd 1.38
Best regards,
On 01.08.2018 13:21, Gordon Sim wrote:
> On 31/07/18 21:21, Michael Ivanov wrote:
>> Then I
0 1
Setting lifetime-property to delete-on-close in same way also does not make
any difference.
Any hope to get temporary queue deleted without terminating server (responder)
process?
Best regards,
On 04.07.2018 11:26, Gordon Sim wrote:
> On 03/07/18 21:15, Michael Ivanov wrote:
&g
}
}
Queue is created and auto-delete property is set, but as I understand to make
auto deletion actually work 'exclusive' property has to be added. Is it
possible using this kind of message? I tried to add 'exclusive': True to
message but it did not work.
Best regards,
Hallo,
I am implementing message broadcasting using fanout exchange. Several processes
are subscribed to exchange and each of them can send messages to this exchange.
Is it possible to prevent the sender to receive it's own message?
Best regards,
--
Michael I
t; you request, nor (I think) does it allow you to
> close senders (which may in itself be a problem) or use an anonymous sender.
Does proton have alternate interface which would allow to specify type of
temporary queue or lifetime policy?
Best regards,
--
Michael Ivanov
---
No problem, just tell me how to access proper page in jira.
07.03.2018 19:17, Gordon Sim пишет:
> On 07/03/18 14:35, Michael Ivanov wrote:
>> Greetings,
>>
>> qpidd 1.37 seems to have a bug in rdma_wrap.cpp, function deviceCount().
>> Origin
ount() {
struct ibv_device **list;
int count;
if ((list = ::ibv_get_device_list(&count)))
::ibv_free_device_list(list);
return count;
}
and it runs now.
Best regards,
--
Michael Ivanov
-
To uns
e reason why it is not deleted.
Is there a way to request messenger to unbind the queue as soon as the message
is sent?
I am using pn_messenger_* interface of proton library.
Best regards,
--
Michael Ivanov
-
To unsubscribe
Hallo,
Is it possible to set up a limit for max number of simultaneous subscriptions
to specific queue in qpiid?
Best regards,
--
Michel Ivanov
-
To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands
limiter is ':'?
Best regards,
18.01.2018 20:34, Gordon Sim пишет:
> On 18/01/18 15:23, Michael Ivanov wrote:
>> Great, it (almost) works! Many thanks!
>>
>> There's still one problem remains. When I turn auth off, then user is
>> considered to be anonymous, e
eue that
> is the fourth allowed queue. Then the attempt to create the fourth queue (q4)
> is denied since that user already has four queues. The log files should help
> expose the workings that arrive at this result.
>
>
> - Original Message -
>> From: "M
c.
I expected queue creation to fail at 5th queue, but it was created.
Do I need to use acls to enforce this limit?
Best regards,
--
Michael Ivanov
-
To unsubscribe, e-mail: users-unsubscr...@qpid.apache.org
For additional commands, e
All clients are running in a single tomcat instance which runs on
the same VM as broker (yes the system runs in VM).
Most of the clients (probably even all I'm not 100% sure) use JMS.
29.11.2017 20:32, Gordon Sim пишет:
> On 29/11/17 12:39, Michael Ivanov wrote:
>> Thanks for re
(though not that frequent)
when tomcat is restarted and system runs normal.
Best regards,
29.11.2017 12:43, Gordon Sim пишет:
> On 29/11/17 06:57, Michael Ivanov wrote:
>> Greetings,
>>
>> I observe following messages from qpidd in /var/log/messages:
>>
>> qp
Greetings,
I observe following messages from qpidd in /var/log/messages:
qpidd: 2017-11-29 13:11:47 [Network] error
qpid.10.1.1.11:5672-10.1.1.1:65355 connection failed: transport error:
amqp:resource-limit-exceeded, local-idle-timeout expired
I assume these messages are generated when open
Greetings,
Can somebiody point me to proper qpidd exchange configuration?
I want to use some kind of broadcast messages delivered to several subscribers
simultaneously. For this I create an fanout exchange with specific name and
make all subscribers to subscribe to this exchange name, same way as
will appear in non-java ccommunication I'll still
apply the patch and use customized 0.34 version.
Many thanks,
06.11.2015 23:48, Gordon Sim пишет:
> On 11/05/2015 10:28 AM, Michael Ivanov wrote:
>> Is there a chance to get it working for 0.34 in foreseeable future? :-)
>
> I
I just tried qpid-client-0.32-bin.tar.gz (we were using 0.30). Still the same.
Is this version to be considered new or should I search for sthing else?
Best regards,
05.11.2015 15:37, Gordon Sim пишет:
> On 11/05/2015 12:06 PM, Robbie Gemmell wrote:
>> On 5 November 2015 at 11:45, Gordon Sim wro
ility the policy is set properly.
05.11.2015 13:27, Gordon Sim пишет:
> On 11/05/2015 10:14 AM, Michael Ivanov wrote:
>> Ok it worked! Probably last time when running recv I mistyped the queue name.
>> But weherever I run recv with such name queue is created and when the recv
>
Is there a chance to get it working for 0.34 in foreseeable future? :-)
05.11.2015 13:27, Gordon Sim пишет:
> On 11/05/2015 10:14 AM, Michael Ivanov wrote:
>> Ok it worked! Probably last time when running recv I mistyped the queue name.
>> But weherever I run recv with such name q
. All other messages are lost.
But anyway, now I need to figure out why this does not happen with java.
Best regards,
05.11.2015 12:54, Gordon Sim пишет:
> On 11/05/2015 09:38 AM, Michael Ivanov wrote:
>> Do you mean recv example utility from proton?
>
> Yes
>
>> I tried i
пишет:
> On 11/04/2015 09:37 PM, Michael Ivanov wrote:
>> Currently it shows:
>>
>> qpid-config list QueuePolicy
>> Objects of type 'QueuePolicy'
>>nameproperties
>>=
der* {u'qpid.lifetime-policy': u'delete-on-close'}
test2_tempSender.* {u'qpid.lifetime-policy': u'delete-on-close'}
05.11.2015 00:34, Gordon Sim пишет:
> On 11/04/2015 09:24 PM, Michael Ivanov wrote:
>> Strange.
>>
>> I just ran qpid-c
rg.apache.qpid.amqp_1_0.jms is used to create the queue)?
Best regards,
05.11.2015 00:12, Gordon Sim пишет:
> On 11/04/2015 08:32 PM, Michael Ivanov wrote:
>> So when I type "qpid-config add QueuePolicy test2_tempSender . . . ." then
>> test2_tempSender is actually inte
0 1
test2_tempSender94cfab8c-4478-4e1c-b958-6d128f60f12fY
0 1 10 1
Is there any way to check the policy settings for the queue?
Best regards,
04.11.2015 22:51, Gordon Sim пишет:
> On 11/04/2015 07:31 PM, Michael Ivanov wrote:
>> Thanks for the fix s
Hallo,
I have a question about direct message receive in proton.
I tried to receive messages directly using amqp://~1.2.3.4 url.
It works but it seems that queue names in this case are ignored.
I.e. when I subscribe to amqp://~1.2.3.4/q1 I also get the messages
for amqp://~1.2.3.4/q2, q3 etc.
Is
test2_tempSender*
and for test2_tempSender.* In all cases the queues werre not deleted.
Am I doing sthing wrong or this is not possible with queue policy in 0.34?
Best regards,
04.11.2015 13:13, Gordon Sim пишет:
> On 11/03/2015 09:40 PM, Michael Ivanov wrote:
>> Sorry, I just went through qpid-confi
03.11.2015 23:51, Gordon Sim пишет:
> On 11/03/2015 08:25 PM, Michael Ivanov wrote:
>> I use c++ qpid broker 0.34 and proton library v 0.10. I am using 2 processes:
>> receiver process (R) which reads the messages and sends replies when
>> requested
>> and sende
. Process S does nor run permanently, but process R does.
The reply queues dissappear only when process R terminates. When process S runs
its reply queue has connections value set to 1, when it terminates connections
become 0.
03.11.2015 21:19, Gordon Sim пишет:
> On 11/03/2015 05:57 PM, Michael Iva
Hallo,
Please help me to resolve the following situation:
I create a temporary queue using "/#" suffix to amqp url. The queue is created
with name like 36275A5C-8630-457B-BD75-3664354ECC2D_#
I set this queue as reply_to address in messages being sent. I receive the reply
message and run pn_messe
Greetings,
Is there some kind of gui to review qpidd queues and / or monitoring qpidd
operation?
best regards,
--
\ / | |
(OvO) | Mikhail Iwanow |
(^^^) | |
\^/ | E-mail: iv...@logit-ag.de |
Please can you check "Possible typo in messenger.c" message?
Is this a real typo?
(this is present in earlier versions also, not just in 0.11)
Also I observe library looping in the following code:
#0 pn_selector_select (selector=0x22bff80, timeout=60) at
qpid-proton-0.11.0-alpha/proton-c/sr
Hallo,
Is this an error:
if (messenger->flags | PN_FLAGS_CHECK_ROUTES) {
. . . .
}
(line 1498 in messenger.c)?
Shouldn't it be:
if (messenger->flags & PN_FLAGS_CHECK_ROUTES) {
Or do I miss sthing?
Best regards,
--
\ / | |
(OvO) | Mikhail Iwa
,
22.10.2015 21:36, aconway пишет:
> On Thu, 2015-10-22 at 18:20 +0300, Michael Ivanov wrote:
>> Hallo,
>>
>> What kind of communication error recovery is available in proton
>> library (if at all)?
>> I am using proton messenger in passive mode and I not
Hallo,
What kind of communication error recovery is available in proton library (if at
all)?
I am using proton messenger in passive mode and I noticed very unpleasant
behaviour:
wherever the connection to qpidd is broken (eg. when qpidd is restarted), the
client
progan does not seem to get any
Hallo,
I have investigated the crash a bit further. I have added decref/incref
trace printout and I got the following at the moment of crash:
COLLECTOR 0xba9050 FREE
COLLECTOR 0xba9050 RELEASE
COLLECTOR 0xba9050 DRAIN
COLLECTOR 0xba9050 POP: event 0xbcdd10/pn_link
PN_OBJ_DECREF: object 0xbcdd10 c
It's still the same in proton 0.10 The line numbers are a bit different,
but the error seems to be the same:
==6040== Invalid read of size 8
==6040==at 0x53679F5: pn_object_reify (object.c:216)
==6040==by 0x5367BA6: pn_class_decref (object.c:92)
==6040==by 0x5375BBF: pn_event_finalize_
Hallo,
I am using proton 0.91 and I constantly experience crashes on process
termination.
I use two messengers, one to read primary input queue and the other to send
replies.
Primary messenger is used in non-blocking mode. On termination I do the
following:
if (_reply) {
pn_messenger_
Sorry to intrude into your discussion, but I have related question.
You have mentioned that the messages can be both durable and non-durable.
How this is controlled in proton? I need all my durable queues to be
persistend over qpidd restart but I don't care about messages.
When I have installed lin
Sorry,
A couple of months ago I discovered a case in proton that prevented
using more than 32767 nodes in message data. One of our applications
created large messages and wherever it exceeded this limit it just
crashed. The data type used to keep number of nodes in proton is
unsigned short and act
Greetings,
I have a process that receives amqp messages using proton messenger in passive
mode
(inside select-based event loop) and sends replies back using second messenger
in
non-passive mode. I want to handle certain messages in a separate process
instance.
Normally I would just fork current
Hallo,
Sorry, this might be the issue I have discovered some time ago and reported to
jira
as issue PROTON-892
(https://issues.apache.org/jira/browse/PROTON-892?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel).
Best regards.
--
\ / | |
(Ov
Hmm thanks, but what if I am using pn_messenger functions? I am afraid
I am not using the reactor.
Best regards,
14.07.2015 15:37, Bozo Dragojevic пишет:
> On 14. 07. 15 12.30, Michael Ivanov wrote:
>> Hallo,
>>
>> I am receiving the qpid message is one process, but w
Hallo,
I am receiving the qpid message is one process, but would like to actually
decode
it in a different process. I it possible to use proton to get the message in the
unpacked binary form, then copy the buffer over to another process (eg. using
pipe)
and unpack it to actual pn_message_t there
54 pmsdev qpidd: 2015-06-30 11:13:54 [Protocol] trace
[qpid.127.0.0.1:5672-127.0.0.1:61305]: 0 <- @begin(17)
[next-outgoing-id=0, incoming-window=2147483647, outgoing-window=0]
Jun 30 11:13:54 pmsdev qpidd: 2015-06-30 11:13:54 [Protocol] trace
[qpid.127.0.0.1:5672-127.0.0.1:61305]: 0 <- @
I have built it myself but I packed them in rpm package. I have used rpm
spec file frrom epel as a template.
29.06.2015 18:59, Gordon Sim пишет:
> On 06/29/2015 03:41 PM, Michael Ivanov wrote:
>> I have started qpidd under debugger and I got the following backtrace:
>>
>> #
0x004049c1 in _start ()
qpidd is 0.32, proton is 0.9
Best regards,
29.06.2015 15:52, Gordon Sim пишет:
> On 06/29/2015 11:27 AM, Michael Ivanov wrote:
>> Hallo,
>>
>> I am using qpidd 0.32 Sometimes during operation the following diagnostics
>> appears:
>>
>> D
Hallo,
I am using qpidd 0.32 Sometimes during operation the following diagnostics
appears:
Detected two management objects with the same identifier:
0-40-1--128(org.apache.qpid.broker:incoming:92bd6cc8-400a-4a81-8770-85d038a3d179,sender-xxx)
Is this a real problem or can these messages be ignor
Greetings,
I am using selectable interface in proton and I wonder should I close file
descriptor
(received from pn_selectable_get_fd()) myself when selectable is terminated or
will
pn_selectable_free() close it?
Best regards,
--
\ / | |
(OvO) | Mikhail Iw
Hallo,
I have a software application that uses proton qpid for communication and
sometimes I observe that pn_messenger_put() terminates with PN_INTR error.
How should I recover from this, should the call just be restarted?
Messenger used for sending is in default (so I assume non-passive, blockin
Thanks, Rafael!
07.05.2015 16:47, Rafael Schloming пишет:
> That looks mostly correct to me. I've made a few notes inline...
>
> On Thu, May 7, 2015 at 9:27 AM, Michael Ivanov wrote:
>
>> Hallo,
>>
>> I am trying to integrate proton messenger with a
Hallo,
I am trying to integrate proton messenger with a regular select-based event
loop.
Regrettably there's not much documentation about reading and sendingn messages
in passive mode using selectors. Can you give a quick look to the pseudo-code,
describing message input in my event loop and veri
Good evening,
Is it reasonable to use amqp messages (currently I am using proton together
with qpidd)
for image transfer? The images are expected to be of 1 ... 1.5Mb size.
Best regards,
--
\ / | |
(OvO) | Mikhail Iwanow |
(^^^) | V
need to be copied if you are going to clear or free the pn_data_t.
>
> --Rafael
>
> On Wed, Feb 18, 2015 at 4:35 AM, Michael Ivanov wrote:
>
>> Greetings!
>>
>> I need to confirm a point about pn_data_put_string usage. Second argument
>> is
>> pn_bytes
Many thanks, the queue name without host address worked!
18.02.2015 14:18, Gordon Sim пишет:
> On 02/18/2015 11:03 AM, Michael Ivanov wrote:
>> Ok I have run my test program with PN_TRACE_FRM set to 1. The program sends
>> a request
>> to qpidd to create a queue TESTQUEU
very-count=0, link-credit=1, drain=false]
[0x177f450]:0 <- @close(24) [error=@error(29)
[condition=:"amqp:internal-error", description="not-found: Exchange not found:
amqp:
(/Archive/misc/mq/qpid-cpp-0.30/src/qpid/broker/ExchangeRegistry.cpp:144)"]]
[0x177f450]: <- EOS
CONNECTION ERR
Greetings!
I need to confirm a point about pn_data_put_string usage. Second argument is
pn_bytes_t which contains pointer to text buffer and actual length of the string
in bytes. When this value is assigned to data node does it mean that the
ownership
of the string buffer is transfered to data ob
Thanks, that worked!
18.02.2015 01:11, Gordon Sim пишет:
> On 02/17/2015 09:59 PM, Michael Ivanov wrote:
>> Greetings,
>>
>> I was creating and deleting queues using qpid c++ messenger sending the
>> following
>> messages to qpidd:
>>
0:49:45.677 @E Error reading messages: no valid sources
I guess this is because the reply queue has somehow dissappeared.
What's wrong here?
Best regards,
02.02.2015 15:02, Rafael Schloming пишет:
> On Mon, Feb 2, 2015 at 4:46 AM, Michael Ivanov wrote:
>
>> Hallo!
>>
>&
Greetings,
I was creating and deleting queues using qpid c++ messenger sending the
following
messages to qpidd:
PROPERTIES: {"method"="request",
"qmf.opcode"="_method_request",
"x-amqp-0-10.app-id"="qmf2"}
DATA:
{"_object_id"={"_object_name"="org.apac
Hallo,
I am trying to use proton routine for data formatting.
pn_data_format checks suire of provided buffer and in case it is not
enough just refuses to copy anything at all.
Is it possible to find out how much does it need beforehand?
Ideally would be if one had the possibility to get the poin
Hallo,
Does proton have a reconnect option similar to qpid c++ Messenger?
In c++ version I can specify reconnect option when connection is created
and in case connection to broker is disrupted the library will be trying
to reconnect internally. Can proton messenger be requested to behave similar?
Hallo,
Is it possible in proton to broadcast a message, so that it can be
received by unspecified number of subscribers? If yes, where can I
read about that?
Many thanks!
--
\ / | |
(OvO) | Mikhail Iwanow |
(^^^) | Voice: +7 (911)
Hallo!
I am implementing message handling event loop using proton library.
I create a pm_messenger, subscribe to several incoming queues and wait
for input. I also need to send outgoing messages when handling incoming
ones and for some of the outgoing messages I want to get an immediate
reply (whi
cs will be
> updated when that happens.
>
> --Rafael
>
> On Fri, Jan 30, 2015 at 5:35 AM, Michael Ivanov wrote:
>
>> Greetings!
>>
>> I want to port some c++ messaging code from qpid cpp messanger to proton.
>> How one is supposed to perform data serialization/
Greetings!
I want to port some c++ messaging code from qpid cpp messanger to proton.
How one is supposed to perform data serialization/deserialization here?
In cpp messenger I used encode/decode functionality and then copied the
actual data between map and user object. What should I use in proton?
Hallo,
I'm using c++ broker and c++ messageger interface to send the messages.
I am setting the contents of the messages using encode() function
(converts Variant::Map to Message). What should I use on Java side
to decode these messages? How should I send messages from java to
be able to read them
:12 +0300, Michael Ivanov wrote:
>> Hallo,
>>
>> I am reading the messages from the queue as follows:
>>
>>Receiverr(_session.nextReceiver());
>>Message message(r.fetch(Duration::FOREVER d));
>>
>
> This sequence should be spending its t
Strange,
I just changed the timeout from Duration::FOREVER to Duration(4000)
but it still waits for the message forever, no exception is thrown
in 4 seconds...
> Hallo,
>
> I am reading the messages from the queue as follows:
>
>Receiverr(_session.nextReceiver());
>Message messa
Hallo,
I am reading the messages from the queue as follows:
Receiverr(_session.nextReceiver());
Message message(r.fetch(Duration::FOREVER d));
At some moment I want to interrupt the receiver using some signal.
>From signal handler I invoke pthread_kill(SIGUSR1, pthread_self())
but
a qpid::messaging c++ interface.
Where can I get the description of using null target and "to" field setting?
I have seen this capability in proton examples, but not in c++.
Best regards,
03.12.2014 11:03, Gordon Sim пишет:
> On 12/03/2014 06:54 AM, Michael Ivanov wrote:
>>
Hallo,
I am developing an event loop which might be required to periodically send
messages to different mailboxes. I am a bit unsure whether creating Sender
object for each message does involve a lot of overhead? Can I create a Sender
each time when I send a message or is it better to cache the se
, Michael Ivanov пишет:
> Hallo,
>
> qpidd dies at some point with the following message:
>
>[Protocol] error Error on attach: Node not found:
> eead7253-4466-44d8-927a-af151f2f2184_receiver-xxx
>[System] warning CLOSING [qpid.127.0.0.1:5672-127.0.0.1:54665] unsent data
>
Hallo,
qpidd dies at some point with the following message:
[Protocol] error Error on attach: Node not found:
eead7253-4466-44d8-927a-af151f2f2184_receiver-xxx
[System] warning CLOSING [qpid.127.0.0.1:5672-127.0.0.1:54665] unsent data
(probably due to client disconnect)
Is this a qpidd b
flag).
Or will the reply queue created as '#' expire after some period of time
automatically?
Bets regards,
21.10.2014 14:23, Gordon Sim пишет:
> On 10/21/2014 10:29 AM, Michael Ivanov wrote:
>> Just one thing: should I destroy the subscription to '#' explicitel
2014 08:43 AM, Michael Ivanov wrote:
>> I am new to qpid-proton, can somebody give me some pointers on how to get
>> replies
>> for the messages when working via qpidd broker?
>
> Subscribe to an address with the '#' as the node. This is a special character
>
Greetings!
I am new to qpid-proton, can somebody give me some pointers on how to get
replies
for the messages when working via qpidd broker? I tried to use msgr-{send/recv}
examples from tests/tools, they seem to work fine when used without broker
(I used primary queue address string amqp://~0.0.
91 matches
Mail list logo
