Re: Easiest way to (pre-)fill/add new msgs into an ActiveMQ server?

Hi Ben, Like Thorsten and Jaskirat said you have a few options but you can also run any of those samples shipped with ActiveMQ as well. Have a look at $AMQ_HOME/example and you can easily run an Ant script with the options described on the build.xml file where you can configure the broker URL,

Re: Closing a Message Group

Hope this helps, -- Marcelo Jabali Sr. Solutions Consultant FuseSource Web: fusesource.com Skype/Twitter: mjabali Blog: http://marcelojabali.blogspot.com On Dec 12, 2011, at 11:09 AM, Raul Kripalani wrote: Hi there, There seems to be a contradiction in the AMQ documentation regarding the closure

Re: Enabling JMX in code snippet

brokers and they both seem to be working fine. When trying local process I can see a Broker process and when trying remote using the following service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi it also connects correctly. Hope this helps, -Marcelo -- Marcelo Jabali Sr. Solutions Consultant

Re: Understanding basic config

Mohit, ActiveMQ has several transport protocols available (connection URLs for a client to connect to a broker). TCP - is used when clients connect to the broker using a TCP socket. VM - is used when you are embedding the broker in your app (client and broker running on the same JVM) and you

Re: Understanding basic config

/configuring-transports.html On Oct 1, 2011, at 10:31 AM, Mohit Anchlia wrote: On Sat, Oct 1, 2011 at 12:06 AM, Marcelo Jabali mjab...@fusesource.com wrote: Mohit, ActiveMQ has several transport protocols available (connection URLs for a client to connect to a broker). TCP - is used

Re: addNetworkConnector - JMX Error

Have you tried setting the connector's name? e.g. connector.setName(myNetworkConnector); The tests available at https://issues.apache.org/jira/browse/AMQ-3348 may also give you some hints to get this working. Hope this helps, -Marcelo On Sep 22, 2011, at 1:52 PM, sub3 wrote: Hi, I want

Re: How to create connections to different brokers by using one ConnectionFactory?

I haven't used myself but maybe the Fanout Transport could help you here. Take a look on http://activemq.apache.org/fanout-transport-reference.html to see if that helps. Thanks, -Marcelo On Sep 14, 2011, at 8:09 PM, Jason Whaley wrote: With a single connection factory you can only use the

Re: Long time persistence service

That seems to be caused by a flow control condition. Take a look on this: http://activemq.apache.org/producer-flow-control.html Hope this helps, -Marcelo On Jul 25, 2011, at 11:37 AM, pol_ice wrote: Hi there, Let me first describe the way I am planning to use activemq for my service.

Re: Upgrade from 5.3 to 5.5

Hi Greg, The empty xmlns= seems to be causing that exception. Hope this helps, -Marcelo On Jul 5, 2011, at 10:47 AM, Robillard, Greg L wrote: I am running the following plugin on 5.3. plugins bean id=ActiveMqSecurity

Re: How to set message expiry in activemq

in context: http://activemq.2283324.n4.nabble.com/How-to-set-message-expiry-in-activemq-tp3580498p3580498.html Sent from the ActiveMQ - User mailing list archive at Nabble.com. -- Marcelo Jabali Sr. Solutions Consultant FuseSource M: 978 729 6239 O: 619 464 2595 Web: fusesource.com Skype/Twitter

Re: Monitoring of expired messages in activemq

Anurag, The following should give all you need: http://activemq.apache.org/advisory-message.html -Marcelo On Jun 7, 2011, at 6:04 PM, agujral wrote: Hi All, I am setting expiry of messages in activemq in my deployment. How can I monitor how many messages are getting expired .

Re: Exception Channel was inactive for too long

Hi Anurag, I'm not sure how you've configured the ActiveMQ transport but take a look on this [1] and see if that helps. It clearly states that setting maxInactivityDuration to 0 would disable inactivity monitoring. But, you may want to set to some other value. [1]

Re: Keeping the messages in a queue or topic during a day

Composite destinations may help a bit in this case too. Something like: String brokerURI = ActiveMQConnectionFactory.DEFAULT_BROKER_URL; ConnectionFactory connectionFactory = new ActiveMQConnectionFactory(brokerURI); Connection connection = connectionFactory.createConnection();

Re: how to set pendingSubscriberPolicy for an embedded broker

Hi Steve, Take a look on org.apache.activemq.broker.region.policy.PolicyEntry (http://activemq.apache.org/maven/5.3.1/activemq-core/apidocs/org/apache/activemq/broker/region/policy/PolicyEntry.html) Hope this helps, -Marcelo On May 19, 2011, at 12:17 PM, Steve Angelovich wrote: I have an

Re: how to set pendingSubscriberPolicy for an embedded broker

()) ; //broker.setDestinationPolicy(destinationPolicy) ; Thanks again for the help, Steve On 05/19/2011 01:40 PM, Marcelo Jabali wrote: Hi Steve, Take a look on org.apache.activemq.broker.region.policy.PolicyEntry (http://activemq.apache.org/maven/5.3.1/activemq-core/apidocs/org/apache/activemq

Re: alternatives to request response pattern

Steve, You can use a queue browse to do that. Basically, you send a message to the queue with the information you need. Then the client will browse the queue looking for the desired information. When you need to update that information just consume the message and publish a new one. You can