Perl Net::Stomp keeps complaining "Error reading command.."

Hi, I have a perl Net::Stomp client that subscribes to a queue (only consumer). it runs for a while before giving.. Error reading command: at /usr/local/lib/perl5/site_perl/5.10.0/Net/Stomp/Frame.pm line 37, line 4. it fails even if the messages are always the same. #!/usr/bin/perl -w use str

Re: Admin Interface Sorting

; Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Wed, Nov 4, 2009 at 2:13 PM, nmittal wrote: > >> >> Great.. I am an official contributor now ;-) >> >> I insta

Re: Admin Interface Sorting

ttp://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Tue, Nov 3, 2009 at 11:12 PM, nmittal wrote: > >> >> >> http://old.nabble.com/Admin-Console:-Sort-on-Queue-name-td25440691.html#a25440691 >> >> >> Bryan Murphy-4 wrote: >>

Re: Admin Interface Sorting

http://old.nabble.com/Admin-Console:-Sort-on-Queue-name-td25440691.html#a25440691 Bryan Murphy-4 wrote: > > Is there a way I can have the administration interface automatically sort > the queues by name when I go to the queues page without having to click on > the name column? > Thanks, > Bryan

Re: CMS 3.0.1: Get exception after sometime (approx 10secs)

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 fo

Re: CMS 3.0.1: Get exception after sometime (approx 10secs)

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

Re: CMS 3.0.1: Get exception after sometime (approx 10secs)

? thanks again Nishant Timothy Bish wrote: > > 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

CMS 3.0.1: Get exception after sometime (approx 10secs)

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: ./decaf/io/DataInputStream

Re: CMS: Installed 3.0.1 but my existing code

I fixed the errors by adding... #include #include 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 `../Libraries/ActiveMQ

Re: CMS: Installed 3.0.1 but my existing code

decaf::util::concurrent; using namespace cms; using namespace std; thanks for your help. Nishant Timothy Bish wrote: > > On Thu, 2009-10-01 at 18:43 -0700, nmittal wrote: >> fails to run. The code has been running on ActiveMQ CPP 2.2.5. I >> recompiled >> the code wi

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/

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: Is it possible to filter/change the queue list order in browser overview?

; > But is there a similar way to filter lets say 5 queues out of 233 > existing? > > Peter > > > nmittal wrote: >> >> I found a workaround solution. >> 1) open standardista-table-sorting.js which is located in the >> $ActiveMQHOME$/webapps/ad

CMS: Installed 3.0.1 but my existing code

fails to run. The code has been running on ActiveMQ CPP 2.2.5. I recompiled the code with 3.0.1 but get the following error... No Matching Factory Registered for format := tcp FILE: activemq/transport/TransportRegistry.cpp, LINE: 50 FILE: activemq/core/ActiveMQConnectionFactory.cp

Re: PERL/STOMP: Subscribe to multiple destinations

destination => '/queue/testq2', > 'ack' => 'client', > 'activemq.prefetchSize' => 1, > } > ); > > while (1) { >my $frame = $stomp->receive_frame; ># if $frame->headers->{&#x

PERL/STOMP: Subscribe to multiple destinations

Hi All, the following code snippet, leads me to believe that we can subscribe to only one destination at a time... my $stomp = Net::Stomp->new( { hostname => "192.168.42.30", port => '61613' } ); $stomp->connect(); $stomp->subscribe( { destination => '/queue/testq',

Re: Is it possible to filter/change the queue list order in browser overview?

I found a workaround solution. 1) open standardista-table-sorting.js which is located in the $ActiveMQHOME$/webapps/admin/js/ folder. 2) change the function... function standardistaTableSortingInit() { standardistaTableSorting.init(); } to the following...

Re: Admin Console: Sort on Queue name

f you want to sort on the 4th column e.target = obj; standardistaTableSorting.headingClicked(e); // will sort Ascending //standardistaTableSorting.headingClicked(e); // uncheck this if you want to sort desc } thanks Nishant nmittal wrote: >

Admin Console: Sort on Queue name

Hi I use the bundled activemq console heavily to monitor queues. I refresh the page frequently to see the latest state. I was wondering if there was a way to ensure that after page refresh the queues are sorted by name? currently everytime I refresh, queue names show up in some random order that I

Re: NMS: How to specify Bitwize operations in selectors

try replacing the & with AND gtsafas wrote: > > I am trying to configure a consumer so it only receives messages that have > the 2nd bit in the ‘Status’ (user defined INT property) as 0. I came up > with the following code but I get this Exception… > > > > “An unhandled exception of type

Re: PERL/STOMP: How to Request Response

} >> >> Can you try using one connection in your client code for starters and see >> if >> it works. >> >> If you cannot make your stomp implementation to work with temp >> destinations, >> you can use regular queues and selectors as described in t

Re: PERL/STOMP: How to Request Response

cribed in this thread > http://www.nabble.com/Implement-request-response-with-JMS-over-Stomp-td24914033.html > > Cheers > -- > Dejan Bosanac > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nigh

Re: PERL/STOMP: How to Request Response

osanac wrote: > > Hi, > > use /temp-topic/ or /temp-queue/ prefixes (instead of /topic/ and /queue/) > for destination names and ActiveMQ will create temporary destinations. > > Cheers > -- > Dejan Bosanac > > Open Source Integration - http://fusesource.com/

PERL/STOMP: How to Request Response

Hi, I am trying to implement request response with a Perl Client using stomp. the documentation on the ActiveMQ website has sample code in JAVA that created a temporary destination and then sets the replyto header to this temp destination. How can I create a temporary destination in Perl STOMP cl

Re: PERL/STOMP: MapMessages

n - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Thu, Aug 20, 2009 at 3:03 PM, nmittal wrote: > >> >> I tried... >> $stomp->subscribe( >> { destination => '/queue/

Re: PERL/STOMP: MapMessages

anning.com/snyder/ > Blog - http://www.nighttale.net > > > On Thu, Aug 20, 2009 at 3:03 PM, nmittal wrote: > >> >> I tried... >> $stomp->subscribe( >> { destination => '/queue/Queue.Emails', >> 'ack'

Re: PERL/STOMP: MapMessages

> > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Thu, Aug 20, 2009 at 2:48 PM, nmittal wrote: > >> >> That was it, I wasnt using any transformation. Now i see

Re: CMS:Synchronous Request Response

Thanks Tim, I am working on implementing this. I will let you know how it goes. thanks Nishant Timothy Bish wrote: > > On Wed, 2009-08-19 at 10:16 -0700, nmittal wrote: >> I am using CMS for ActiveMQ to implement request-response. I understand >> from >> the example

Re: PERL/STOMP: MapMessages

he topic. > > But as I said, your Stomp client must play along as well. > > Cheers > -- > Dejan Bosanac > > Open Source Integration - http://fusesource.com/ > ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Wed

PERL/STOMP: MapMessages

Hi, Has anyone been able to write a Perl client that reads MapMessges off of an ActiveMQ queue? We have a C++ ActiveMQ client that is sending MapMessages to the broker. However, the Perl client using Net::Stomp says that the body is undefined. Below is the message as seen in the activemq admin we

CMS:Synchronous Request Response

I am using CMS for ActiveMQ to implement request-response. I understand from the examples how to do asynchronous request-response. In my application I want the requester to wait till it receives the response. How can this be done with the CMS AMI. thanks for your help. -- View this message in c

Duplex not working (or I am doing something wrong)

Hi, I want to setup message exchanges (both ways) between two brokers running on different boxes. I have a producer P1 on box 1 thats publishes messages that are consumed by a consumer C2 on box 2. C2 then does some calculations and publishes messages on P2 that a consumer C1 on box 1 subscribes

Re: CMS: Cloning a Message

Understood. Thanks Tim. Timothy Bish wrote: > > On Wed, 2009-06-03 at 12:49 -0700, nmittal wrote: >> thanks. So could I do something like this... >> void *cloneMessageProperties(void *src_msg) { >> Message *msg = ((Message *)src_msg)->clone(); >> msg

Re: CMS: Cloning a Message

thanks. So could I do something like this... void *cloneMessageProperties(void *src_msg) { Message *msg = ((Message *)src_msg)->clone(); msg->clearBody(); return msg; } Timothy Bish wrote: > > On Wed, 2009-06-03 at 12:24 -0700, nmittal wrote: >> Hi, i

CMS: Cloning a Message

Hi, is there a function to copy all properties in a message to a new one. thanks Nishant -- View this message in context: http://www.nabble.com/CMS%3A-Cloning-a-Message-tp23857727p23857727.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: CMS 2.2.6 requires higher autoconf

Thanks Tim, that worked. Its building now. Timothy Bish wrote: > > Looks like you would have to build autoconf and its associated tools > from source and install, your distro apparently doesn't offer anything > newer than 2.59 > > Regards > Tim. > > On Tue, 20

CMS 2.2.6 requires higher autoconf

I am trying to build activemq-cpp-2.2.6 on "Linux corp.rsi.com 2.6.18-92.1.10.el5xen #1 SMP Wed Jul 23 04:25:48 EDT 2008 i686 i686 i386 GNU/Linux" I get the following errors... [nmit...@corp activemq-cpp-2.2.6]$ ./autogen.sh configure.ac:18: error: Autoconf version 2.61 or higher is required co

Re: Fresh install, failed to run

ActiveMQ in Action - http://www.manning.com/snyder/ > Blog - http://www.nighttale.net > > > On Tue, Jun 2, 2009 at 6:35 PM, nmittal wrote: > >> >> Hi, I downloaded and unpacked ActivewMQ 5.2.0 on a linux machine with the >> following configuration... >> $ una

Fresh install, failed to run

Hi, I downloaded and unpacked ActivewMQ 5.2.0 on a linux machine with the following configuration... $ uname -a Linux corp.rsi.com 2.6.18-92.1.10.el5xen #1 SMP Wed Jul 23 04:25:48 EDT 2008 i686 i686 i386 GNU/Linux however, when I try to run activemq, i get the following error... $ bin/activemq A

Re: CMS: Unknown exception

Tim, please ignore this message. As I suspected, it was a bad message. BTW, I am using 2.2.5 thanks Nishant Timothy Bish wrote: > > On Thu, 2009-05-14 at 12:23 -0700, nmittal wrote: >> I am writing a high volume tick handler (25000 msgs/sec). Everything >> works >>

CMS: Unknown exception

I am writing a high volume tick handler (25000 msgs/sec). Everything works fine for some time and then I get... unable to allocate memory for mutex; resize mutex region caught unknown exception FILE: activemq/core/ActiveMQConsumer.cpp, LINE: 505 FILE: activemq/core/ActiveMQSession

Re: CMS and Multithreading

Thats awesome. saves a lot of time for me as a developer trying to do my own synchronization. thanks Tim. Timothy Bish wrote: > > On Fri, 2009-05-01 at 06:44 -0700, nmittal wrote: >> below is an excerpt from the book "ActiveMQ in action"... >> The JMS spec specific

CMS: Session, Destination

Hi All, If I am not mistaken, then destinations are created from Sessions. (session->createTopic() or session->createQueue()) Then how come, destinations are required to be thread safe while Sessions are not? thanks Nishant -- View this message in context: http://www.nabble.com/CMS%3A-Session%

CMS and Multithreading

below is an excerpt from the book "ActiveMQ in action"... The JMS spec specifically defines concurrency for various objects in the JMS API and requires that only a few objects support concurrent access. The ConnectionFactory, Connection and Destination objects are required to support concurrent ac

Re: SimpleProducer example inherits from Runnable.. curious why?

Understood. Thanks. Timothy Bish wrote: > > On Thu, 2009-04-30 at 13:11 -0700, nmittal wrote: >> Hi All, in the examples that come with the CMS distribution, I see the >> following... >> class SimpleProducer: public Runnable >> >> is there a reason why a p

SimpleProducer example inherits from Runnable.. curious why?

Hi All, in the examples that come with the CMS distribution, I see the following... class SimpleProducer: public Runnable is there a reason why a producer has to inherit from Runnable. The run() function is called like any other functions. any insight is appreciated. thanks Nishant -- View thi

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > > On Tue, 2009-04-28 at 08:35 -0700, nmittal wrote: >> >> >> Timothy Bish wrote: >> > >> > >> > It still appears if your environment is working against you. You need >> > to spend some time figuring out wh

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > > > It still appears if your environment is working against you. You need > to spend some time figuring out what is installed and where. > >> /usr/bin/ld: skipping incompatible /usr/lib/libuuid.so when searching >> for -luuid > > This error usually means that you don't

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > > On Mon, 2009-04-27 at 09:38 -0700, nmittal wrote: > > Most autoconf based packages install in /usr/local by default unless you > pass the prefix argument to the configure script. > > Try './configure --prefix=/usr' > > Reading the

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > > On Mon, 2009-04-27 at 08:35 -0700, nmittal wrote: > > > You apparently have v1.2.7. You can usually find out the version by > using the config script installed with APR 'apr-1-config --version' will > tell you. You can find out wher

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > >>From problems you were having previously I'm assuming that you have an > older version of APR installed somewhere on Path and that is getting > found instead of the 1.3 version you built and installed in /usr/local > most likely in /usr/lib. The best solution is to buil

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > > On Fri, 2009-04-24 at 14:05 -0700, nmittal wrote: >> >> >> > It looks like its not using the correct version of APR, which is odd. >> > The `apr_pool_create_unmanaged_ex' didn't exist until APR 1.3 so if >> > tha

Re: Libraries to include while compiling my activemq-cpp code

> It looks like its not using the correct version of APR, which is odd. > The `apr_pool_create_unmanaged_ex' didn't exist until APR 1.3 so if > that's not being found then it seems as if you are getting an old APR. > Have you tried linking against the APR .so files you built instead of > the lib

Re: Libraries to include while compiling my activemq-cpp code

nmittal wrote: > > > >> It looks like its not using the correct version of APR, which is odd. >> The `apr_pool_create_unmanaged_ex' didn't exist until APR 1.3 so if >> that's not being found then it seems as if you are getting an old APR. >>

Re: Libraries to include while compiling my activemq-cpp code

Timothy Bish wrote: > > Besides the activemq-cpp lib you need: > > libapr-1 > libaprutil-1 > > and whatever libs that the APR scripts tell you > apr-1-config --libs > apu-1-config --libs > > Regards > Tim. > > > Tim thanks. My Makefile looks like this... ifeq ($(UNAME), Linux) CPPLDFLAGS

Books/Tutorials

Hi, I am new to ActiveMQ and JMS. Could someone be kind enough to point me to some good books or any online documentation. IMHO, documentation on ActiveMQ website is helpful if you know what you are doing. regards, Nishant -- View this message in context: http://www.nabble.com/Books-Tutorials-