Re: Artemis JMS client: Can I stream body of ActiveMQTextMessage?

On 5/1/25 15:31, Justin Bertram wrote: I can see that it arrives as you describe as a large message but it reads it all into memory (ActiveMQTextMessage) before reaching user code... Are you using the streaming pattern as outlined in the documentation I linked previously? If not then the entire

Re: [Artemis] Passing message userID into STOMP

On 10/3/24 11:04, Мурад Байгильдин wrote: Hi, Justin! Sender sends message into request queue and expects response message in response queue, with response's JMSCorellationId header being set to message ID that was sent (and could not be read by responder app). Sender (java app) originally was no

Re: ActiveMQ Federation Questions

On 9/17/24 05:15, Devriendt, Erik wrote: Hello Ken Your link points to the documentation of the ActiveMQ Classic version. Patrick indicates as version: AMQ: v2.36.0, which is the Artemis version. I think a better link is https://activemq.apache.org/components/artemis/documentation/latest/feder

Re: Need help with federation setup with ActiveMq

On 6/26/24 06:56, Saju Daniel wrote: Hello, Just a gentle reminder. The issue is kind of critical for us to implement federation on our setup . Please let me know if you need more information on the problem. After talking to Justin Bertram about some core client details I tried your setup an

Re: Need help with federation setup with ActiveMq

MESSAGE COUNT MESSAGES ADDED DELIVERING COUNT MESSAGES ACKED COUNT ROUTING TYPE INTERNAL audit-trail-shared events.# 5 0 2 0 2 0 MULTICAST false Regards, Saju On Thu, 20 Jun 2024 at 20:44, Timothy Bish wrote: On 6/20/24 12:50, Saju Daniel wrote: Hello Tim, Thanks

Re: Need help with federation setup with ActiveMq

On 20. Jun 2024, at 16:55, Timothy Bish wrote: On 6/19/24 14:33, Saju Daniel wrote: Hello All , We see duplicated message at the consumer end on USA federation with a symmetric federation setup as described here - https://activemq.apache.org/components/artemis/documentation/2.20.0/feder

Re: Need help with federation setup with ActiveMq

On 6/19/24 14:33, Saju Daniel wrote: Hello All , We see duplicated message at the consumer end on USA federation with a symmetric federation setup as described here - https://activemq.apache.org/components/artemis/documentation/2.20.0/federation-address.html The configuration is described in t

Re: Issue with TTL of received AMQP messages

On 6/17/24 05:16, Devriendt, Erik wrote: We stumbled on an issue in Artemis with the handling of the TTL field of received AMQP. Our Artemis instance has a AMQP broker connection to a IBM MQ broker and receives messages forwarded by that IBM MQ broker. If the IBM client does not provide a speci

Re: Apache ActiveMQ Classic 5.17.3; STOMP receipts

On 5/14/24 10:28, Bouscaren, Paul wrote: Classic (per the subject line) Stomp 1.1 Among other issues, the STOMP specification suggests I will receive a receipt for my DISCONNECT frame, which I do not receive. The tests in the broker would imply that it works https://github.com/apache/activem

Re: MQTT retained messages and federation

On 5/8/24 05:56, Devriendt, Erik wrote: Hello all I have a question about retained messages in MQTT. I have 2 federated activeMQ Artemis 2.32.0 brokers A and B. When I start a MQTT client on broker A that publishes a retained message on a given topic and then exits, a second MQTT subscriber c

Re: Federation Question

On 4/22/24 03:06, herbert.helmstr...@systema.com wrote: Hello Team, I have a question regaring Artemis. We have two different clusters, that run more or less independently. But for some events and requests there should be a transparency between the clusters. I thought that Adress  Federation

Re: feasibility of connecting ActiveMQ Artemis with IBM MQ

On 3/25/24 10:15, Devriendt, Erik wrote: Hello all We plan to use ActiveMQ Artemis in a larger project for our customer. This broker will serve the message exchange between the internal components of our system, but the customer also asks to connect to their IBM MQ broker for publishing data f

Re: Connecting ActiveMQ 5.18.3 using Artemis Client

activemq-client for classic broker doesn't support it therefore I was trying to find out the client library which can support that. On Tue, Jan 2, 2024 at 5:51 PM Timothy Bish wrote: On 1/2/24 17:29, Paras Jain wrote: Hi, I am trying to implement an ActiveMQ client with sharedconsumer function

Re: Connecting ActiveMQ 5.18.3 using Artemis Client

On 1/2/24 17:29, Paras Jain wrote: Hi, I am trying to implement an ActiveMQ client with sharedconsumer functionality with ActiveMQ 5.18.3. The activemq-client ( https://mvnrepository.com/artifact/org.apache.activemq/activemq-client) doesn't seem to support SharedConsumer functionality yet. When

Re: [EXTERNAL]:Re: STOMP client receives undefined priority header when JMSPriority = 4 (default)

The AMQP specification defines that the priority value carried in the AMQP Header section of the Message has a default value of 4 which means that an AMQP peer may omit this value on the wire to reduce encoding size if it chooses to and the receiving peer should interpret that as carrying the d

Re: Critical CVE-2023-46604 Fix Question

On 11/1/23 14:55, Steigerwald, Aaron wrote: Hello, Does anyone have an estimate for how soon Apache Artemis will be delivered with Apache ActiveMQ artifacts that address the critical CVE-2023-46604 "Apache ActiveMQ is vulnerable to Remote Code Execution" fix? Fix details can be found here: h

Re: Hunting memory leaks

On 8/9/23 08:06, Jan Šmucr wrote: Hello. I’m using a simple master-slave Artemis 2.26.0 cluster, and I’m noticing heap usage growing more and more each day no matter the throughput. There’s about 670 sessions at the same time opened for producers and consumers. Consumers are polling queues on

Re: [RESULT][VOTE] Release Apache Qpid protonj2 1.0.0-M17

On 7/31/23 18:03, Timothy Bish wrote: There were 3 binding +1 votes, and 1 other vote received. The vote has passed. I will add the files to the dist release repo and release the maven staging repo shortly. The website will be updated after the release has had time to sync to the mirrors and

[RESULT][VOTE] Release Apache Qpid protonj2 1.0.0-M17

There were 3 binding +1 votes, and 1 other vote received. The vote has passed. I will add the files to the dist release repo and release the maven staging repo shortly. The website will be updated after the release has had time to sync to the mirrors and maven central. -- Tim Bish

Re: connection attempt hangs

handle an error from whatever API point in OpenSSL would provide one, or not use expired certificates as an alternative. On Mon, Jul 24, 2023 at 7:52 AM Timothy Bish wrote: On 7/21/23 17:01, david kerns wrote: I started with the example code here: https://activemq.apache.org/components/cms

Re: connection attempt hangs

On 7/21/23 17:01, david kerns wrote: I started with the example code here: https://activemq.apache.org/components/cms/example I modified it to use SSL and a certificate... all working. Six months later when the certificate expired, starting the subscriber just hangs on: connection->start(); It

Re: ActiveMQ / configure queues

On 3/31/23 10:22, Ephemeris Lappis wrote: Hello. Thanks. I'm going to have a look at these configuration items. Do you confirm this also work for "classic" ActiveMQ (we do not use Artemis) ? The configuration for ActiveMQ Classic and ActiveMQ Artemis are not interchangeable. Regards. Le

Re: how o set closeMqttConnectionOnPublishAuthorizationFailure on MQTT connector

On 3/17/23 10:10, Modanese, Riccardo wrote: Hello, the prhttps://issues.apache.org/jira/browse/ARTEMIS-3702 introduced a parameter to allow the user to configure the broker behavior when a publish attempt on a not allowed (by ACL) topic is attempted (so if disconnect the client or send

Re: How do I install and use ApacheMQ?

On 7/26/22 10:11, Turritopsis Dohrnii Teo En Ming wrote: Subject: How do I install and use ApacheMQ? Good day from Singapore, How do I install and use ApacheMQ? Thank you. Regards, Mr. Turritopsis Dohrnii Teo En Ming Targeted Individual in Singapore 26 July 2022 Tuesday Blogs: https://tdtemc

Re: [External] - Re: How to avoid AMQ229014 TTL "dump" for a "patient" Python 3 Stomp Listener

x27;t know how to process the message. Given the specification says an EOL constitutes a heart beat one could assume the broker would process it as such. What I wouldn't give for actual code examples! :p here you go:  socket.write("\n"); ________ From

Re: [External] - Re: How to avoid AMQ229014 TTL "dump" for a "patient" Python 3 Stomp Listener

On 6/23/22 10:21, Richard Bergmann wrote: I am set up to receive the heartbeat event on-heartbeat, but it is never fired. Heartbeat makes sense, and I did a bit of digging on that, but the "STOMP heart-beating and connection-ttl" section withinhttps://activemq.apache.org/components/artemis/doc

Re: Question regarding ActiveMQ C-API

On 3/16/22 01:42, Brian Alizadeh wrote: Hi Justin and Matt, It seems OpenWire has a C-API at this address: http://svn.apache.org/repos/asf/activemq/sandbox/openwire-c/ That client was never released or maintained in any way so using it would be a dead end.  I'd suggest as others have that you

Re: activemq-cpp unit tests not building

r and bowl of shrimp at the Anchor Bar at The Fish Market at the bottom of King Street. 😊 Great, now I want some beer and shrimp ;) --Jim (former Old Town Alexandria resident) -Original Message- From: Timothy Bish Sent: Wednesday, February 23, 2022 3:05 PM To: users@activemq.

Re: activemq-cpp unit tests not building

ng it at this time.  You can try other C or C++ clients such as the AMQP clients hosted by the Qpid project or a STOMP client of which there are many. --Jim -Original Message- From: Timothy Bish Sent: Wednesday, February 23, 2022 12:26 PM To: users@activemq.apache.org Subject: Re: act

Re: activemq-cpp unit tests not building

On 2/23/22 14:16, james wing wrote: I'm attempting to build & install activemq-cpp client on a Debian system, with unit and integration tests. After git-ing the latest source and following instructions in the README.txt (and/or here: https://activemq.apache.org/components/cms/developers/buildin

Re: ActiveMQ - Stomp over websockets - Same Origin Policy

On 8/7/20 2:40 PM, Christopher Pisz wrote: What I need: To determine if I can connect to activemq using stomp over websockets from a remote machine, with a client I wrote. What I did: I wrote my own stomp over websockets client in C++ and built it for CentOS7, on my home computer. I installed an

Re: ActiveMQ - Stomp over websockets - Same Origin Policy

On 8/7/20 2:08 PM, Christopher Pisz wrote: Yes, I did a Google search. It yields code examples or javascript libs. I need a built client that connects with a different protocol, so I can quickly test that the server will allow clients to connect at all. You can try the ActiveMQ JMS client librar

Re: STOMP - How do I know if my ACK is working?

On 8/5/20 3:01 PM, Christopher Pisz wrote: I have finished implementing ACKs in my STOMP over Websockets client and want to test it out. I can connect, subscribe, send, and receive messages, from ActiveMQ, but the protocol doesn't have anything to tell me whether or not the ACK worked. How can I

Re: Apache activemq 5.15.9 Linux version download error

On 3/31/20 3:40 PM, Madhuri Bhosale wrote: Hi team, I want to download activemq version 5.15.9 version. On click download link it give page not found error. Please advise... Need the version. Thanks, Madhuri Bhosale Old releases are always available in the Apache Archives: http://archive.ap

Re: OutOfMemory encountered in Artemis CoreAmqpConverter

On 3/27/20 10:00 AM, Dirkjan Ochtman wrote: Hi there, I'm still trying to build an AMQP RPC message flow. I have the request path working and am now debugging the response path. In doing so, it seems that the response message is correctly being sent over the expected channel, but the broker seem

Re: Scala "Wire format" error on Receive from Queue

On 2/25/20 4:32 PM, Justin Taylor wrote: I have ActiveMQ running on a server. I can connect from my PC using Python stomp. With Scala, I get this error: Exception in thread "main" javax.jms.JMSException: Wire format negotiation timeout: peer did not send his wire format. I copied the Scala

Re: Configure ActiveMQ (on AWS) for heartbeat read grace period

On 1/15/20 10:32 AM, gilp wrote: I'm struggling with configuring for coping with broken connections. I'm getting the impression that MQ removes inactive connections._I assume the following happens_: When a destination does not receive any message for a long time -> the consumer connection is

Re: Problems with my attach message

On 12/13/19 3:25 PM, Dirkjan Ochtman wrote: On Thu, Dec 12, 2019 at 11:59 PM Timothy Bish wrote: which is then encoded (not quite optimal, but seems to be correct per the spec) as [0, 0, 0, 70, 2, 0, 0, 0, 0, 163, 16, 97, 109, 113, 112, 58, 97, 116, 116, 97, 99, 104, 58, 108, 105, 115, 116

Re: Problems with my attach message

On 12/12/19 3:08 PM, Dirkjan Ochtman wrote: Hi there, I'm trying to implement AMQP 1.0 in Rust from scratch because I'd like my Rust service to be able to talk to an Artemis broker. I've been making good progress, but am hitting some trouble now that I'm trying to send the attach performative af

Re: AMQ CPP - How do you set up multiple destination for one producer

On 10/18/19 8:00 AM, JackOfAllTrades wrote: Answering my own questionagain So basically, just create the producer without initializing with a queue(temporary or otherwise). This seems to be different behavior from CMS then of JMS Since you don't provide your code it is unclear what ex

Re: Authorization plugin - don't know what to do with client attempting to write to weird advisory topic

On 9/26/19 10:22 AM, Jędrzej Dudkiewicz wrote: On Thu, Sep 26, 2019 at 3:01 PM Tim Bain wrote: Chris, The problem he's pointing out is that the destination name is the comma-separated concatenation of two advisory topic names. It feels like there's a missing String.split() call earlier in the

Re: Is there a way to monitor delayed message ?

On 7/13/19 12:04 AM, Justin Bertram wrote: The names of the metrics he mentioned match those from 5.x and not Artemis so I assume he's asking about 5.x. However, it's worth noting that Artemis does track delayed/scheduled messages using the ScheduledCount metric on the QueueControl MBean. I don'

Re: Issues with ActiveMQ 5.14.2 and Java 8

On 6/26/19 5:34 PM, Mike Garcia wrote: Hi, We just updated our systems to Java 8 and now ActiveMQ 5.14.2 fails to launch. We get the following error message in the wrapper.log file when we try to launch the ActiveMQ service: Error: Registry key 'Software\JavaSoft\Java Runtime Environment'\

Re: JMS QueueBrowser does not return actual number of messages in the queue

On 6/19/19 1:18 PM, cooshal wrote: Hi: thank you for the clarification. Is there a way to retrieve the queue stats? I wanted to retrieve the number of messages, pending messages, etc. similar to those shown in activemq console. The only really reliable means would be to use JMX and ask the MB

Re: JMS QueueBrowser does not return actual number of messages in the queue

On 6/19/19 12:13 PM, cooshal wrote: Hi: I am using ActiveMQ version 5.15.8 I have the following code fragment, which is basically there to count the number of messages in a particular queue (here, it is tst.errors) brokerConnection = connectionFactory.createConnection(); session = this.createS

Re: Can consumers acknowledge/confirm receipt of a message versus auto acknowledgement?

On 6/5/19 12:18 PM, leejacks...@cox.net wrote: Hi! We have a consumer written using the cms_browserGetNextMessages function written by Apache I don't see this Apache person you mention listed in the committers for the that project (https://github.com/fusesource/fusemq-c/blob/master/fu

Re: Need examples of Artemis for .NET core C# on AcknowledgementModes in sender and receiver

Re: Need examples of Artemis for .NET core C# on AcknowledgementModes in sender and receiver Thanks for confirming my suspicions, Tim. Justin On Fri, May 31, 2019 at 2:53 PM Timothy Bish wrote: On 5/31/19 3:44 PM, Justin Bertram wrote: I'm not terribly familiar with NMS, but in my exper

Re: Need examples of Artemis for .NET core C# on AcknowledgementModes in sender and receiver

On 5/31/19 3:44 PM, Justin Bertram wrote: I'm not terribly familiar with NMS, but in my experience the only component which acknowledges a message is a consumer. How does a sender in NMS use acknowledgements? It doesn't Justin On Fri, May 31, 2019 at 2:29 PM Gabriel Almeida Goncalves < gabrie

Re: Needing header to trace lost messages

On 5/22/19 1:10 PM, leejacks...@cox.net wrote: Our header is a string value, so we tried using cms_getMessageStringProperty(txtMessage, "OriginalDestination", key, bufferLen). It is failing with a return code of 1. Any ideas? -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-Use

Re: Needing header to trace lost messages

On 5/22/19 11:25 AM, leejacks...@cox.net wrote: Hi! We have a consumer written using the cms_browserGetNextMessages function written by Apache (https://github.com/fusesource/fusemq-c/blob/master/fusemqc-client/src/main/cpp/CMS_QueueBrowser.cpp). We are experiencing missing messages. We post mes

Re: Non_persistent messages and qpid-jms-client-0.20.0.jar or higher.

On 5/3/19 5:58 AM, Patrick Vansevenant wrote: I'm not able to send non_persistent messages to an ActiveMQ broker (5.15.3) with version 0.20.0 or higher of the qpid-jms-client library. The messages are shown as persistent on the console and they behave also as persistent. Sending non_persistent me

Re: Release date for ActiveMQ 5.15.10

On 4/29/19 5:00 AM, hjeth...@birst.com wrote: Hi Team, We observed an issue with Message Persistence on Broker side (Refer this link for detail regarding same). As mentioned i

Re: JMS Asynchronous Receiver for ActiveMQ Artemis

On 2/21/19 10:24 PM, Justin Bertram wrote: I looked at the code for the javax.jms.Connection implementation in ActiveMQ 5 and it wasn't clear to me what would have been blocking in the call to start(). Artemis supports the OpenWire protocol so you can still use the 5.x client. If you use the 5.x

[ANNOUNCE] ActiveMQ-CPP Version 3.9.5 Released

Hi Everyone, Its official, AcitveMQ-CPP v3.9.5 has now been released. There is a new configuration option to help deal with hang when broker doesn't respond to a connection request and some fixes for SSL leaks. The Wiki page for the release is here: http://activemq.apache.org/cms/activemq-cpp

Re: activemq-cpp support encrypted keystore password

On 1/21/19 2:28 PM, skimbrell wrote: In looking at the Java implementation of the activemq client, you are able to encrypt a password and then pass it in as a property enclosing it within an ENC() and the activemq recognizes the password is encrypted and decrypts it. My question is whether or no

Re: Why input string param length limit on writeUTF(…) of ActiveMQBytesMessage.java

The JMS API states that the methods of JMS BytesMessage "are based largely on those found in |java.io.DataInputStream| and |java.io.DataOutputStream|." which is why most implementations will rightly encode using a size value of two bytes to match that of the DataOutputStream writeUTF implementa

Re: Access ActiveMQ from Perl problem

On 12/14/18 5:07 PM, USBLexus wrote: Hi, I installed CPAN Net-STOMP library (https://metacpan.org/release/Net-STOMP-Client) as suggested here http://activemq.apache.org/cross-language-clients.html, but if I try to connect to my AciveMQ broker 5.14.0, I can see following error in logs: INFO | j

Re: Create connection factory even when broker is down

On 12/14/18 4:54 AM, BlueSpirit wrote: TL;DR I would like to instantiate the connection factory even when the broker is down. How should I achieve this? I am creating a ActiveMQConnectionFactory using the following URL: failover:(tcp://localhost:61616)?jms.warnAboutUnstartedConnectionTimeout=300

Re: Using AMQP against ActiveMQ 5

On 12/10/18 5:50 AM, kkaczkow wrote: Hello Tim! I have tested AMQP with ActiveMQ 5 and it turned out to be approximately 3 times slower than OpenWire. Would you have any hints how to improve performance for AMQP (both on broker and client side)? Konrad -- Sent from: http://activemq.2283324.n

Re: Using AMQP against ActiveMQ 5

On 12/7/18 9:19 AM, kkaczkow wrote: Hey guys! I was wondering is there is any handicap related to using AMQP against ActiveMQ instead of OpenWire? Also is using Apache Qpid, which implements JMS 2.0, fully compatible with ActiveMQ 5? When used against ActiveMQ 5.x brokers the Qpid JMS client f

Re: Apache NMS ActiveMQ - support for createSharedDurableConsumer

NMS API does not offer support for this and there aren't any plans to add it.  The OpenWire protocol doesn't offer the features needed to implement shared subscriptions so it isn't easily added there.  You could trying switch to an AMQP based .NET client like AmqpNetLite and work from there.

Re: ActiveMQCPP--Cannot publish to a deleted destinatination: temp-queue:

On 09/18/2018 09:38 PM, dpatel wrote: I did try to connect with the ?jms.watchTopicAdvisories=false in the uri. connection.watchTopicAdvisories=false -- Tim Bish

Re: [Artemis 2.6.2] AMQP messages going to expiry queue, redelivery off that queue is failing

erroneous null character in the message transfer from the broker: https://lists.apache.org/ thread.html/b1fd9c09a1f66f5529601a8651fbb96585c011b22bbd84e07c4f23b1@% 3Cusers.qpid.apache.org%3E thank you so much for your time On Tue, Aug 14, 2018 at 1:19 PM Timothy Bish wrote: On 08/13/20

Re: connections

On 09/06/2018 05:35 PM, developer wrote: Hi, Could anyone correct me if I am doing anything wrong here. p= new ActiveMQConnectionFactory() ; connection1 = p->createConnection(xy,yz); connection1->start(); q= new ActiveMQConnectionFactory() ; connection2 = q->createConnection(xy,yz);

Re: [Artemis 2.6.2] AMQP messages going to expiry queue, redelivery off that queue is failing

On 08/13/2018 07:12 PM, Dan Langford wrote: some of my users are attempting a pattern to deduplicate messages based on a time window instead of a fixed amount of space (a duplicate id cache) so far the concept has been working very well. So they send their AMQP messages (qpid-jms-client) into a

Re: redelivery with qpid proton (AMQP, activemq 5.15)

On 08/14/2018 10:25 AM, areddy wrote: I'm using qpid proton (python) to connect to activemq and receive messages. I noticed that, whenever my client "releases" a message, activemq immediately retries without incrementing the retry count and without respecting the redelivery policy. That is doin

Re: Simple question on AMQP 1.0 protocol support

On 07/20/2018 12:49 PM, dbeavon wrote: If a client and broker implement the AMQP 1.0 standard spec, then they should be able to interoperate, right? IE it is the standard that matters more than the particular version/revision of the client code. I'm asking because redhat distributes v.1.1.8 of

Re: Threads started in ActiveMQCPP

On 07/19/2018 07:02 PM, developer wrote: Hi, This question is with reference to activemq cpp version 3.9.3 Once we call intialize and establish connection by calling activemq::library::ActiveMQCPP::initializeLibrary(); x= ActiveMQConnectionFactory() ; connection = x->createConnection(xy,xz);

Re: C++ Broker Performance with large messages

On 07/12/2018 03:25 AM, kullboys wrote: Hello everyone I tested throughput of the Qpid C++ Broker (compiled as Release). It was tested on a virtual machine with 15 GB RAM. First I sent a 100 MB message into a persistent queue. From sender to receiver it took 16 seconds for one message. Afterwa

Re: Artemis Kerberos support for openwire and stomp protocol

On 06/13/2018 02:52 AM, xabhi wrote: Thanks for the reply Tim. Is there a plan to extend Kerberos Authentication to STOMP and other protocols in Artemis? Should i log a JIRA ticket for this? Thanks, Abhi -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html There a

Re: Artemis Kerberos support for openwire and stomp protocol

On 06/12/2018 04:24 AM, xabhi wrote: Hi, I am looking to setup Artemis for my use-cases that are currently using ActiveMQ v5.14.1 and want to use Kerberos auth which isn't available in ActiveMQ currently. How can i set-up Kerberos authentication for openwire and STOMP protocol? How will clients

Re: Update Links on Wiki

On 05/23/2018 03:33 PM, Benjamin Darfler wrote: Hi, I've recently changed my blog and I noticed some of the links on the wiki are stale. I'd love to make sure that interested users can find the right information still. Who can help me update the following links? *On https://cwiki.apache.org/con

Re: [ANNOUNCE] Apache ActiveMQ 5.15.4 Released

On 05/22/2018 03:27 PM, Anindya Haldar wrote: How does the this version relate to the Apache ActiveMQ Artemis versioning? Is there a mapping, or is it completely separate from Artemis? We are evaluating Artemis; so are wondering. They are two different brokers with different release streams.

Re: Active MQ thread getting blocked.

This is the stack trace you see when using a failover URI and a connection has yet to be established. The createSession call must block here as there isn't a broker to service any requests On 05/15/2018 11:58 AM, nik...@gmail.com wrote: HI, I'm looking to identify the following case where ac

Re: ActiveMQ AMQP NMS build with Mono

On 05/11/2018 11:09 AM, tschneider wrote: Hello, I am working in linux. I want to get the NAnt build working for mono. https://github.com/apache/activemq-nms-amqp >From reading the documentation I thought it was supported but it does not appear to be. Can anyone help me out? -- Sent from:

Re: Broker redelivery - messages lost on broker restart

5.8.0 is quite old, try moving to a new broker release. On 04/20/2018 02:30 PM, j.kupka wrote: Hello, I cofigured redelivery policy through Redelivery plugin. Everything works as expected except the scenario when the broker is restarted while there are messages scheduled for re-delivery. Those

Re: Message Property Type Always String?

On 04/13/2018 11:52 AM, Tom Parsons wrote: Hello Forum- I'm a new user of ActiveMQ CMS (ActiveMQ-cpp-3.9.3), and new to JMS as well. I am creating, formatting, and sending test messages to myself to start. In my code to consume those message, I check the property type of all the message propert

Re: Getting 'java.lang.NumberFormatException: For input string: "1-1"' errors when doing client side ack with STOMP clients if message sent by AMQP producer

On 04/13/2018 01:53 PM, Daniel Hutchison wrote: Hey all, When my STOMP clients try to do client side ACKs on a message that was sent from an AMQP producer, I'm getting the following error message showing up in activemq's log (and my stomp clients get an error on their connection as well): 2018-

Re: Unexpected resend behavior when pulling messages using NMS .NET ReceiveNoWait

On 04/05/2018 03:04 AM, asafm wrote: I am using NMS ActiveMQ .NET client to pull messages from the queue using MessageConsumer.ReceiveNoWait method. The consumer application attempts to pull all pending messages every second. I am trying to configure messages to be resent, but oddly it does not w

Re: Inactivity Monitor - closing connection exactly at given timeout even keepalive true

If using HTTP transport then I recall there might have been a bug fixed for the inactivity and lack of ping commands getting marshaled.  That would probably mean you need to upgrade to a later release though.  Otherwise you'd need to analyze the network traffic and see if a firewall or somethin

Re: Apache Camel and IBM MQ

On 03/12/2018 12:20 PM, Gupta Bharat wrote: Hello, Issue: I am routing a message from active mq topic to Ibm mq queue, using Apache camel as the medium between these two. Apache camel is used for intermediate routing and for transformations. I am setting JMSDestination in message header as so

Re: mKahaDB - no clean-up because of ACKs

On 03/09/2018 11:26 PM, Tim Bain wrote: Joachim, There must have been at least one file that was kept not because of acks in an earlier file. Presumably this would be the one with the lowest number. Can you provide the log output for that file? The standard guess when people say that their Kaha

Re: NMS PGP Certificate Revoked

I also downloaded > the asc file, but when I try to verify the binaries with the asc, it tells > me that the certificate (Timothy Bish) has been revoked. Looking the > certificate up manually on MIT's page says the same thing. If the > certificate has been revoked, is there no wa

Re: Using NMS and JMS at the same time

On 02/23/2018 05:43 AM, almin wrote: Can ActiveMQ support NMS and JMS at the same time as part of a single interface. There are two applications (both support ActiveMQ), both using different connectors *App1 uses JMS* (written in Java) and *App2 uses NMS* written in .NET. I am trying to have a

Re: C++ Broker Performance with large messages

On 02/20/2018 11:47 AM, andi welchlin wrote: Hello all, I tested throughput of the Qpid C++ Broker (compiled as Release). It was tested on a virtual machine with 15 GB RAM. First I sent a 100 MB message into a persistent queue. From sender to receiver it took 16 seconds for one message. After

Re: Active MQ CPP

On 02/20/2018 10:35 AM, duttaab wrote: What kind of issues do you suspect if its getting called multiple times from different threads - or we can face undefined behavior. Thanks Abhi -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html Black holes, unexpected time

Re: Active MQ CPP

On 02/20/2018 05:53 AM, duttaab wrote: Hi, In a process which is multi-threaded, is it ok to initialize ActiveMQ-CPP multiple times (by multiple threads) by calling API --> "activemq::library::ActiveMQCPP::initializeLibrary()". Or should it be called only once in the process. Thanks Abhi --

Re: Scheduling(delayed delivery) a message AMQP.NETLIBRARY broker: ActiveMQ Windows platform C#

On 02/14/2018 07:06 AM, bittusrivastava wrote: Thanks for reply. how to use MessageAnnotation. i tried reading documentation but couldn't find any useful resource. for example if i have to set attribute "x-opt-delivery-delay" how can we do it. Thanks -- Sent from: http://activemq.2283324.n4.n

Re: ActiveMQ and Java 9

On 02/14/2018 02:10 PM, nbhc wrote: Does ActiveMQ work with Java 9? I tried v5.15.2 and JDK9.0.4, activemq fails to start with exception like below: java.io.IOException: java.lang.IllegalAccessException: class org.iq80.leveldb.util.ByteBufferSupport cannot access class jdk.internal.ref.Cleaner (

Re: Trying to send and receive text messages using ActiveMQ with JavaScript (AMQP) and Java (OpenWire/JMS) clients

Java-side as mentioned in the original post with the added bytes before the "Hello World!" string. On 14/02/2018 00:46, Timothy Bish wrote: On 02/13/2018 06:22 PM, Jeroen van Ooststroom wrote: Thank you for your response. When I upgrade to ActiveMQ 5.15.3 my simple JavaScript client i

Re: Trying to send and receive text messages using ActiveMQ with JavaScript (AMQP) and Java (OpenWire/JMS) clients

ks, Jeroen... On 13/02/2018 23:45, Timothy Bish wrote: On 02/13/2018 05:29 PM, Jeroen van Ooststroom wrote: I have a simple test JavaScript (Node.js) client that connects to ActiveMQ using AMQP and our Java client that connects to the same ActiveMQ using OpenWire (JMS). When I send a messag

Re: Trying to send and receive text messages using ActiveMQ with JavaScript (AMQP) and Java (OpenWire/JMS) clients

On 02/13/2018 05:29 PM, Jeroen van Ooststroom wrote: I have a simple test JavaScript (Node.js) client that connects to ActiveMQ using AMQP and our Java client that connects to the same ActiveMQ using OpenWire (JMS). When I send a message from the JavaScript client (just a simple “Hello World!”)

Re: Scheduling(delayed delivery) a message AMQP.NETLIBRARY broker: ActiveMQ Windows platform C#

On 02/12/2018 01:58 AM, bittusrivastava wrote: Thanks for response. I couldn't find where i can set those header in AMQP.net library. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html They would be set in the MessageAnnotations on the message that you want to be

Re: Can we achieve clustering and distributed feature of ActiveMQ for .net application

On 02/09/2018 08:14 AM, Tim Bain wrote: ActiveMQ 5.x doesn't support clustering (multiple active brokers all sharing a set of messages to serve to clients), but Artemis does. ActiveMQ supports having a client failover between multiple active brokers, which could be linked together in a network o

Re: Persistent issue on Windows platform C# on restarting broker

Are you sending the messages with durable = true set on them? On Feb 8, 2018 7:21 AM, "bittusrivastava" wrote: > one thing i want to add that i am using amqp.netlite library for amqp > protocol > > > > -- > Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User- > f2341805.html >

Re: Can i Use ActiveMq for .net application over amqp protocol

On 02/04/2018 11:54 AM, bittusrivastava wrote: Hi Tim, Thanks a lot for your response. Could you pls provide me any pointer where someone has done POC on this and explained step by step. -- Sent from: http://activemq.2283324.n4.nabble.com/ActiveMQ-User-f2341805.html https://blogs.apache.org

Re: Can i Use ActiveMq for .net application over amqp protocol

On 02/02/2018 07:53 AM, bittusrivastava wrote: Hi, I am investigating as how can i use activeMQ for .net application. I want to use *AMQP* protocol as well. Can anyone please suggest any pointers as how to do it. there are many implementation but they are connecting to uri "tcp://localhost:61616"

Re: ActiveMQ-CPP IPV6 support

On 01/05/2018 12:37 PM, QuickSilver wrote: Hi Apologies if this has been answered elsewhere but I haven't found any clear response, hence posting this here. Does the activemq-cpp client library support IPV6 now? We are required to ensure that our product is IPV6 compliant and our C++ applicatio

Re: Amazon MQ

On 12/08/2017 11:33 AM, Christopher Shannon wrote: Have you tried searching with bing? given the context of the thread maybe it'd be better to ask Alexa ? On Fri, Dec 8, 2017 at 10:39 AM, Justin Bertram wrote: You can imagine that such organizations who make tons of investment in ActiveM

Re: Connecting to invalid URI leads program crash.

On 11/20/2017 09:56 PM, hackerick4 wrote: Hello guys, I was using Paho C library but found a issue. I'm not it's a bug or not. Here are several lines of codes in C. URI1 and URI2 are in valid URI for active MQ, Why the MQTTAsync_connect function didn't report any error but success ? and the prog

  1   2   3   4   5   6   7   8   9   10   >