HTTP Tunneling for Embedded Broker

I've the following use case: According to ActiveMQ docs and code, it is possible to open http transport from broker. Jetty server is started inside HttpTransportServer. Listener from HttpTransportServer is registered in HttpTunnelServlet, which is started inside Jetty. I have an embedded broker.

Re: JMS Transactions and losing the connection

On Wed, Oct 28, 2009 at 5:10 PM, Drizzt321 wrote: > > What will happen if a Session is transacted via JMS Transactions, and there > is some kind of network hiccup that causes the Connection to be lost/reset. > Will the transaction automatically be rolled back? Yes. > Do I need to call > rollback

Re: Why can't a message be routed to a broker that has seen it before?

The network ttl will prevent the continuous bouncing, so I am not concerned about that. I will keep my eye out for duplicates. bsnyder wrote: > > On Wed, Oct 28, 2009 at 4:28 PM, Elliot Barlas > wrote: >> >> I commented out the NetworkBridgeFilter.java if statement mentioned in my >> original

Re: Why can't a message be routed to a broker that has seen it before?

On Wed, Oct 28, 2009 at 4:28 PM, Elliot Barlas wrote: > > I commented out the NetworkBridgeFilter.java if statement mentioned in my > original post and it seems to be working as expected.  Do you know of any > harmful side affects this may cause? Well, there's potential for messages to just const

JMS Transactions and losing the connection

What will happen if a Session is transacted via JMS Transactions, and there is some kind of network hiccup that causes the Connection to be lost/reset. Will the transaction automatically be rolled back? Do I need to call rollback on the new Session? If the broker goes down (shutdown, or JVM term

Re: Why can't a message be routed to a broker that has seen it before?

I commented out the NetworkBridgeFilter.java if statement mentioned in my original post and it seems to be working as expected. Do you know of any harmful side affects this may cause? bsnyder wrote: > > On Wed, Oct 28, 2009 at 12:52 PM, Elliot Barlas > wrote: >> >> It seems that AMQ has a ha

Re: CMS: problems installing 3.0.1

duh.. that was a typo.. thanks a lot Tim. Timothy Bish wrote: > > On Wed, 2009-10-28 at 11:18 -0700, nmittal wrote: >> Hi, >> I am trying to install CPP version 3.0.1 after download and untaring... I >> do >> >> # ./configure --with-apr=/usr/local/apr/bin/apr-1-config >> --with-apr-util=/usr/l

Re: CMS: problems installing 3.0.1

On Wed, 2009-10-28 at 11:18 -0700, nmittal wrote: > Hi, > I am trying to install CPP version 3.0.1 after download and untaring... I do > > # ./configure --with-apr=/usr/local/apr/bin/apr-1-config > --with-apr-util=/usr/local/apr/bin/apr-1-config > # make Try ./configure --with-apr=/usr/local/apr

CMS: problems installing 3.0.1

Hi, I am trying to install CPP version 3.0.1 after download and untaring... I do # ./configure --with-apr=/usr/local/apr/bin/apr-1-config --with-apr-util=/usr/local/apr/bin/apr-1-config # make however it fails with the following error... libtool: link: g++ -ansi -pedantic -DLINUX=2 -D_REENTRANT

Re: making queues findable from InitialContext.lookup(name)

Hi Gary, that was a great idea, and I hadn't tried it yet, but ActiveMQ doesn't seem to like having anything else in the context path. I get: [WARN] TcpTransportFactory - path isn't a valid local location for TcpTransport to use string: "/dynamicQueues/">java.lang.NumberFormatException: Fo

Re: Why can't a message be routed to a broker that has seen it before?

On Wed, Oct 28, 2009 at 12:52 PM, Elliot Barlas wrote: > > It seems that AMQ has a hard constraint that a message cannot be routed to a > broker that has seen it before. > > NetworkBridgeFilter.java > >        if (contains(message.getBrokerPath(), networkBrokerId)) { >            if (LOG.isTraceEn

Re: Out of Memory on 5.3

Hi Mitch, yeah, I said in thread I was referring to, that it is working with "regular" stomp connector. I started investigating AMQ-2440 patch the other day, should be have something soon. Cheers -- Dejan Bosanac - http://twitter.com/dejanb Open Source Integration - http://fusesource.com/ Active

Re: Out of Memory on 5.3

So we turned off stomp+nio and went back to plain old stomp and so far it's working fine. New(IO) isn't always better, I guess :-) Seems like maybe it's this issue -> https://issues.apache.org/activemq/browse/AMQ-2440 afei wrote: i have same problem http://www.nabble.com/file/p26093204/a

Why can't a message be routed to a broker that has seen it before?

It seems that AMQ has a hard constraint that a message cannot be routed to a broker that has seen it before. NetworkBridgeFilter.java if (contains(message.getBrokerPath(), networkBrokerId)) { if (LOG.isTraceEnabled()) { LOG.trace("Message all ready routed on

Re: Set up multiple network connector in the same instance ActiveMQ

don't think wildcards work for statically included destinations as a destination name needs to be known upfront to setup up the forwarding consumer. 2009/10/28 titexe > > Thank you for your response; > > is one question which I can not find the answer : > > it's possible to configure network con

Re: sendFailIfNoSpace=true, no JMSException for Producer

you need to turn off producer flow control so that you will be blocked by the queue and also have your producer use sync send (as it defaults to async sending for non persistent or non transactional messages) so that you can catch any exception. 2009/10/28 moreno9000 > > Hi all, > I'm using AMQ

Re: Cannot receive from Virtual Topic's consumer queue

Sorry, nevermind, it works great now. PEBKAH. I was just not starting the connection that I created my queue session out of. -- View this message in context: http://www.nabble.com/Cannot-receive-from-Virtual-Topic%27s-consumer-queue-tp26093937p26096429.html Sent from the ActiveMQ - User mailing

Re: Cannot receive from Virtual Topic's consumer queue

What is your broker configuration (so that I may compare it with mine and see what I'm missing)? -- View this message in context: http://www.nabble.com/Cannot-receive-from-Virtual-Topic%27s-consumer-queue-tp26093937p26096214.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: Cannot receive from Virtual Topic's consumer queue

Nope, that was my bad. Sorry for the confusion. Your code should work. I tried something similar with ActiveMQ 5.3 and it worked fine for me. Here's my code, which is using JNDI. MessageListener listener = new MessageListener() { @Override public void onMes

Re: Installing Activemq-cpp in HP-UX

On Mon, 2009-10-26 at 22:37 -0700, Radha Manickam wrote: > Hi Tim, > > I have attached the config.log. > > Radha. >From what I've read about the HP UX pthreads impl it sounds as if there's some problems with the way they've defined the pthread_create which break autoconfs tests. You could modif

Re: Set up multiple network connector in the same instance ActiveMQ

Thank you for your response; is one question which I can not find the answer : it's possible to configure network connector (staticallyIncludedDestinations , excludedestination)to allow the queues that their names begin with "A. *" ? Thank you in advance, titexe Gary Tully wrote: > > yea,

Re: Cannot receive from Virtual Topic's consumer queue

I forgot to mention that once the consumer queues have been created, the messages will be forwarded on to the queues, even if the corresponding consumers are not active. One option is to have the broker create the queues on start up. Joe http://www.ttmsolutions.com Joe Fernandez wrote: > > If

Re: Cannot receive from Virtual Topic's consumer queue

Joe Fernandez wrote: > > If you activate your consumer after the messages have been published to > the topic, then the messages will not be forwarded on to the consumer's > queue. > Sorry, but I thought I'm sending to the topic after setting up the consumer, just as you suggest. What do yo

Re: Cannot receive from Virtual Topic's consumer queue

If you activate your consumer after the messages have been published to the topic, then the messages will not be forwarded on to the consumer's queue. As an alternative, you might want to check out Camel to implement a similar messaging pattern. http://camel.apache.org/recipient-list.html J

sendFailIfNoSpace=true, no JMSException for Producer

Hi all, I'm using AMQ 5.3 with a Producer that sends 10.000 very small msg (1kb for msg, no persistence) to a queue. No consumers are listening to the queue. In activemq.xml this is System Usage configuration:

Re: Cannot receive from Virtual Topic's consumer queue

Just want to add that I also tried attaching JConsole and looking at the Queue/Topic MBeans. It showed that the consumer queue had 0 dispatch and enqueue count. The virtual topic had 1 enqueue count, 0 dispatch count. So apparently the message isn't getting relayed from the topic to the queue?

Cannot receive from Virtual Topic's consumer queue

Hello, I'm trying to use Virtual Topics for the first time (and I'm relatively new to ActiveMQ). I've tried to follow the instructions on the virtual destinations page and also looked at VirtualTopicPubSubTest in activemq-core unit tests and tried to follow it as closely as I could see. This is

Re: Out of Memory on 5.3

i have same problem http://www.nabble.com/file/p26093204/aa.jpg aa.jpg themitchy wrote: > > This is what we've done to tune so far: > > - UseDedicatedTaskRunner=false > - flow control is off > - stomp transport uses transport.closeAsync=false > > I agree that it is because

Re: Set up multiple network connector in the same instance ActiveMQ

yea, see http://activemq.apache.org/networks-of-brokers.html#NetworksofBrokers-NetworkConnectorPropertiesdynamicallyIncludedDestinations And to configure mutliple connectors, just add them in and give them different "name" attributes. 2009/10/28 titexe > > Hello everybody, > > it's possible to

Re: making queues findable from InitialContext.lookup(name)

think you may have to modify the source to achieve what you want here. Is the initial context used for destination lookup parametrised? I wonder if a solution would be to have the provider url contain the context in its path. so something like: tcp://localhost:61616/dynamicQueues such that the r

Set up multiple network connector in the same instance ActiveMQ

Hello everybody, it's possible to configure network connector to allow the queues that their names begin with "A. *" ? and to configure multiple network connector for the same broker? if yes how setup this ;) Thank you in advance titexe -- View this message in context: http://www.nabble.com/

Re: 5.3 transportConnector strictly - network of brokers

yea, that indicates that the listen should be on all network interfaces. Previously this was the behavior if "localhost" was used which was a security hole. For a discussion see: https://issues.apache.org/activemq/browse/AMQ-2094 2009/10/27 michaelrobinson > > Not sure if this was intended or no

ActiveMQ Queue "frozen"

Hello, we are using ActiveMQ 5.3. Application is using Spring JMSTemplate (DefaultMessageListenerContainer) configured like this: The container has started, few messages are delivered. When things go wr