August 17, 2010 - betasoft is pleased to announce release 2.4 of the
Delphi and Free Pascal library Habari ActiveMQ Client.
Home Page:
http://www.mikejustin.com/habari_activemq.html
Online Resources:
Habari ActiveMQ Client - Getting Started (PDF):
http://www.mikejustin.com/download/HabariActiv
I set it up as documented http://activemq.apache.org/pure-master-slave.html
the slave comes up fine
but each time something actually tries to connect to the master broker, I
get this error message:
I only get these messages if I attach a slave into the mix. I don't
need anything complica
I get error messages when it first creates the tables, when then I get a
message that it can't create the lock.
I'm trying to use a mysql database as a shared storage mechanism.
Java Runtime: Sun Microsystems Inc. 1.6.0
/usr/lib/jvm/java-1.6.0-openjdk-1.6.0.0.x86_64/jre
Heap sizes: current
i have a network of 2 brokers, let's call them "Remote" and "Central", running
on ActiveMQ 5.0.3, in a store-and-forward configuration. i inherited this
setup, i did not design it, but it seems like a generally solid configuration.
On the Remote broker, there are topics (e.g. "org.nwea.topics.li
I'm using ActiveMQ 5.3.2 with Websphere 6.1 and I am have trouble getting
rollbacks to work. My messages are marked as PERSISTENT. My rollbacks just
move the message to the DLQ. I would like the message to be redelivered to
the original queue using a maximumRedeliveries set to 4. After the 4th
I'd initially outlined a problem here, and chose to see if I could get the
retroactive consumer support to work.
http://old.nabble.com/Coping-with-forgetful-subscribers-tp29292239p29294876.html
I've got a broker with a configured persistenceAdapter set up with a
timedSubscriptionRecoveryPolicy
On Mon, 2010-08-16 at 09:45 -0700, cppdeveloper wrote:
> >From debugging the StompWireFormat class, I see that the CONNECT frame is
> marshalled and sent from ActiveMQ-CPP to the OpenMQ broker, and OpenMQ
> starts the connection and send back a frame to the ActiveMQ-CPP client. Then
> the StompWire
>From debugging the StompWireFormat class, I see that the CONNECT frame is
marshalled and sent from ActiveMQ-CPP to the OpenMQ broker, and OpenMQ
starts the connection and send back a frame to the ActiveMQ-CPP client. Then
the StompWireFormat class tries to unmarshal the message in the function:
BenXS wrote:
>
> Whenever a new JMS msg is arriving in a queue/topic where a MDbean is
> listening (through "onMessage()").
> Is there always a new Bean instance created and used for handling this JMS
> msgs?
>
> Or can it be that an already existing Bean instance is used for handling
> the nex
On Mon, 2010-08-16 at 09:31 -0500, Devin Venable wrote:
> I would be happy to contribute, assuming I manage to get this sample up and
> working.
>
> Upon running, I get this exception:
>
> Unhandled Exception: Apache.NMS.NMSConnectionException: No
> IConnectionFactory implementation found for con
I would be happy to contribute, assuming I manage to get this sample up and
working.
Upon running, I get this exception:
Unhandled Exception: Apache.NMS.NMSConnectionException: No
IConnectionFactory implementation found for connection URI:
activemq:tcp:/carbon:61616
at Apache.NMS.NMSConnectionF
On Mon, 2010-08-16 at 09:08 -0500, Devin Venable wrote:
> Those are perfect. By the way, if you download zipped source for the latest
> release (Apache.NMS-1.3.0-src.zip), those test files are not present. It
> would be helpful to include them and to update the apache web site (
> http://activemq
Those are perfect. By the way, if you download zipped source for the latest
release (Apache.NMS-1.3.0-src.zip), those test files are not present. It
would be helpful to include them and to update the apache web site (
http://activemq.apache.org/nms/examples.html) to show the examples also.
On Mo
On Mon, 2010-08-16 at 08:42 -0500, Devin Venable wrote:
> I need to whip up some quick examples for some folks I work with who use the
> .NET platform. Unfortunately, there are no short examples posted on the
> site for .NET for either the ActiveMQ or STOMP client.
>
> http://activemq.apache.org/
I need to whip up some quick examples for some folks I work with who use the
.NET platform. Unfortunately, there are no short examples posted on the
site for .NET for either the ActiveMQ or STOMP client.
http://activemq.apache.org/nms/examples.html
I've been working on extracting a simple examp
Whenever a new JMS msg is arriving in a queue/topic where a MDbean is
listening (through "onMessage()").
Is there always a new Bean instance created and used for handling this JMS
msgs?
Or can it be that an already existing Bean instance is used for handling the
next JMS msg as well?
Ben
--
Vie
Thanks for the information. I assume you set a camel route to send the
messages from the queue to a bean and this bean makes a client connection to
MQ? Or are these beans running outside of the Active MQ/Camel environment,
such as a Spring message driven bean?
Thanks,
Craig
sweenma wrote:
>
should not, check out the source:
http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/transport/failover/FailoverTransport.java?view=markup
the reconnect mutex.
On 16 August 2010 13:01, vv wrote:
>
> Can any out of order processing of the Transport Listener
Hello,
I have a active/pasive with NFS shared drive configuration within a network
of brokers and at the receiver end I find this error in logs:
--
...
ERROR JournalPersistenceAdapter - Failed to mark the Journal:
org.apache.activeio.journal.InvalidRecordLocationException: T
Can any out of order processing of the Transport Listener
events(interrupted/resumed) and onMessage callback happen?
i.e. if the link is unstable, and at the same time the producer keeps
sending the messages to the consumer..
vv wrote:
>
> Hi,
>
> Does the TransportListener & the Rx Message L
they will be called from different threads. The interrupted callback
will use the calling thread, the send thread, and the resumedCallback
will be called from the failover transport reconnect thread once the
connection is reestablished. The resumedCallback will only be called
after the interrupted
Hi,
Does the TransportListener & the Rx Message Listener(OnMessage) be called
from the same thread/context? during a transient link down/up event will the
transportInterrupted & transportResumed ,onmessage callback function be
called simulataneously. i.e. can there be a thread switching between t
Thanks, I was able to make it work.
Now i'm having issues loading a route created in java
public class SampleConnectorRoute extends RouteBuilder {
public void configure() {
from("file://c:/app/mdt/dropbox/new").to("file://c:/app/mdt/dropbox/processed");
}
...
I'ev placed the jar un
Hi,
that test tries to run the broker on your desktop machine.
You should checkout
http://jmstester.fusesource.org/documentation/manual/index.html for
performing tests you required.
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveMQ in
Hi John,
TransportListener doesn't monitor if broker is going up and down, but
monitors the status of your client's connection. It's set on the
connection and it only provides a mechanism for the connection to
notify your application on the events. It doesn't require any separate
thread or context
Hi Michael,
maven and pom would do the trick. You basically only need activemq-all
jar or you can get separate jars. A bit outdated list can be found
here (will update it soon)
http://activemq.apache.org/initial-configuration.html#InitialConfiguration-RequiredJARs
but basically, you'll need acti
Hi,
Camel web console has a separate context set in the
webapps/camel/WEB-INF/applicationContext.xml
There's an open issue for this
https://issues.apache.org/activemq/browse/AMQ-2203
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveMQ in
27 matches
Mail list logo
