Re: [Fixed] Programatically setting up a proxying broker

2017-08-04 Thread Tim Bain
Ah, makes sense. Thanks for clarifying. Tim On Aug 4, 2017 7:35 AM, "Clebert Suconic" wrote: Oh.. duh... apologize... I misread this through the iPhone yesterday.. I thought it was referring to Proxy to the connections: https://github.com/apache/activemq-artemis/pull/1293 On Fri, Aug 4, 2017

Re: [Fixed] Programatically setting up a proxying broker

2017-08-04 Thread Clebert Suconic
Oh.. duh... apologize... I misread this through the iPhone yesterday.. I thought it was referring to Proxy to the connections: https://github.com/apache/activemq-artemis/pull/1293 On Fri, Aug 4, 2017 at 9:08 AM, Tim Bain wrote: > Clebert, which feature were you referring to? > > On Aug 3, 2017 9

Re: [Fixed] Programatically setting up a proxying broker

2017-08-04 Thread Tim Bain
Clebert, which feature were you referring to? On Aug 3, 2017 9:44 PM, "Clebert Suconic" wrote: > There is a pending pull request in activemq artemis to add that feature. > > On Thu, Aug 3, 2017 at 11:51 AM Mark Raynsford < > list+org.apache.activ...@io7m.com> wrote: > > > On 2017-08-03T08:57:38

Re: [Fixed] Programatically setting up a proxying broker

2017-08-04 Thread Tim Bain
Ah, that makes sense. Those class names are a little confusing, and so is the term "discovery" since it sounds like it should mean "runtime discovery of dynamic information" but static discovery actually means "discovery from a config file." Since it sounds like you aren't planning to continue usi

Re: [Fixed] Programatically setting up a proxying broker

2017-08-03 Thread Clebert Suconic
There is a pending pull request in activemq artemis to add that feature. On Thu, Aug 3, 2017 at 11:51 AM Mark Raynsford < list+org.apache.activ...@io7m.com> wrote: > On 2017-08-03T08:57:38 -0600 > Tim Bain wrote: > > > > My question was why you needed to subclass it in the first place. > > Ah, t

Re: [Fixed] Programatically setting up a proxying broker

2017-08-03 Thread Mark Raynsford
On 2017-08-03T08:57:38 -0600 Tim Bain wrote: > > My question was why you needed to subclass it in the first place. Ah, that was down to an error in thinking on my part when looking at the available network connectors. It went something like this: "Hm, need a NetworkConnector. Don't seem to need '

Re: [Fixed] Programatically setting up a proxying broker

2017-08-03 Thread Tim Bain
My question was why you needed to subclass it in the first place. On Aug 3, 2017 6:51 AM, "Mark Raynsford" wrote: > On 2017-08-03T06:29:48 -0600 > Tim Bain wrote: > > > OK, glad to hear that it's working properly now. > > > > But I'm surprised to hear that you think the existing classes don't d

Re: [Fixed] Programatically setting up a proxying broker

2017-08-03 Thread Mark Raynsford
On 2017-08-03T06:29:48 -0600 Tim Bain wrote: > OK, glad to hear that it's working properly now. > > But I'm surprised to hear that you think the existing classes don't do what > you want; what are you looking for that you couldn't get? Sorry, that was phrased poorly. What I meant was that the a

Re: [Fixed] Programatically setting up a proxying broker

2017-08-03 Thread Tim Bain
OK, glad to hear that it's working properly now. But I'm surprised to hear that you think the existing classes don't do what you want; what are you looking for that you couldn't get? Tim On Aug 3, 2017 4:38 AM, "Mark Raynsford" wrote: > I discovered what the problem was. > > I'd created my own

Re: [Fixed] Programatically setting up a proxying broker

2017-08-03 Thread Mark Raynsford
I discovered what the problem was. I'd created my own subclass of NetworkConnector, because none of the existing implementations seemed to be what I needed. It turns out that I actually needed to use DiscoveryNetworkConnector; the abstract NetworkConnector base class doesn't actually do any useful

Re: Programatically setting up a proxying broker

2017-08-02 Thread tpavelka
http://activemq.2283324.n4.nabble.com/Programatically-setting-up-a-proxying-broker-tp4729043p4729160.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Programatically setting up a proxying broker

2017-08-02 Thread Mark Raynsford
'Ello. On 2017-08-02T00:19:48 -0700 tpavelka wrote: > I know nothing about static destinations but one thing I noticed in your > Github code: when you add network and transport connectors, you do not start > them. I tested this with one of my sample ActiveMQ programs and if I don't > start the c

Re: Programatically setting up a proxying broker

2017-08-02 Thread tpavelka
o use: org.apache.activemq.broker.TransportConnector#start and org.apache.activemq.network.NetworkConnector#start HTH, Tomas -- View this message in context: http://activemq.2283324.n4.nabble.com/Programatically-setting-up-a-proxying-broker-tp4729043p4729158.html Sent from the ActiveMQ - User ma

Re: Programatically setting up a proxying broker

2017-08-01 Thread Mark Raynsford
'Ello. For the purposes of keeping everything consistent, I've pushed my example program to a GitHub repository: https://github.com/io7m/activemq-examples See: https://github.com/io7m/activemq-examples/blob/develop/src/main/java/com/io7m/activemq/examples/ForwardingServers.java I've also

Re: Programatically setting up a proxying broker

2017-07-31 Thread Tim Bain
OK, no subscriber on the proxy broker certainly explains why no messages are making it to the main broker, so let's dig into that. Do you see (via JMX) a networkConnector between the two brokers? And do you see advisory messages passing from the main broker to the proxy when a subscriber connects?

Re: Programatically setting up a proxying broker

2017-07-31 Thread Mark Raynsford
Still no luck, unfortunately. This is the test program I'm using now: http://ataxia.io7m.com/2017/07/31/ForwardingServers.java I use setDynamicallyIncludedDestinations() with a wildcard topic ">". I still see no subscriptions on the proxy broker from the receiver broker. -- Mark Raynsford | h

Re: Programatically setting up a proxying broker

2017-07-31 Thread Mark Raynsford
On 2017-07-31T06:55:07 -0600 Tim Bain wrote: > People do what you're trying to do, so this is a use case that works (or at > least, did work at some point in the past). Right. > My advice when message forwarding isn't working in a network of brokers is > to use JMX to figure out what's going on

Re: Programatically setting up a proxying broker

2017-07-31 Thread Tim Bain
People do what you're trying to do, so this is a use case that works (or at least, did work at some point in the past). My advice when message forwarding isn't working in a network of brokers is to use JMX to figure out what's going on in each broker. I'd start with the proxy broker and confirm th

Re: Programatically setting up a proxying broker

2017-07-31 Thread Mark Raynsford
Hm, is anyone out there actually using ActiveMQ in this manner? The reason I'm doing this is that I'm considering deploying message brokers in a manner analogous to the way in which one would typically deploy mail servers: Programs on a server communicate with an MTA (such as Postfix or qmail) on

Re: Programatically setting up a proxying broker

2017-07-30 Thread Mark Raynsford
Slightly shorter and simpler example here: http://ataxia.io7m.com/2017/07/30/ForwardingServers.java I've tried to step through the broker code in a debugger, but I'm not familiar with the ActiveMQ sources, and regardless it's pretty tough to use a debugger to find problems of the class "nothing

Re: Programatically setting up a proxying broker

2017-07-30 Thread Mark Raynsford
On 2017-07-29T18:57:30 -0600 Tim Bain wrote: > If you use the TCP transport for the networkConnector between the brokers, > does it work? I've got a half-memory of a mailing list post where someone > found that the NIO transport didn't work in a networkConnector, but I can't > find it now so it's

Re: Programatically setting up a proxying broker

2017-07-29 Thread Tim Bain
If you use the TCP transport for the networkConnector between the brokers, does it work? I've got a half-memory of a mailing list post where someone found that the NIO transport didn't work in a networkConnector, but I can't find it now so it's possible I'm misremembering. Tim On Jul 29, 2017 2:0

Programatically setting up a proxying broker

2017-07-29 Thread Mark Raynsford
'Lo. I'm experimenting with configuring a broker P that will simply forward all messages to a remote broker R. There will not be any subscribers directly accessing P (but multiple producers will send messages to queues and topics on P to be forwarded to R). I have the following small example prog