Hi,
We did the same thing and got installed the activemq-cpp.
But when tried to compile the example program(main.cpp) that is given in the
activemq-cpp/examples, we got the error as follows:
# ./main
Memory fault(coredump)
This is the trace that i got for the core created.
# gdb ./main core
Thank you Brett,
but I turned off async send, according to Gary Tully's first suggestion
(actually Producer's send speed decresead).
The strange matter is that Producer sends sync, but it receives
exception (when queue is full) only via an exception listener.
I don't know if is a AMQ's bug or,
Hi,
web console doesn't support fine-grained authorization at the moment. The
jira would be great for starters, if you can provide a patch it'd be even
better.
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveMQ in Action -
All,
I need some design guidance.
We are implementing a file-transfer system that transfers files from agent
software installed on customer machines into a central network (or to other
agents in P2P fashion) over ActiveMQ. The files are transferred as
binary-chunks [32K size].
We want to
comments inline:
2009/10/29 Brett Humphreys brett.humphr...@gmail.com
Hello all,
I had a question about a policy entry memory limit. I'm creating a broker
with the following attributes:
systemUsage
systemUsage sendFailIfNoSpace=true
memoryUsage
Hi Dan,
for stomp.py, here's the code snippet to do what you need to do:
dest='/queue/test.foo'
conn = stomp.Connection([(HOST,PORT)])
conn.start()
conn.connect()
message = {'field1' : 'foo', 'field2' : 'bar'}
conn.send(message, destination=dest,
On Thu, 2009-10-29 at 19:18 -0700, KVS wrote:
Thanks Tim.
Actually i need those Dlls only for reference..
I downloaded NMS src zip file from web link .. but I didnt find dlls in that
build / bin folder. Could you please give the specified web link to download
.. please.
If you go back
James,
thanks for great example. Shouldn't it be jms-map-json in this example
however?
Dan, you can also take a look at PHP example here
http://stomp.fusesource.org/documentation/php/book.html#_message_transformation
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration -
Hi Dejan,
the stomp.py code only supports this single transformation type at the
moment, and turns the python dict into an XML string as follows:
def __convert_dict(self, payload):
Encode python dictionary as map.../map structure.
xmlStr = map\n
for
config:
policyEntry queue= producerFlowControl=true memoryLimit=5mb
setup:
1 perl stomp producer producing into a queue,
connecting and disconnecting on every post,
rather low frequency of posts (0.5/minute)
0 consumers
behaviour:
works OK until around 68 messages are in the queue (surely
Hello Tim,
I am sorry, I didnt find the reference for
using Spring.Messaging.Nms;
using NMS;
namespace ListenerConsole
According to the Re.Mark Link ..
http://remark.wordpress.com/articles/messaging-with-net-and-activemq/
Please help me in finding those references.
Regards,
KVS
Timothy
Hello Tim,
I am sorry, I didnt find the reference for
using ActiveMQ;
using Spring.Messaging.Nms;
using Spring.Messaging.Nms.Listener;
According to the Re.Mark Link ..
http://remark.wordpress.com/articles/messaging-with-net-and-activemq/
Please help me in finding those references.
On Fri, 2009-10-30 at 06:11 -0700, KVS wrote:
Hello Tim,
I am sorry, I didnt find the reference for
using Spring.Messaging.Nms;
using NMS;
namespace ListenerConsole
According to the Re.Mark Link ..
http://remark.wordpress.com/articles/messaging-with-net-and-activemq/
Please help
Is my issue similar to this one?
https://issues.apache.org/activemq/browse/AMQ-1022 AMQ-1022
In 1022, error was due to a permission (to write on a queue) problem,
in my case error is due to a queue full problem,
but in both cases producer receives an exception only in an asynchronous way
Hi Tim, as suggested, I added the lines but when I do a make I get the
following errors... (the same code built fine with 2.2.5
$ make
make: Warning: File `../Libraries/ActiveMQ/activemq.cpp' has modification
time 7 s in the future
g++ -g -ggdb -I. -I/usr/local/include/activemq-cpp-3.0.1
Where can one find a link to the JMS Docs??? I'd like to get a better
understanding of some of the JMS specs so I can better understand various
features, etc with ActiveMQ.
Timothy states From JMS Docs on ClientAcknowledge in this issue. Where
does one find this information?
Found this
On Fri, 2009-10-30 at 08:41 -0700, magellings wrote:
Where can one find a link to the JMS Docs??? I'd like to get a better
understanding of some of the JMS specs so I can better understand various
features, etc with ActiveMQ.
Timothy states From JMS Docs on ClientAcknowledge in this issue.
have a look at one of the test cases for this feature from trunk and
do a compare and contrast or try and munge it into something that
demonstrates your behavior.
see:
I fixed the errors by adding...
#include memory
#include activemq/library/ActiveMQCPP.h
thanks
Nishant
nmittal wrote:
Hi Tim, as suggested, I added the lines but when I do a make I get the
following errors... (the same code built fine with 2.2.5
$ make
make: Warning: File
I ported my code from CPP 2.2.5 to CPP 3.0.1 and after a successful build
tried to run it. I can see the Queues and Topics created by the code but
after some 10 secs or so.. i get the following messages...
Exception: DataInputStream::readLong - Reached EOF
FILE:
I figured it out. I was using debug versions of activemq cms lib when
building release versions of my project. After I built with release versions
of dependent libs, the problem went away. thanks for the help.
Regards,
Andrew
andrewdc wrote:
I am newbie on acticemq CMS API. I have compiled
Hi,
Should I download latest php stomp client form here
(1)
http://stomp.fusesource.org/download.html
stomp-php-1.0.0.tar.gz
or
(2)
http://code.google.com/p/stompcli/downloads/list
stompcli-php5-1.0-20080916.tar.gz
I ask because it seems I should use option 1, but the file is empty.
Thanks
Hi All,
Could you please forward any documentation related to start with Active MQ
using C# ..
I am looking for sending / receiving messages using Active MQ in C# ..
Regards,
KVS
--
View this message in context:
On Fri, 2009-10-30 at 10:00 -0700, nmittal wrote:
I ported my code from CPP 2.2.5 to CPP 3.0.1 and after a successful build
tried to run it. I can see the Queues and Topics created by the code but
after some 10 secs or so.. i get the following messages...
Exception: DataInputStream::readLong
How come individual acknowledgement mode isn't documented?
4.4.11 Message Acknowledgment
If a session is transacted, message acknowledgment is handled automatically
by commit, and recovery is handled automatically by rollback.
If a session is not transacted, there are three acknowledgment
Tim, thanks!
Yes I am using 5.3.0 and that change seems to have fixed this issue.
however, I am now worried about migrating to the new version of Broker and
CPP as I have a ton of existing code that would need changing. are there
other changes like these that would need to be made in my code?
On Fri, Oct 30, 2009 at 12:14 PM, magellings mark.gelli...@qg.com wrote:
How come individual acknowledgement mode isn't documented?
Because INDIVIDUAL_ACKNOWLEDGEMENT is not part of the JMS spec. It's
an ActiveMQ only feature.
Bruce
--
perl -e 'print
On Fri, 2009-10-30 at 11:14 -0700, magellings wrote:
How come individual acknowledgement mode isn't documented?
The individual acknowledge mode is an ActiveMQ specific mode not
supported directly by the JMS spec so you won't find anything in there
about that. Individual Ack is pretty much
On Fri, 2009-10-30 at 11:22 -0700, nmittal wrote:
Tim, thanks!
Yes I am using 5.3.0 and that change seems to have fixed this issue.
however, I am now worried about migrating to the new version of Broker and
CPP as I have a ton of existing code that would need changing. are there
other
ok will change the configuration then.. just to make sure..
transport.keepAliveResponseRequired=true or false?
also I am assuming this would need to be done for all connectors (including
stomp) ..right?
thanks
Nishant
Timothy Bish wrote:
On Fri, 2009-10-30 at 11:22 -0700, nmittal wrote:
On Fri, 2009-10-30 at 11:35 -0700, nmittal wrote:
ok will change the configuration then.. just to make sure..
transport.keepAliveResponseRequired=true or false?
also I am assuming this would need to be done for all connectors (including
stomp) ..right?
It should be set to true, doing so
thanks Tim
Timothy Bish wrote:
On Fri, 2009-10-30 at 11:35 -0700, nmittal wrote:
ok will change the configuration then.. just to make sure..
transport.keepAliveResponseRequired=true or false?
also I am assuming this would need to be done for all connectors
(including
stomp) ..right?
Hello all,
I'm looking for an example of how to limit tempUsage. I'm sending a lot of
non-persistent messages to topics that have very slow consumers. I've
created a KahaStore that I'm using for the tempDataStore attribute on the
Broker. That seems to be honored by the broker in terms of
Scenario: I have a consumer of a persistent queue that is prefetching
messages. I'd like to implement a timeout on the broker side to timeout the
connection and release all prefetched messages back for redelivery if the
consumer hasn't ack'd back any message in some configurable period of time.
Trying to build from source I've done this:
svn co https://svn.apache.org/repos/asf/activemq/trunk activemq
mvn -Dtest=false -DfailIfNoTests=false clean install
The build fails saying it can't find two artifacts from maven.
1) net.sf.josql:josql:jar:1.5
2) net.sf.josql:gentlyweb-utils:jar:1.5
http://old.nabble.com/file/p26139375/testindex.html testindex.html
http://old.nabble.com/file/p26139375/testindex.js testindex.js
Hello
I am using activeMQ 5.2.0, and to send data between c++ code and web browser
(firefox and ie).
It works good when I am sending the data from web browser to
36 matches
Mail list logo
