Hello,
I run activemq with database oracle. I stop the activemq yesterday and today
morning I start it new and want to consume the messages, which I send
yesterday. But I get the following Error:
Failed to retrieve message for id:943
What can be the problem? Can you help me please?
--
View thi
On Wed, Mar 3, 2010 at 1:29 AM, aness123 wrote:
>
> Hi @ all,
>
> I'm using ActiveMQ 5.3.0 and Java Message Service to send and receive
> message to/from several queues. I wanna send 1000 messages and more by my
> program by using a MessageProducer. Unfortunately sending jams when I send
> more th
Hi Marc,
> We are sending files >1GB around using the ActiveMQ's BlobMessage.
...mmh you have an interesting real-life use case: can you give us a few
more details?
Things like the "side protocol" you use (FTP? WebDAV?), daily volumes, any
special other ActiveMQ tuning you performed etc
Cheers,
Hi Marcin,
This looks very similar to a bug that I have logged:
https://issues.apache.org/activemq/browse/AMQ-2616
Supposed to be fixed in 5.3.1 and later.
Mats
On 4 March 2010 06:50, lucious wrote:
>
> Hello here is what we have:
>
> 1) AMQ -5 3.0 with the following configuration:
> http:
Can you try to access amq/amq.js in your application and see what happens?
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveMQ in Action - http://www.manning.com/snyder/
Blog - http://www.nighttale.net
On Wed, Mar 3, 2010 at 3:19 AM, hmi
100 MB isn't really that large. We are sending files >1GB around using the
ActiveMQ's BlobMessage. Why don't you try using that instead of doing
chunking and serialization/deserialization manually?
http://activemq.apache.org/blob-messages.html
Marc
On Wed, Mar 3, 2010 at 6:17 AM, Cristian Botiza
Hello here is what we have:
1) AMQ -5 3.0 with the following configuration:
http://activemq.apache.org/schema/core";
brokerName="localhost" useJmx="true" dataDirectory="${activemq.base}/data">
RuralHunter schrieb:
> I created a network connector from my local activemq to a remote activemq
> server with configuration below:
>
> uri="static://(tcp://a.b.c.d:62616)" duplex="true"/>
>
>
On AMQ 5.2 and 5.3 I use "static://(failover:(tcp://a.b.c.d:62616))"
(ok, we have the de
Forgot the stacktrace:
ERROR | failed to forward message on attempt: 1 reason:
javax.jms.IllegalStateException: Producer is closed message:
ActiveMQTextMessage {commandId = 14, responseRequired = true, messageId =
ID:longshanks.ongame.com-62594-1267627711097-0:1:1:1:10, originalDestination
= null,
bsnyder wrote:
>
> There is no built-in support for integrating with RV built in to
> ActiveMQ, but it can bridge to TIBCO EMS. Here's an example:
>
> http://activemq.apache.org/jms-bridge-with-remote-tibco-broker.html
>
That example works well except for initial connection (when Tibco is down
On Mar 3, 2010, at 3:29 AM, aness123 wrote:
>
> I'm using ActiveMQ 5.3.0 and Java Message Service to send and receive
> message to/from several queues. I wanna send 1000 messages and more by my
> program by using a MessageProducer. Unfortunately sending jams when I send
> more than 300 messages.
the contents of the toString() depends on the message type, what message
type are you using?
I think for your use case you must add your own implementation. But look at
the source to be sure.
On 3 March 2010 12:05, BenXS wrote:
>
> You say "you may" so it is not a must?
>
> From what you said I
you need to add the attribute: persistenceFlag="true"
On 3 March 2010 11:55, BenXS wrote:
>
> So ok, I inserted the code:
>
> http://www.springframework.org/schema/beans";
> id="forcePersistencyModeBroker"
> class="org.apache.activemq.plugin.ForcePersistencyModeBrokerPlugin">
>
>
>
> from page
You say "you may" so it is not a must?
>From what you said I CAN log incoming XML JMS message but they are written
as one long text line (as output from toString()) into the logfile?
I enabled logging but NO XML message appears in logfile.
So how else can I write the "toString()" info to logfile
So ok, I inserted the code:
http://www.springframework.org/schema/beans";
id="forcePersistencyModeBroker"
class="org.apache.activemq.plugin.ForcePersistencyModeBrokerPlugin">
from page:
D:\java\JMS\Apache ActiveMQ\docs\initial setup\config persistence\enforcing
persistency\Enforcing persisten
Hi Aneess
I could not find any issue in your code. Are you sure that your program is
not sending only 300 messages or exiting by timeout?
This issue happens even with something like that?
while(true) {
producer.send(msg);
}
I suggest you to check the sample from ActiveMQ - from
your installati
I would look for some streaming options in ActiveMQ if you want to send the
full file. But 100 MB is quite huge...anyway see class BytesMessage. You may
try using a BufferedStream around the byte array, or read it in chuncks using
readBytes(byte[]).
From
To get access to the message content you may have to extend the
LoggingBrokerPlugin as it just logs the contents of the toString() on a
message, the contents of which varies with message type.
It is a simple plugin so it is easy to extend to get it to do what you want.
have a look at the send met
So you think sending the file in full size is not performance efficient? I
wonder what happens when the receiving app get the file, will the full
content of the file load into memory or will just part of it will get loaded
and the rest will load on demand?
Thanks,
Can you chunk the file? In thi
yea. that plugin is part of 5.3, the fix version is 5.3.0 so you just need
to add the relevant config,
It is an element in the plugins list and uses xbean so you can use
see: http://activemq.apache.org/developing-plugins.html
On 3 March 2010 10:04, BenXS wrote:
>
> Ok, thank you. But one mo
Can you chunk the file? In this case you might split it between multiple
producers and consumers
and play with the number of producers/consumers and chunck size. You may send
and process chuncks
concurrently and also limit the message size.
Just one option...
___
I need to send a large text file through ActiveMQ. On the receiving end, it's
a JAVA application that retrieve the file and manipulate its content. I send
the file through ActiveMQ by serializing/deserializing.
Because the file is big, could be over 100Mb, i think there must be some
performance i
Ok, thank you. But one more question:
On the bottom of the webpage you mentioned it is written:
"Patch applied in revision 800274"
What does that mean? A patch is a fix for a bug. But the missing "force
persistency" is not a bug but a new feature.
Furthermore a revision is listed: Is this revi
I would like to log the full XML JMS Header and the full XML payload
for all incoming and for all outgoing JMS Msgs.
The resp. XML content should be written to a logfile.
How can I achieve this?
I read several times the web page
http://activemq.apache.org/logging-interceptor.html
and played
see https://issues.apache.org/activemq/browse/AMQ-2339 for a plugin that
forces all messages to be persistent.
On 3 March 2010 09:35, BenXS wrote:
>
> Is there a way to force ActiveMQ to store inbound JMS msgs even if they are
> NOT declared as persistent?
>
> Background: I send JMS msgs (payloa
Is there a way to force ActiveMQ to store inbound JMS msgs even if they are
NOT declared as persistent?
Background: I send JMS msgs (payload) from well known HermesJMS tool to
ActiveMQ over menu
Messages->TextMessages
Here I cannot pass or define a JMS header for these JMS messages. The JMS
he
Hi @ all,
I'm using ActiveMQ 5.3.0 and Java Message Service to send and receive
message to/from several queues. I wanna send 1000 messages and more by my
program by using a MessageProducer. Unfortunately sending jams when I send
more than 300 messages. My program does not continue anymore. Here i
27 matches
Mail list logo
