Hi all
I'm trying to configure a master/slave conf with JDBC. I can't get the JDBC
to work with sql server 2008:
18:02:45,875 [main] WARN JDBCPersistenceAdapter - Database driver NOT
recognized: [microsoft_sql_server_jdbc_driver_2_0]. Will use default JDBC
implementation.
18:02:46,125 [main] WA
Have you read this - http://codedependents.com/2009/10/16/efficient-lightweight-jms-with-spring-and-activemq/
- it may help
On 20 Jan 2010, at 01:35, go canal wrote:
I need to use message-driven-channel-adapter.
From: go canal
To: users@activemq.apache.org
Yes - those settings apply to the both FileCursor and Kaha (which is
used by the AMQStore). - can you share the configuration you are using?
KahaDB isn't the same as Kaha - we weren't very imaginative with names
Im afraid
On 19 Jan 2010, at 23:48, rideallday wrote:
Rob,
I'm seeing the exa
Hey - that's great to hear!
On 19 Jan 2010, at 23:13, jongraf wrote:
Our load tests have completed and I am proud to report that reading
the
documentation, educating the entire technical team and documenting the
various ActiveMQ settings in our properties files has led to a
significant
p
I am having problems with the following configuration and I hope someone can
shed some light on my problem.
I have a persistent topic with one producer and one consumer. The producer
puts out 5 messages per hour. Each message is approximately 45MB in size and
is sent as a serialized java object.
I
Hi,
Thank you for your reply.
I do initialize and shutdown the library.
Here is the complete code.
int main(int argc AMQCPP_UNUSED, char* argv[] AMQCPP_UNUSED) {
activemq::library::ActiveMQCPP::initializeLibrary();
std::cout << "=\n
I need to use message-driven-channel-adapter.
From: go canal
To: users@activemq.apache.org
Sent: Wed, January 20, 2010 8:53:39 AM
Subject: Re: Configuring a topic in Spring with default ActiveMQ
I think I need to add:
Now I can receive messages but only th
I think I need to add:
Now I can receive messages but only the first one. I can not get subsequent
messages.
This is my service activator:
@ServiceActivator
public void upperCase(String input) {
System.out.println ("message received : " + input);
}
Anything I missed out ?rgds,
canal
Rob,
I'm seeing the exact same behaviour as Daniel,
>
> So I would recommend the following
>
> 2. Try KahaDB - which - with the BTreeIndex - will not hit the
> problems you are seeing with the Filecursor
>
>
however I am already using KahaDB as the persistenceAdapter.
Your advice seem
Hi,
I am running the default ActiveMQ 5.3.0. Wanted to configure a
publish-subscribe-channel in Spring. But I am not able to get any data, this is
my Spring configuration, anything wrong :
appreciate your help,
canal
On Fri, 2010-01-15 at 00:32 -0800, diedie wrote:
> Hi,
>
> I recently upgraded my cms library from 3.0 to 3.1(built using vs-2005),
> and face some issues that handle leaks when reconnecting to server.
>
> So I wrote a simple testing program based on vs2005-activemq-example,
> and found that it
Our load tests have completed and I am proud to report that reading the
documentation, educating the entire technical team and documenting the
various ActiveMQ settings in our properties files has led to a significant
performance increase.
Our web app hit 1750 hits per second with 1,000 virtual u
you are correct about the port requirement - a different port for each
broker is only required if they run on the same host
On 19 Jan 2010, at 22:30, johnluo1 wrote:
Hi,
I am looking at activemq-dynamic-network-broker1.xml and
activemq-dynamic-network-broker2.xml, (and also mentioned at
http
Hi,
I am looking at activemq-dynamic-network-broker1.xml and
activemq-dynamic-network-broker2.xml, (and also mentioned at
http://fusesource.com/docs/broker/5.3/connectivity_guide/connectivity_guide.pdf
page 74), it seems brokers in a cluster need to run at different port?
I guess for running a
ok - thanks for the feedback!
On 19 Jan 2010, at 21:05, quinn wrote:
Thanks very much for the response.
After rebooting it is working again. If I can reproduce, I will post
again.
rajdavies wrote:
ok - some basic things to re-check - just in case:
1. so in the broker config only you h
Thanks very much for the response.
After rebooting it is working again. If I can reproduce, I will post again.
rajdavies wrote:
>
> ok - some basic things to re-check - just in case:
> 1. so in the broker config only you have set tcp://0.0.0.0:port
> 2. your remote client is using tcp://hostn
The WCF library creates endpoint connection mappings. If you are doing WCF
style programming, this is the higher level library you would use. If your
application is not designed around WCF, then you don't need it. Use the normal
NMS API interfaces.
- Jim
-Original Message-
From: Tim
I wonder if your issue is related to the pageSize, default 200, the amount
of messages that the broker will keep in memory for a destination. If your
selection criteria matches a message further down the queue than the
pageSize it will not be dispatched till those ahead of it in the queue are
consu
Thank you. A rest interface does make sense here. Since consuming
applications would be deployed to a different locations. Could I write
specific servlets in the jetty container for a REST interface?
My other question is even if I deployed an application to the embedded jetty
server and used the
sry - Jaime - fuse jira better for STOMP
On 19 Jan 2010, at 16:58, Jamie McCrindle wrote:
Ah, ok, I'll raise it in the ActiveMQ jira, I was just directed to the
FuseSource jira
cheers,
j.
On Tue, Jan 19, 2010 at 4:56 PM, Rob Davies
wrote:
You just need to register in jira -
https://issues.
Hi Jamie,
you can register fuse account here https://fusesource.com/login
and then you should be able to submit issues to stomp project directly
http://fusesource.com/issues/browse/STOMP
Cheers
--
Dejan Bosanac - http://twitter.com/dejanb
Open Source Integration - http://fusesource.com/
ActiveM
Ah, ok, I'll raise it in the ActiveMQ jira, I was just directed to the
FuseSource jira
cheers,
j.
On Tue, Jan 19, 2010 at 4:56 PM, Rob Davies wrote:
> You just need to register in jira -
> https://issues.apache.org/activemq/secure/Signup!default.jspa - then you
> should be able to raise a bug
>
You just need to register in jira - https://issues.apache.org/activemq/secure/Signup!default.jspa
- then you should be able to raise a bug
On 19 Jan 2010, at 16:49, Jamie McCrindle wrote:
Hiya,
We've worked around the problem by increasing the buffer size but it's
not the best solution. I'd l
Hi,
AjaxServlet can't be exposed to the web in general. It must be a part of the
application which is running the client js code to send/receive messages. If
you need a general-purpose web interface, try using REST. As for security
you can secure it using basic-auth or any other method used on the
Hiya,
We've worked around the problem by increasing the buffer size but it's
not the best solution. I'd like to raise a bug in Jira but it's for
authorized users only. Is there another way to get it in?
cheers,
j.
On Thu, Jan 14, 2010 at 11:30 AM, Jamie McCrindle
wrote:
> Will post an issue. I'
that'll be the jmx implementation - which is part of the JRE - can you
run with out jmx ?
On 19 Jan 2010, at 16:25, moreno9000 wrote:
Hi rajdavies,
I see a lot of threads like this one:
"JMX server connection timeout 6925" daemon prio=10 tid=0x08faf000
nid=0x2759 in Object.wait() [0xac0ae00
I've developing an application on google's app engine. I would like to
integrate it with active mq. I figure I could put my active mq server
exposed to the web except I would need to authenticate users before allowing
them to pub sub to the Q. How should I do this. I basically want them to log
int
Hi rajdavies,
I see a lot of threads like this one:
"JMX server connection timeout 6925" daemon prio=10 tid=0x08faf000
nid=0x2759 in Object.wait() [0xac0ae000..0xac0af130]
java.lang.Thread.State: TIMED_WAITING (on object monitor)
at java.lang.Object.wait(Native Method)
- waitin
Hi moreno,
can you take a stack trace of the broker ? - the threads should be
getting garbage collected
thanks,
Rob
On 19 Jan 2010, at 10:37, moreno9000 wrote:
I confirm Marcin's problem (with AMQ 5.3).
One producer (java application with transport=openwire)
For each message producer ope
On Tue, 2010-01-19 at 01:21 -0800, titexe wrote:
> Hello,
>
> i'm trying to develop listener for my application in .Net,
>
> Two solution are available :
>
> 1- Listener .Net NMS Activemq
> 2- Listener WCF NMS Activemq
>
> the first solution, don't handle exeptions of listener, like network
> i
An additional observation:
The size of the dispacthed queue seems also to be equal the (largest) number
of messages I received in a row. E.g. if I received 5 message the webconsole
looks like this:
"Enqueues 10; Dequeues 5; Dispatched 10; Dispatched Queue 5"
If I receive 10 messages later from
No,
sorry no simple testcase and currently don't have the time to create one.
As I can the see from the 'Prefetch 0' in the web console, prefetchSize
seems to get noticed from ActiveMQ. However, it doesn't seem to have any
effect on the dispatched queue.
I can only provide this code snippet cu
I would strongly recommend moving up to 5.3. A LOT of issues have been
addressed since 5.1.
AFAIK, you cannot control the size of in-memory queues based on the number
of messages. If that is indeed the case, you could submit a JIRA requesting
this feature.
If these are transient messages and y
prefetch==0 should be the answer here. Do you have a simple test case you
can share?
2010/1/19 Christoph Kutzinski
> Hi,
>
> let me first describe my use-case as it is probably a little bit different
> from the usual JMS use case:
>
> We have a single process which fills a JMS queue from a pool
I confirm Marcin's problem (with AMQ 5.3).
One producer (java application with transport=openwire)
For each message producer open a Connection, send a msg, close the
Connection.
Server side no problem for what concern file descriptors opened,
memory usage, socket opened (with netstat I see all c
Hi,
let me first describe my use-case as it is probably a little bit different from
the usual JMS use case:
We have a single process which fills a JMS queue from a pool of available items
(say we have 50 items total).
The we have n consumers (lets say 2) which read the items from the queue in a
Hello,
i'm trying to develop listener for my application in .Net,
Two solution are available :
1- Listener .Net NMS Activemq
2- Listener WCF NMS Activemq
the first solution, don't handle exeptions of listener, like network
interruption, retryetc
I would like to know the difference between
Hi Joe,
I'd found the file to change the location of the activemq-data dir. It's in
my activemq web console/WEB-INF/activemq.xml. It works just like what I
wanted it to be. Thanks a lot for the help.
Cheers,
Florence
Florence.Tan wrote:
>
> Hi Joe,
>
> Thanks a lot for your feedback. But
38 matches
Mail list logo
