I produce a BlobMessage to broker, then the binary file would be saved in the
fileserver(inside jetty).
However, even when I consumed that BlobMessage and get the binary file, the
file saved in the fileserver still exists!! Named
:ID_MyConputer-3581-1189147531234-0_0_1_1_1.
Why not delete it ?
-
FWIW, I can't reproduce the timing issue... It seems your original code runs
fine on my setup.
Keep in mind that I am using a different version of amq.js. (See JIRA issue
http://issues.apache.org/activemq/browse/AMQ-1377 AMQ-1377 . )
Find the debug log and see if there were any exceptions or st
Try this:
http://www.w3.org/TR/html4/strict.dtd";>
Observatory
amq.uri='amq';
var myHandler = {
rcvMessage: function(message) {
alert("received " + message);
On 9/6/07, Juergen Mayrbaeurl <[EMAIL PROTECTED]> wrote:
>
> Hi!
>
> Our application has to make sure that all consumers with durable topic
> subscriptions get messages in strict order even when a message has to be
> delivered.
> E.g.
> Publisher puts message 1 to 10 on topic. Consumer opens a sess
Could you try with a more recent release; say at least 4.1.1? There
have been numerous bug fixes since 4.1
On 9/6/07, tendlu <[EMAIL PROTECTED]> wrote:
>
> Using ActiveMQ 4.1
>
> I have a producer that does the following -
>
> 1. main thread creates a Connectionfactory using tcp
> 2. creates a few
On 9/6/07, Olivier OTTAVI <[EMAIL PROTECTED]> wrote:
> That will result in easier connection managment between the nodes of the
> network and even load of each brokers. I would like to be able to scale the
> network of brokers without scaling automatically the producers. Like 2
> producers and 3 br
On 9/7/07, tendlu <[EMAIL PROTECTED]> wrote:
> Not all messages(persistent) to a queue are sent to the broker if messages
> are sent from multiple threads. Each thread creates its own connection and
> session.
>
> Please let me know if I am missing something or is this a bug?
That sounds wrong; do
Ok, It looks like the webpage is talking via the servlet, I am seeing post
and get messages in the log file when I hit the send button on my page.
Below is the HTML I am using:
Observatory
amq.uri='amq';
var myHandler =
{
rcvMessage: functi
I tried them, but I could not get them to work. Sorry for all the dumb
questions.
J
chago wrote:
>
> That's correct. Have you tried the examples in web demo?
>
>
> Zanderfax wrote:
>>
>> So I don't have to configure anything on the Jetty side to have the
>> topics available?
>>
>
>
--
That's correct. Have you tried the examples in web demo?
Zanderfax wrote:
>
> So I don't have to configure anything on the Jetty side to have the topics
> available?
>
--
View this message in context:
http://www.nabble.com/Looking-for-Help-ActiveMQ-and-Jetty-tf4379195s2354.html#a12533912
Se
So I don't have to configure anything on the Jetty side to have the topics
available?
J
chago wrote:
>
> When using the javascript client (amq.js) you subscribe to topics and
> queues in your javascript code. For example, in the chat.js file when the
> 'join' button is pressed, an event fires
When using the javascript client (amq.js) you subscribe to topics and queues
in your javascript code. For example, in the chat.js file when the 'join'
button is pressed, an event fires that is coded as:
amq.addListener('chat', 'topic://CHAT.DEMO', chatHandlerCallback);
Any messages posted to tha
Not all messages(persistent) to a queue are sent to the broker if messages
are sent from multiple threads. Each thread creates its own connection and
session.
Please let me know if I am missing something or is this a bug?
--
View this message in context:
http://www.nabble.com/Help%21-Missing-m
Ok, I understand that.
Next question, how do I define what queue I want to watch? I have tried to
follow the docs on the Jetty page, but I am not sure that I have the right
things in the jetty.xml and jetty-plus.xml files. Or is that not where you
set that up? The docs are not very clear on thi
You use the http: scheme to connect your client to a remote or external
broker. You also have available other schemes like https:, tcp:, and ssl: to
connect to a remote broker. Just depends what protocol you want to use.
The vm: scheme is used to start an intra-JVM or embedded broker. So if you
So if my broker is running on server bob, I would change the value to
vm://bob:1234 or would it be http://bob:1234?
J
chago wrote:
>
> If you download ActiveMQ, the web demo module contains a few demos that
> use Jetty with an embedded broker talking to web pages using the amq.js
> script fil
If you specifiy a broker uri of the following format in creating an
ActiveMQ.ConnectionFactory:
tcp://localhost:61616?jms.redeliveryPolicy.maximumRedeliveries=3
an NMSException is thrown on calling
ActiveMQ.ConnectionFactory.CreateConnection().
The exception text is:
"no such property: redeliv
Hi all,
This is a follow on from the thread "Temp queue vs topic with message
selectors?", where I was having difficulty with temp queues.
See also : https://issues.apache.org/activemq/browse/AMQ-1375 AMQ-1375
Anyway, following some investigation I have encountered a situation where
temp que
Any clues?
tendlu wrote:
>
> Using ActiveMQ 4.1
>
> I have a producer that does the following -
>
> 1. main thread creates a Connectionfactory using tcp
> 2. creates a few threads - say 5
> 3. each thread creates a new Connection and a new Session using the
> connectionfactory created in the
That will result in easier connection managment between the nodes of the
network and even load of each brokers. I would like to be able to scale the
network of brokers without scaling automatically the producers. Like 2
producers and 3 brokers etc. Is Iona recommand architecture where load
balancin
We're using the Spring configuration for the ActiveMQConnectionFactory (with
version 4.1.0):
On 9/6/07, drod <[EMAIL PROTECTED]> wrote:
>
> Yes I did and I try it with this configuration:
> tcp://localhost:61616?jms.prefetchPolicy.all = 100
Strange, works for me. You can also customize the PrefetchPolicy POJO
on ActiveMQConnectionFactory / ActiveMQConnection before you create a
consume
Yes I did and I try it with this configuration:
tcp://localhost:61616?jms.prefetchPolicy.all = 100
But it doesn't work!
Juergen Mayrbaeurl wrote:
>
> Did you look at
> http://activemq.apache.org/what-is-the-prefetch-limit-for.html
> what-is-the-prefetch-limit-for on the ActiveMQ website?
On 9/6/07, Olivier OTTAVI <[EMAIL PROTECTED]> wrote:
> It seems from my perspective that the PooledConnectionFactory is caching
> only one connection to the network. Since load balancing between nodes is
> done at connection time, using PooledConnectionFactory will not work with
> load balancing. W
On 9/6/07, Juergen Mayrbaeurl <[EMAIL PROTECTED]> wrote:
>
> Thanks!
>
> Upgrading from 4.1.0 to 4.1.1 means that we'll have to to rebuild/distribute
> our publisher and consumer apps and setup up a new broker, too?
Its always advisable to upgrade the JMS client and broker together, yes
--
James
Thanks!
Upgrading from 4.1.0 to 4.1.1 means that we'll have to to rebuild/distribute
our publisher and consumer apps and setup up a new broker, too?
Kind regards
Juergen
James.Strachan wrote:
>
> On 9/6/07, Juergen Mayrbaeurl <[EMAIL PROTECTED]> wrote:
>>
>> Are the versions (distributions) o
It seems from my perspective that the PooledConnectionFactory is caching
only one connection to the network. Since load balancing between nodes is
done at connection time, using PooledConnectionFactory will not work with
load balancing. Will this be a problem to have a real pool of jms
connections
On 9/6/07, Juergen Mayrbaeurl <[EMAIL PROTECTED]> wrote:
>
> Are the versions (distributions) of ActiveMQ "ActiveMQ 4.1.0" and "Apache
> ActiveMQ 4.1.0-incubator" the same?
Yes. 4.1.0 happened while ActiveMQ was still in incubation; so the
maven version number had to include "-incubator". However
Sorry!
Just found the answer on the website. The distribution package of version
4.1.0 has "incubator" in its name.
Juergen
Juergen Mayrbaeurl wrote:
>
> Are the versions (distributions) of ActiveMQ "ActiveMQ 4.1.0" and "Apache
> ActiveMQ 4.1.0-incubator" the same?
>
> Kind regards
> Juergen
Are the versions (distributions) of ActiveMQ "ActiveMQ 4.1.0" and "Apache
ActiveMQ 4.1.0-incubator" the same?
Kind regards
Juergen
--
View this message in context:
http://www.nabble.com/ActiveMQ-version-4.1.0-and-incubator-version-4.1.0-tf4392835s2354.html#a12524900
Sent from the ActiveMQ - Use
Just read https://issues.apache.org/activemq/browse/AMQ-1140 JIRA issue
about compression . Does this really mean that up to version 4.1.1
compression didn't work?
Kind regards
Juergen
Juergen Mayrbaeurl wrote:
>
> We're using compression (useCompression=true in serverURL) on the producer
> s
On 9/6/07, Marcin Szkudlarek <[EMAIL PROTECTED]> wrote:
>
> Hi all,
> How I can check the state of activemq connection? i.e. how i can check that
> the activemq server is up and running? My app needs to detect the cases when
> the server is killed by kill -9 so advisory topics are not helpful here.
Hi!
Try to use the JMX interface ( http://activemq.apache.org/jmx.html ActiveMQ
JMX ).
Since you're using Spring this is quite easy.
Kind regards
Juergen
Marcin Szkudlarek wrote:
>
> Hi all,
> How I can check the state of activemq connection? i.e. how i can check
> that the activemq server i
Hi all,
How I can check the state of activemq connection? i.e. how i can check that
the activemq server is up and running? My app needs to detect the cases when
the server is killed by kill -9 so advisory topics are not helpful here.
I'm using SpringFramework support for activemq.
Regards,
Marc
Did you look at
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
what-is-the-prefetch-limit-for on the ActiveMQ website?
Juergen
drod wrote:
>
> How can I set the prefetchSize for a TopicSubscriber using ActiveMQ 4.1.1
> ?
>
>
--
View this message in context:
http://www.n
Hi
We had the same problem with NFS, I think it's an NFS/Java issue since
there also seem to be problems with other applications.
But someone told me they've it running successful with NFS, so I
suppose it's NFS-implementation/version specific whether locking works
or not (he ran a JVM 1.5.0_08 and
Unfortunately noone has replied yet!
Our problem still exists, but maybe some more information will help:
The problem showed up the first time, when we switched from Java 1.4 to Java
5 on our AIX machines. It's not reproducable what makes tracking down the
problem quite difficult.
Any ideas? Sho
You can specify your own jdbc adapter class (see
http://activemq.apache.org/jdbc-support.html).
What I'd do is write a mysql adapter (extend the mysql one) and
override the locking statements. You can also rename the mysql adapter
for AMQ 5 (or svn revision 518161/518164) into
MySqlPropertLockingAd
Hi!
Our application has to make sure that all consumers with durable topic
subscriptions get messages in strict order even when a message has to be
delivered.
E.g.
Publisher puts message 1 to 10 on topic. Consumer opens a session, gets
message 1, makes a client acknowledment, gets message 2, mak
How can I set the prefetchSize for a TopicSubscriber using ActiveMQ 4.1.1 ?
--
View this message in context:
http://www.nabble.com/prefetchSize-for-TopicSubscriber-tf4390619s2354.html#a12518267
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
40 matches
Mail list logo
