Re: Blob Messages ??? does it work ???

2007-12-30 Thread Marco Buss
In general it works, but it is a little bit tricky i think. First keep in mind that the message only holds the reference to your blob. It works for you with an URL becaus the publisher must not send the blob to the so called uploadurl. That url must point to the fileserver webapp (you can find

Re: Writing to JMS queues from RPG programs

2007-12-30 Thread mjustin
Hello Sriram If there is a HTTP package for RPG then the application could use the REST protocol which seems to be very easy to implement. (However I have only experience with STOMP.) Michael svdv wrote: > > Hello All, >We are looking at using ActiveMQ as a way to have asynchronous deliv

Setting subscriptionRecoveryPolicy with ActiveMQConnectionFactory

2007-12-30 Thread Fady
Hello, I am new to ActiveMQ. I have ActiveMQ 5.0.0 embedded in Tomcat, getting connections from ActiveMQConnectionFactory. So far, I used a simple URL vm://localhost?broker.persistent=false. Now, I have the need to disable the subscription recovery policy (http://activemq.apache.org/subscriptio

Blob Messages ??? does it work ???

2007-12-30 Thread CBT
I'm trying to use ActiveMQ V5 to send and receive Blob messages this is a new features with this version. there are three ways to send these kind of messages : file : BlobMessage message = session.createBlobMessage(new File("c://mkv.txt")); URL : BlobMessage message = sessi

unsubscribe unsuccess!!

2007-12-30 Thread bill richard
[EMAIL PROTECTED] msgclient]$ javax.jms.JMSException: java.lang.NullPointerException at org.apache.activemq.util.JMSExceptionSupport.create(JMSExceptionSupport.java:49) at org.apache.activemq.ActiveMQConnection.syncSendPacket(ActiveMQConnection.java:1178) at org.apache.acti

Can not receive MapMessage in ActiveMQ 5.0

2007-12-30 Thread pcdinh
ActiveMQ 5.0's QueueReceiver seems to have problems with MapMessage. It always returns bull object when the timeout occurs or waits in a countless time. Receiver code QueueConnectionFactory connFactory = new ActiveMQConnectionFactory(ActiveMQConnection.DEFAULT_BROKER_URL); QueueConnection conn =