Hi, reading the ActiveMQ documentation (we are using the 5.3 release) I find a section about the possibility of using a JDBC persistence adapter with ActiveMQ. What are the bennefits? Does it provide any gain in performance or reliability? When should I use it? ...
For a production environment, is Apache Geronimo better for applications that uses ActiveMQ, Derby, Solr? ...
I create my consumer (in C# using the NMS library) as so: ConnectionFactory factory = new ConnectionFactory(_mqServer); _con = factory.CreateConnection(); _con.Start(); _session = _con.CreateSession(AcknowledgementMode.Transactional); _queue = _session.GetQueue(_mqQueue); _consumer = _sess...
I need the queue to enforce no-duplicate policy. Is it possible? If so , how? (I've been googling for hours... ) Edit: The ActiveMQSession implementation has this lines: // transform to our own message format here ActiveMQMessage msg = ActiveMQMessageTransformation.transformMessage(message, connection); ...
I'm using activeMQ 5.3 to send messages to a flex client via blazeds 3.2. When the client connects for the first time, I can see the subscriptions to the activeMQ broker being made. However, after I kill the browser that runs the client the subscriptions remain open even though no messages are being consumed anymore. This finally resul...
Hi, I'm running jetty-6.1.7 and I've got an ActiveMQConnectionFactory that I'd like to reference in my spring configuration via a JNDITemplate. My jetty.xml configuration is vanilla: <New id="connectionFactory" class="org.mortbay.jetty.plus.naming.Resource"> <Arg>jms/connectionFactory</Arg> <Arg> <New class="org.apach...
I'm having a hardtime trying to install pyactivemq (link) on my osx leopard. Following a tutorial (in portuguese) on compiling it ends up ok, but when I run the tests i receive only a crypt message: "Fatal Python error: Interpreter not initialized (version mismatch?)" There is not much information on the web about using pyactivemq on ...
I have a C# publisher and subscriber that talk to each other using ActiveMQ and NMS. Everything works fine, except I have no way to know when ActiveMQ goes down. This is particularly bad for the consumer. They stop getting data, but aside from the fact that data stops showing up, no errors or events are raised. Is there a way using NMS(...
I am trying to use the Apache.NMS.WCF bindings for a WCF application and get the following error - Contract requires TwoWay (either request-reply or duplex), but Binding 'NmsBinding' doesn't support it or isn't configured properly to support it. My system.service model looks like this - <bindings> <nmsBinding> ...
It appears that the ActiveMQ FuseSource Stomp PHP client can't handle messages larger than 1024 bytes. The code is as follows in Stomp.php: $rb = 1024; $data = ''; $end = false; do { $read = fread($this->_socket, $rb); if ($read === false) { $this->_reconnect(); return $this->readFrame();...
I have a durable consumer to a remote JMS queue in embedded Camel routing. Is it possible to have this kind of routing with master-slave configuration? Now it seems that the Camel routes are started and activated already when slave ActiveMQ is started and not when the actual failover happens. Now it causes the slave instance to receive ...
'm trying to do simple pub/sub with ActiveMq. I can get it all working fine, but the subscriber disconnects after about 30 seconds. I've looked for a timeout type of value I can change but nothing seems to be working. Here is the subscriber: using System; using Apache.NMS; using Apache.NMS.ActiveMQ; using Apache.NMS.ActiveMQ.Commands; ...
I am trying to produce a proof of concept shipping logging from Log4J through JMS using the log4J JMSAppender. I have tried ActiveMQ and the example supplied with it. I have torn this example apart, and made it more generic and compatible with multiple platforms. It looks like I have it all plumbed up OK as I can see a connection to the...
I want to use ActiveMQ as a message broker communicating between a C++ component and a Java component in two process. Eg. C++ component is the publisher and the Java component is the subscriber(there maybe multiple subscribers). I look at ActiveMQ website and it mentions the tool OpenWire and ActiveMQ-CPP. However, all the examples on th...
I have a local ActiveMQ broker which is on an unreliable internet connection, and also a remote ActiveMQ broker in a reliable datacenter. I have already sorted out a "store and forward" setup so that outgoing messages are sent to the remote broker when the Internet connection is available. That alone works great, but when messages are o...
Hi, if I use the DefaultMessageListenerContainer of Spring to recieve JMS messages, I don't get JMS messages redelivered, even if I set sessionAcknowledgeMode to 2. In case of a RuntimeException within the onMessage() of my JavaBean, the message is not acknowledged within the JMS provider (ActiveMQ), it stays as pending in the queue. B...
We have an issue in ActiveMQ where we have a huge number of messages not dropping off topics. The topics are set to non-persistent, non-durable. Our Activemq.xml file is <beans> <broker xmlns="http://activemq.apache.org/schema/core" useJmx="false" persistent="false"> <!-- <persistenceAdapter> <journaledJDBC journalLogFile...
I'd like to use ActiveMQ to connect python service with C# clients. Is there a way to specify failover connection in C# (openwire) and python (Stomp)? The ActiveMQ will be configured Shared File System Master Slave. ...
I'm trying to determine my options for clustering my ServiceMix 3.3.1/Camel 2.1/AMQ 5.3 application. I'm performing high volume message processing and I need to cluster for high availability and horizontal scalability. Here is basically what my application does...HTTP->QUEUE->PROCESS->DATABASE->TOPIC from("jetty:http://0.0.0.0/inbound...
I have a JMS topic on an ActiveMQ network of brokers cluster (aka distributed topic). I have an external JMS consumer (Weblogic portal) that needs to subscribe to this topic and get all the messages sent to it (across all brokers). If the consumer subscribes to the topic on one of the brokers, it will only get the subset of the message...