Here's a sample URI.
failover:(tcp://QGMQDEV1:10200?transport.UseInactivityMonitor=false&transport.UseLogging=true,tcp://QGMQBETA1:10200?transport.UseInactivityMonitor=false&transport.UseLogging=true)?transport.AsyncConnect=true&transport.AsyncTimeout=2
I had this just happen to me again. I
I have a windows service using the Apache NMS ActiveMQ 1.4.1 provider and
when trying to stop the service it appears to have gotten in an infinite
loop. When the service stops, the session and connection are disposed. Any
ideas why the EndianBinaryReader would be doing this?
2010-11-23 14:33:53
For now Tim I have just disabled it. We implemented our own keep alive
functionality when we discovered this same issue where consumer is idle and
there is a network hiccup.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/NMS-InactivityException-tp3049191p3049659.html
Sen
Thanks Tim! :)
I was hoping there was a more generalized list of breaking changes.
Something included with the specific version. Jumping through all the
issues out there would be quite tedious, especially when moving from
pre-v1.2 to v1.4. This is especially true if we are talking the broker
Found the culprit!!! Failover transport options for the NMS provider changed
to require a "transport" prefix. This appears to have been a breaking
change from an early version of the provider.
This:
?AsyncConnect=true
now has to be this:
?transport.AsyncConnect=true
Otherwise, with .NET, if
I'm not setting that explicitly so I'm guessing it's the default, whatever
that is.
--
View this message in context:
http://activemq.2283324.n4.nabble.com/NMS-InactivityException-tp3049191p3049397.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
I'm seeing a lot of these messages logged by the NMS ActiveMQ provider.
There are multiple log statements every millisecond and seems to be
infinite. Any ideas why this is occurring?
2010-11-18 10:02:25,107 [17384] [DEBUG] Apache.NMS.Tracer - No Message sent
since last write check. Sending a Ke
Those 1s should be 1000s. Sorry :)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-5-4-1-slower-than-ActiveMQ-5-2-tp3048866p3048967.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Here is a our scenario (P= producer, C=consumer, BrKR = broker, t=topic,
vt=virtual topic)
| |
P1 -- vt1 --> | | -- t1 (durable), vt1 > C1 t2 > BrKR
1
P2 -- t1 --> | |
P3 -- t1 --> |BrKR 1| -- t1 (durable), t5 (durable) --> C2 --
Hi.
We're testing out ActiveMQ 5.4.1 and it is much slower than ActiveMQ 5.2.
In our test case, with v5.2 we were able to process about 520,000 messages
in about 9 hrs but with ActiveMQ 5.4.1 it takes 18hrs to process 21,000
messages. So processing 520,000 messages would take days.
Are there
I am using message groups with ActiveMQ 5.4.1 and when ending the group I'm
seeing some odd behavior.
I run two consumers on Queue A. There is a 200ms delay when processing a
message. I have a producer send 100 messages with group A to the broker
with the last having a group sequence of -1.
Greetings,
DBA with here with some questions for the ActiveMQ development and user
community, hopefully you can provide some insight or relate experiences...
We have HA ActiveMQ brokers running against a SQL Server 2008 database that
is mirroring to secondary site. During a recent failover we f
http://old.nabble.com/Securing-the-web-console-impossible--tt16765525.html#a16784476
vbose wrote:
>
> I tried to follow the steps mentioned at the URL
> http://www.nighttale.net/activemq/securing-activemq-531-console.html
> securing-activemq-531-console to secure ActiveMQ 5.3.2 web console. B
ssage broker automatically sweeps destinations of expired
> messages every 30 seconds. You can change this default value via the
> 'expireMessagesPeriod' policyEntry attribute.
>
> Joe
> ActiveMQ Ref Guide - http://bit.ly/AMQRefGuide
>
>
>
>
> magellings
Hello,
I'm using ActiveMQ 5.2 and NMS 1.1.
I'm sending non-persistent messages to a broker with an expiration time of 1
hour. After one hour the messages are not deleted from the queue (can see
through jconsole and web console "number of pending messages"). After one
hour, no more messages ar
Hello. Does anyone have any idea why we'd be getting the exception when
posting from Fiddler?
--
View this message in context:
http://old.nabble.com/ActiveMQ-AJAX-Problems-tp28287864p28401870.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
-
> 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 Thu, Apr 22, 2010 at 5:51 PM, magellings wrote:
>
>>
>> > sr
http://sxdevweb1.qg.com:8099/shared/cache/jquery/142/jquery-1.4.2.js";>
http://sxdevweb1.qg.com:8099/shared/cache/jquery-ui/172/jquery-ui-1.7.2.js";>
amq = org.activemq.Amq;
amq.init({ uri: 'http://wamq
t; ActiveMQ in Action - http://www.manning.com/snyder/
> Blog - http://www.nighttale.net
>
>
> On Tue, Apr 20, 2010 at 4:13 PM, magellings wrote:
>
>>
>> Hello. I'm trying to get ActiveMQ AJAX to work but can't so far.
>>
>> I'm using fiddle
We run JDBC master/slave. There isn't any message lost provided you use the
failover protocol on the client side. When a message is sent to the broker
with the producer the broker sends an acknowledgment back when it has
persisted the message to the datastore. When a consumer consumes a message
If you use c3p0 as a connection pooler, then you can run a slave which will
retry to obtain the lock on the lock table. Then when the database is
restarted, or goes down, the master goes down, and the slave broker will
take over when the database comes back up. You'll then need something to
rest
Hello. I'm trying to get ActiveMQ AJAX to work but can't so far.
I'm using fiddler, and when I post to our address of
"http://wamqdev1:10201/demo/amq"; with request body of
"destination=topic://t1&message=message&type=send" I get a response with the
exception below. The topic I'm posting to does
what's your blog...and do you mean 25000 per second, or 25000 per 10 seconds?
Vibe from Boston wrote:
>
> I will be soon posting the benchmark stats on my blog, but I wanted to
> post it here.
> all on one meaty machine, Intel I7 64bit Windows server, 8GB ram.
>
> Client sends a message to nio
Why wouldn't you just use straight-up WCF? There is an ActiveMQ WCF
provider, albeit I'm not all that familiar with it.
Thierry M. wrote:
>
> Hi,
>
> I would like to know if it's possible to communicate between a C# Client
> application and a C# Web Service (hosted on IIS) using ActiveMQ for
ration is now:
>
>destroy-method="close">
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
> And at least in out development environment it is working ok. Thank you
> for your help!
>
>
> magellings wrote:
we are using c3p0 with sql server. Be sure there is a record inserted into
the lock table. If there isn't after 30s the master broker will fail as you
see and shutdown. You can ensure the record is inserted if you set
createTablesOnStartup to true, but then I'd recommend setting this back to
fa
got this one figured out...
just add the transacted = true property. must default to auto or client
acknowledgement...this sets it to a transactional session.
there's actually a lot of properties I'm assuming can be set...alb
Hello. When using the camel delayer the camel consumer takes a message off
the queue and sleeps the specified time. You can see in the web console
that the messages received column indicates a message was received, it then
waits X amount of time, and then forwards the message to the destination
Hi.
I'm trying to use the camel delayer with ActiveMQ 5.2 with the NMS ActiveMQ
provider. I can get the delayer to work when using the static delay method
(e.g. 1) but not when using the expression
syntax. I do not know what the precise value should be for the delayme
header. Should it be
Tim can you include the .xml intellisense files with the binaries? These
provide good user experience when developing against the referenced NMS
framework classes.
Right click project > Properties > Build > check "XML documentation file".
Then when you include the xml file in the same folder as
And if it calms your nerves a bit we are running the broker on Windows Server
2008 64-bit.
lernit2007 wrote:
>
> Hello,
>
> I don't find any information whether activeMQ run on Windows Server 2008
> x64. Have anybody an information for me?
>
> Thanks
>
--
View this message in context:
htt
We are using ActiveMQ 5.2 with MSSQL 2008 just fine.
we drop sqljdbc.jar in apache-activemq-5.2.0\lib\optional with Date Modified
timestamp of 10/11/2007 11:10AM (and we also use the c3po connection pooler)
add the following config in activemq.xml
Everything looks good from Quad/Graphics perspective except for issue
AMQNET-218
http://issues.apache.org/activemq/browse/AMQNET-218
AMQNET-218 is needed for consumers to shutdown properly inside a windows
service.
Timothy Bish wrote:
>
> * ANNOUNCEMENT *
>
> The Ap
have been delivered by its session.
Timothy Bish wrote:
>
> 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
&g
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 regar
>From what I can tell even with JMX properly set up you still can't maintain
seperate privs. One user/password is hard-coded/configured to be used by
the web console at start up to connect to the broker. I want to be able to
configure separate user/passwords to connect to the broker grabbed when
Hi.
I'm using ActiveMQ 5.2 and am wondering if there is a way to set the
userName and password properties in webconsole-embedded.xml based on
credentials entered with a basic authentication setup for the web console?
These are the credentials the web console uses to c
See http://www.nabble.com/Transactions-and-redelivery-td25915300.html
Alexey Romanchuk wrote:
>
> Thanks for reply Gary, it is exactly what I need. Could you also tell me
> where I can specify that failed message should go to the end of queue to
> allow to process other existing messages in q
y
> reconnecting, and then attempting to perform the exact same command which
> is causing the same exception to occur, and round and round it goes %-|.
>
>
>
> magellings wrote:
>>
>> I captured some stats from the broker before after this happened...
>>
>
Yes. The way we are doing it is adding a bit of metadata into the message to
keep a redelivery count. This is added only when we want to do a
redelivery.
Our framework sits on top of the NMS ActiveMQ provider (.NET). It parses
the metadata from the message. This redelivery logic is abstracted
We are sort of in the same boat.
Transactions generally are not just used for redelivery purposes. They also
are performance efficient as you can batch.
http://activemq.apache.org/should-i-use-transactions.html
What we are doing to avoid hang ups in clients on redeliveries is to use
ClientAckn
I can confirm I do see these exceptions when testing against ActiveMQ 5.2.
Just searched my logs...
log.txt(78574): 2009-10-12 12:27:34,780 [17400] [ERROR] Apache.NMS.Tracer -
RECEIVED Exception: System.IO.EndOfStreamException: Unable to read beyond
the end of the stream.
log.txt(234845): 2009-1
If it helps at all we are running ActiveMQ 5.2 on Windows Server 2008 64-bit
as a windows service and is working great.
Does require a 64-bit JRE or JDK.
titexe wrote:
>
> Hello,
>
> Does Fuse message broker supports Windows 2008? If yes 32 or 64 bit and
> what version of JVM?
>
> Thank you
I captured some stats from the broker before after this happened...
http://www.nabble.com/file/p25721340/stats2.txt Before
http://www.nabble.com/file/p25721340/stats5.txt After
Does anyone see any stat that sticks out as a problem?
magellings wrote:
>
> I found something inter
What acknowledgement mode are you using? It's my understanding if you are
using Transactional or ClientAcknowledge you shouldn't have this problem.
With AutoAcknowledge messages are buffered on the consumer end and are lost
if not processed when the consumer shuts down.
lujan99 wrote:
>
> Aft
ode this into the NMS ActiveMQ provider
and submit a patch for review.
[1] http://fusesource.com/docs/router/1.6/eip/MsgEnd-Idempotent.html
[2] http://activemq.apache.org/enterprise-integration-patterns.html
[3] http://camel.apache.org/idempotent-consumer.html
[4] http://issues.apache.org/activemq/
Evaluating this further it appears the broker is not persisting any
information back to the database when it dispatches messages to consumers.
I verified by removing update privs on the ACTIVEMQ_MSGS table as well as
insert, update, and delete privs on the ACTIVEMQ_ACKS table. Yes we are
using J
206)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
at java.lang.Thread.run(Unknown Source)
m
Hello. We are running JDBC Master/Slave with ActiveMQ 5.2 and upon failing a
master broker to slave broker we are seeing duplicate messages come through
to the consumers processing a queue. These messages are not flagged as
redelivered.
It's my understanding that the consumer is suppose to go t
>
> sorry to hear that Mark - do you have a test case ?
> On 24 Sep 2009, at 16:08, magellings wrote:
>
>>
>> Hello. I haven't gotten any feedback on this issue. To me seems
>> rather
>> important as JDBC Master/Slave is a common configuration and
Hello. I haven't gotten any feedback on this issue. To me seems rather
important as JDBC Master/Slave is a common configuration and if it doesn't
work with the NMS provider we at least will be out of luck with using 5.3
when it is released. This is of course if it is a problem with 5.3.
Could
Hello. We have our consumers set to a prefetch of 1000 (default).
I'd like to understand a bit more on how the broker handles situations where
a consumer prefetches messages but doesn't process them right away. For
example, A message is prefetched but not actually processed by the consumer
un
e official NMS 1.1 provider and
ActiveMQ 5.2.
http://www.nabble.com/Async-error-occurred--%3E-ActiveMQ-5.2-and-NMS-td25474605.html
magellings wrote:
>
> Hello curious if anyone has time to test this as I have with the sample
> application. Sql Server Express can be used
t out the cache fix but can't because of
these errors with even getting 5.3 to run out of the box.
-Thanks
magellings wrote:
>
>
> I'm attaching a sample app, configurations, and logs in a zip file. This
> uses the official 1.1 NMS provider. Ran a test against a 5.
d producer, consumer, and
broker does not recover. One can use Sql Server Express to set up the
database needed for jdbc master/slave. I did not test in another
master/slave configuration.
magellings wrote:
>
> Hello. We are stress testing ActiveMQ 5.2 using NMS for .NET
> producers
Hello. We are stress testing ActiveMQ 5.2 using NMS for .NET
producers/consumers. We are sending 200,000 messages through our system and
we ran into the error "Async error occurred" shortened for brevity. Log
file is attached. It seems this error keeps reoccuring after the first one
and fills
Zip file uploaded...
http://www.nabble.com/file/p25458793/ConsoleApplication1.zip
ConsoleApplication1.zip
--
View this message in context:
http://www.nabble.com/Getting-negative-number-of-pending-messages-tp22106707p25458793.html
Sent from the ActiveMQ - User mailing list archive at Nabble.c
a bit more NMS experience and 5.3 experience could overlook
this that would be great. Seems like something with jdbc master/slave may
be messed up.
If I get some help hopefully I can verify the original problem (caching bug)
is fixed in 5.3 as it is suppose to be.
magellings wrote:
>
>
;ll then perform
the test again against 5.3 with the official 1.1.
Timothy Bish wrote:
>
>
> What version of the NMS client are you using? Do you have a sample app
> that can causes this to happen I'd like to try and reproduce the NMS
> errors if possible.
>
> Regard
Note test went from 2009-09-09 14:01:29,918 to about 14:06.
I also needed to kill the broker.
magellings wrote:
>
> Using the wild-card address allowed the producers to connect.
>
> I'm getting a lot of exceptions in the activemq.log however with 5.3 so I
> can't te
th 5.3 "localhost" is local, not the wildcard address. you may need to
> use
> the wildcard address "0.0.0.0" if you localhost is tied to a different
> interface.
>
> 2009/9/9 magellings
>
>>
>> Okay I have 5.3 configured with the following confi
http://mortbay.com/schemas/jetty/1.0";>
rajdavies wrote:
>
> We are aiming to get a 5.3 release candidate to vote on next week - so
>
Right now we're focusing pretty hard on stress testing version 5.2 but we can
try and fit in a test. When is the estimated release date of version 5.3?
In other words, how much time do we have? :)
rajdavies wrote:
>
>
> On 4 Sep 2009, at 15:14, magellings wrote:
>
>>
Could anyone tell me what edition of the 32-bit wrapper we get when we
download activemq? Hopefully the 32-bit version is community...
We are running activemq on a 64-bit windows platform and need the 64-bit
version. Could anyone let me know if using the community edition would
suffice? http:/
We too were having problems were number of pending of messages was a negative
number and messages received was greater than number sent. We determined
there were indeed duplicate messages being sent.
We ended up setting useCache to false on the queue policy entry and the
problem appears to be re
Minor note.
java -cp lib/jetty-6.1.9.jar:lib/jetty-util-6.1.9.jar
org.mortbay.jetty.security.Password admin test
The : needs to change to a ; in order for java to search both JAR archives.
Otherwise you'll get a:
java.lang.ClassNotFoundException: org.mortbay.jetty.security.Password
Correct s
Hello
If a consumer processes a message and the session is rolled back then the
message is redelivered. The question I have is if this consumer dies (or
the session/connection disposed) before the message is redelivered its
maximum redelivered count can another consumer pick up this redelivered
Hello
I believe this test may not be fully testing the zero prefetch size
scenario.
If you add a consumer with prefetch (say 5) and produce 20 messages, the
consumer with prefetch should consume a static amount of messages. If two
zero prefetch consumers recieve twice, then there would be 18 me
Hello.
When setting PrefetchSize on the Session to 0 I do not obtain any messages
when using the Listener event on the MessageConsumer.
If I call Receive on the MessageConsumer to initiate a pull request I can
obtain messages. Can this work with the Listener event too and maybe I'm
missing some
ether through the root rss feed (as that has the text of the message) and
the various elements below.
On a side note does anyone know if or when the activemq nms framework will
implement a QueueBrowser API like the java provider does?
magellings wrote:
>
> Does anyone know how the conte
I tested on the latest 5.3 snapshot (-5.3-20090620.174423-1-bin) and the same
exception occurs. I don't know if this is related to NMS or not. Maybe you
could try to replicate it? Can you run your unit test and look at the
broker log to see if the error is logged?
magellings wrote:
&
snapshot.
>
> - Jim
>
> -----Original Message-
> From: magellings
>
> Date: Mon, 29 Jun 2009 11:56:20
> To:
> Subject: Re: uses virtual topic and ClientAcknowledge to submit
> themessage
> occured probem
>
>
>
> Hey Jim thanks for the
re all
> working. You can view the tests in VirtualTopicTest.cs in the
> Apache.NMS.ActiveMQ project.
>
> Regarding this particular problem, I would have to do further
> investigation to find the ultimate source of the problem.
>
> - Jim
>
> -----Original Message-
Is this an NMS specific problem or with the actual broker?
I see the link below but the user is saying everything works with java code.
Does anyone know what version of ActiveMQ Virtual Topics did work?
http://activemq.apache.org/virtual-destinations.html
pclovec wrote:
>
> i try to test
Does anyone know how the content below is encoded?
This is the response from drilling down the RSS feed on the webconsole. The
content is not the same content as the message contains. The content of the
message is "Grp0Guida739fb58-6c65-415e-b559-c4d6d01e80b4".
Example RSS link:
http://wamqdev
magellings wrote:
>
> I may have found a work around but I don't know the full implications of
> it.
>
> Spring allows one to initialize synchronization. Doing this along with
> reusing a ConnectionFactory will cache the session in which you don't take
> the hit of a
y.UserName = "frontend";
connectionFactory.Password = "pizz@";
magellings wrote:
>
> I believe I figured out the performance problem. Currently we are using
> JDBC master/slave.
>
> The major performance problem is the socket connection is
Looks like there is a possilbe syntax error for logging with NMS ActiveMQ 1.1
in the FailoverTransport doReconnect() method:
catch(Exception e)
{
failure = e;
Tracer.DebugFormat("Connect fail to: (0}, reason: {1}", uri, e.Message);
}
The "(0}" should be "{0}". Is this an item that could be
the logic to
always try the address that previously connected successfully first. If it
fails than the successfully connected address is updated to the address of
the new master broker and the process repeats.
magellings wrote:
>
> Hello. Has anyone used the 1.1 binaries for NMS and NMS.Ac
Hello. Has anyone used the 1.1 binaries for NMS and NMS.ActiveMQ from trunk
and the failover: protocol?
I'm experiencing a lot of slowness and I've found at least one comment (on
item in issue tracker) stating the same.
http://issues.apache.org/activemq/browse/AMQNET-26?focusedCommentId=47183&p
>
> hope this helps,
> Gary.
> 2009/4/7 magellings
>
>>
>> How do you exactly provide your own implementation?
>>
>> On the JDBCPersistenceAdaptor the createDatabaseLocker will always use
>> the
>> DefaultDatabaseLocker:
>>
>> prote
iveMQ 1.1.0
magellings wrote:
>
> Could anyone tell me if there is an estimated release date for NMS 1.1? I
> see there are only a few more open issues in the JIRA.
>
--
View this message in context:
http://www.nabble.com/Estimated-release-date-for-ActiveMQ-NMS-1.1-tp22089569p2
of the
> org.apache.activemq.store.jdbc.DefaultDatabaseLocker and implement
> keepAlive to be aware of your database backup policy.
>
> If you go down this route and conceive a better default or optional
> strategy, feel free to submit it as a patch.
>
>
>
> 2009/3/11 magellings
>
eriences, both positive and negative.
>
> Thanks,
> Jim
>
> On Wed, Feb 18, 2009 at 2:17 PM, magellings wrote:
>
>>
>> Could anyone tell me if there is an estimated release date for NMS 1.1?
>> I
>> see there are only a few more open issues in the JIRA.
I was successfully able to get everything working with login configured with
BASIC authentication and following all the steps in this thread by original
poster.
BASIC
adminRealm
Trying with DIGEST led me to the "all modules ignored" error, which also is
logged with a user who isn'
2.resourcepool.TimeoutException: A client timed out
while waiting to acquire a resource from com.mchange.v2.resourcepo
resourcep...@d964af -- timeout at awaitAvailable()
at
com.mchange.v2.resourcepool.BasicResourcePool.awaitAvailable(BasicResourcePool.java:1317)
at
com.mchange.v2.re
not.
In our scenario during a Sql Server failover it may take 15 minutes. We
aren't using a high availability cluster. Does a connection pooler give the
capability of dealing with this so that ActiveMQ doesn't shutdown?
bsnyder wrote:
>
> On Tue, Mar 10, 2009 at 1
Hello.
Does anyone know if there is logic in activeMQ to retry connecting to a
database if JDBC master/slave is configured? Perhaps there is some
configuration I'm missing. Right now we log ship from the active Sql Server
database to the passive Sql Server database. During maintenance it would
This isn't a question but an FYI for the ActiveMQ NMS Provider team.
Jetbrains is offering free CI for OSS now.
If you do not know or have not looked into CI it is very beneficial and I
recommend researching.
http://tinyurl.com/bv4jn4
-Mark (mark.gelli...@qg.com)
--
View this message in con
s people. Feel free to report back any of
> your experiences, both positive and negative.
>
> Thanks,
> Jim
>
> On Wed, Feb 18, 2009 at 2:17 PM, magellings wrote:
>
>>
>> Could anyone tell me if there is an estimated release date for NMS 1.1?
>> I
>
Could anyone tell me if there is an estimated release date for NMS 1.1? I
see there are only a few more open issues in the JIRA.
--
View this message in context:
http://www.nabble.com/Estimated-release-date-for-ActiveMQ-NMS-1.1-tp22089569p22089569.html
Sent from the ActiveMQ - User mailing list
91 matches
Mail list logo
