Re: Integration between Node.js and ActiveMQ - how to use

2017-05-10 Thread Gordon Sim
On 10/05/17 08:36, pedro-masterasp wrote: Regarding my questions I found some of the answers: Q1: Given that STOMP is a protocol, if I find a NPM library for any of the other protocols, can I use Node.js with that given protocol? A1: The answer is yes. For example, using a MQTT library for Node

[artemis]: hierarchical topics over AMQP

2017-08-08 Thread Gordon Sim
How do I configure a hierarchical topic address in artemis since 2.0? That is, I want to define a multicast type address 'mytopic' such that I can then subscribe to mytopic/foo or mytopic/bar (or mytopic/#), and these are all treated as parts of the same topic? If I just have:

Re: Starting with AMQ+AMQP 1.0+QPID Proton

2013-07-08 Thread Gordon Sim
On 07/05/2013 03:30 PM, Pablo Rodríguez Rey wrote: Also, I've a question about mixing AMQP 1.0 Filters/Selectors. I don't know how to make a selector for filtering the Priority of a message. I have a cluster of 6 machines with 3 workers each. 2 are low-priority workers and can do any video transc

Re: Starting with AMQ+AMQP 1.0+QPID Proton

2013-07-08 Thread Gordon Sim
On 07/08/2013 05:20 PM, Pablo Rodríguez Rey wrote: On Mon, Jul 8, 2013 at 6:01 PM, Gordon Sim wrote: On 07/05/2013 03:30 PM, Pablo Rodríguez Rey wrote: I can send and receive messages using AMQP URLs: amqp://127.0.0.1/route But I dont know how to set the paramers to active the selector

Re: Starting with AMQ+AMQP 1.0+QPID Proton

2013-07-08 Thread Gordon Sim
On 07/08/2013 06:20 PM, Pablo Rodríguez Rey wrote: Tested with JMS names, but still ignores them: $ php recv.php "amqp:// 127.0.0.1/xxx2/asd/asd?transport.transformer=jms&JMSPriority%3E5" Ok, so that will result in the 'xxx2/asd/asd?transport.transformer=jms&JMSPriority%3E5' being sent as th

Re: Starting with AMQ+AMQP 1.0+QPID Proton

2013-07-08 Thread Gordon Sim
On 07/08/2013 06:52 PM, Christian Posta wrote: Don't think messenger API supports using filters/selectors. It does not (neither directly through the API, nor through any special syntax in the addresses). Is it possible to express a selector in the string passed to ActiveMQDestination.create

Re: AMQP and Node.js

2013-07-12 Thread Gordon Sim
On 07/12/2013 02:45 AM, razeone wrote: Well, I have this Node.js application that uses STOMP to connect to ActiveMQ. Everithing was cool until I needed better performance, and que STOMP implementations in Node.js are more like personal projects. So, looking for the ActiveMQ documentation, I real

Re: AMQP and Node.js

2013-07-12 Thread Gordon Sim
On 07/12/2013 05:00 PM, Gordon Sim wrote: On 07/12/2013 02:45 AM, razeone wrote: Well, I have this Node.js application that uses STOMP to connect to ActiveMQ. Everithing was cool until I needed better performance, and que STOMP implementations in Node.js are more like personal projects. So

Re: AMQP and Node.js

2013-07-16 Thread Gordon Sim
On 07/15/2013 06:46 PM, razeone wrote: Thanks a lot Gordon, your answer gave me a very good alternative to STOMP and it looks like works fine. Now I have been connected, the question I have now is: How do I establish content based routing? I mean, pass selector headers, it is possible with AMQP?

Re: AMQP and Node.js

2013-07-16 Thread Gordon Sim
On 07/15/2013 08:55 PM, James Carr wrote: I would raise an issue on the original github project so it can get added. That is certainly a good idea... node-amqp should be a one stop place for working with amqp rather than having to make a bunch of modules for each concrete implementation. ..

Re: AMQP Bridge

2013-08-12 Thread Gordon Sim
On 08/12/2013 11:01 AM, Rob Percival wrote: I've been attempting to configure a static bridge between two brokers (I want any messages received on a local broker to immediately be forwarded to a remote broker if it's available). If I use OpenWire, i.e. a "static:(tcp://1.2.3.4:61616)" URL, it wor

Re: AMQP 1.0 Client for .Net/C# (Apache NMS, QPid) available?

2013-10-31 Thread Gordon Sim
On 10/31/2013 07:46 AM, Tom_Z wrote: Hi, ActiveMQ supports AMQP 1.0, but I could't find any client-side implementations for .Net or am I missing something? Apache NMS does not support AMQP yet, see http://activemq.apache.org/nms/nms-providers.html and an open issue https://issues.apache.org/jir

Re: AMQP 1.0 Client for .Net/C# (Apache NMS, QPid) available?

2013-10-31 Thread Gordon Sim
On 10/31/2013 10:30 AM, Timothy Bish wrote: It looks like there's something here: http://qpid.apache.org/components/qpid-wcf/index.html The WCF component only speak AMQP 0-10 I'm afraid. However the Qpid.Messaging .NET client can speak AMQP 1.0 (you need to specify the value of the 'protocol'

Re: AMQP 1.0 Client for .Net/C# (Apache NMS, QPid) available?

2013-10-31 Thread Gordon Sim
On 10/31/2013 10:30 AM, Timothy Bish wrote: We welcome contributions so if you want to work on a NMS client for AMQP we'd love to see that. https://issues.apache.org/jira/browse/AMQNET-454

Re: AMQP 1.0 Client for .Net/C# (Apache NMS, QPid) available?

2013-11-01 Thread Gordon Sim
On 11/01/2013 07:08 AM, Tom_Z wrote: In addition I've learned from http://qpid.2158936.n2.nabble.com/where-is-the-API-documents-for-net-client-td5840918.html#a5842572 and http://qpid.apache.org/components/index.html#messaging-apis that - Qpid WCF client seems to be obsolete(?) and only speaks A

Re: Does AMQP supports ActiveMQ failover options in URL ??

2013-11-18 Thread Gordon Sim
No, I don't believe there is any AMQP 1.0 client that supports specific ActiveMQ failover options. What options are available depends on the specific client used (AMQP is a protocol, not an implementation). [Of the 1.0 clients that I myself have tested: The current Qpid JMS 1.0 client does n

Re: Does AMQP supports ActiveMQ failover options in URL ??

2013-11-18 Thread Gordon Sim
On 11/18/2013 03:14 PM, xbhanu wrote: So ActiveMQ failover://() will not work with ActiveMQ? right ? -- failover://(amqp://host:port) will not work ? (it anyways gives me malformedURL exceptions) The ActiveMQ failover transport syntax won't work with the QPid AMQP 1.0 JMS client. I am using

Re: Does AMQP supports ActiveMQ failover options in URL ??

2013-11-19 Thread Gordon Sim
On 11/19/2013 05:18 AM, xbhanu wrote: Using the qpid implemented client with JNDI and creating a connection factory with something like connectionfactory.qpidConnectionfactory = amqp://guest:guest@clientid/test?brokerlist='tcp://localhost:5672' (as provided in qpid client examples) still doesnt w

Re: Does AMQP supports ActiveMQ failover options in URL ??

2013-11-19 Thread Gordon Sim
On 11/18/2013 06:30 PM, xbhanu wrote: Am I correct to assume that Apache Qpid is 100% AMQP compliant but ActiveMQ is still in the process of adapting AMQP? I wouldn't put it in those terms. Qpid is really an umbrella project for several different components (as is ActiveMQ) many/most of which

Re: Does AMQP supports ActiveMQ failover options in URL ??

2013-11-20 Thread Gordon Sim
On 11/20/2013 12:25 PM, xbhanu wrote: How does AMQP fare against Openwire in terms of performance and latency ? AMQP and Openwire are protocols. Throughput and latency can only be measured against implementations. So while in theory, aspects of a protocol can impact performance in different w

Re: Query regarding OpenWire/STOMP/AMQP

2013-11-28 Thread Gordon Sim
On 11/28/2013 06:33 AM, Robert Davies wrote: There’s no reason that there aren’t other clients for OpenWire other than we hadn’t got round to it (there’s been little demand for it as we’ve has STOMP - so its not as if there hasn’t been at least some connectivity). As ActiveMQ now supports AMQP

Re: Problems in publishing from AMQP-JMS Bridge

2013-12-02 Thread Gordon Sim
On 11/29/2013 07:01 AM, xbhanu wrote: Hi, I am publishing simple Object messages from the JMS-AMQP bridge(qpid-amqp-1-0-client-jms-0.22.jar) to a Python AMQP client (the SWIG proton wrapper from Qpid). The problem is that serializing/deserializing is not happening properly. Basically I am sendi

Re: Problems in publishing from AMQP-JMS Bridge

2013-12-03 Thread Gordon Sim
On 12/03/2013 05:41 AM, xbhanu wrote: Yes, But my point is that a similar AMQP message(a j.u.Date instance) sent by a java client written with the Messenger API (proton-j) are successfully interpreted by the AMQP Python/Perl client. Even sending a list or map from proton-j java client works so wh

Re: Problems with the AMQP python messenger API

2013-12-12 Thread Gordon Sim
On 12/12/2013 01:33 PM, xbhanu wrote: Yes, and infact i am doing exactly this. But the accept call has no effect it seems. You also need to set the incoming message window, e.g. messenger = Messenger() messenger.start() messenger.incoming_window = 10 messenger.subscri

Re: Problems with the AMQP python messenger API

2013-12-13 Thread Gordon Sim
On 12/12/2013 04:07 PM, xbhanu wrote: One more thing, I dont think there is a concept of durable topic subscriptions in AMQP ? True right ? Well, AMQP doesn't explicitly define 'topics'. It does however define distribution modes. More importantly it covers how the lifecycle of a 'terminus' ca

Re: ActiveMQ / AMQP / PHP

2014-08-06 Thread Gordon Sim
On 08/06/2014 06:02 PM, Frizz wrote: Hi there, I'm trying to access ActiveMQ (5.10) via AMQP in PHP code. Is there some sample code for that? I use a AMQPConnection in PHP to connect, but get a strange error message: 'PhpAmqpLib\Exception\AMQPRuntimeException' with message 'Error reading data.