Hi all,
Does anybody know how to integrate Active MQ with IBM Websphere AppServer?
Currently I'm integrating Active MQ 5.2 with IBM Websphere AppServer 7.0 so
that the message-driven bean can be supported. What should I do with the JNDI
properties?
It will be much appreciated if any suggestions
Try this way:
Three brokers: b1, b2 and b3; with Queue named q1;
Config networkConnectors from b1 to b2 and b3;
For the Queue q1, run consumer application on b2 and b3; The messages put into
q1 will be dispatched to b2 and b3 in same weight.
I tried this configuration and found it worked well.
Hi all -
I wrote a publish/subscribe clients that seem to be working well with the
broker. I want make the clients more reliable - particularly when the
network connection goes down. This is especially needed for the subscriber,
which just sits on an asynchronous listener once the connection sta
2009/6/19 Denis Bazhenov :
> I'm interested in following topic. What does the InFlightCount mean if
> JMX console for queue.
>
> It's seems like in flight count is difference between dequeue count and
> dispatch count. But I have very strange situation.
>
> I have a queue which have following stati
I am not sure Denis but I enterprit it as bug in jmx console
Denis Bazhenov wrote:
>
> I'm interested in following topic. What does the InFlightCount mean if
> JMX console for queue.
>
> It's seems like in flight count is difference between dequeue count and
> dispatch count. But I have very st
>> I've got a simple ActiveMQ client running inside Tomcat. When I
>> shutdown Tomcat I get an exception from the "Inactivity Monitor Write
>> Check" thread. My question is has anyone seen this issue and have a
>> fix for it? I've tried making sure that I call the stop() method on
>> my CamelCon
Hi All,
I must admit that I am not a java pro or activeMQ. I want to use activeMQ
for our .NET app. I will be using Spring.NET NMS for this. We are also
wondering whether we can use Oracle AQ as persistence for activeMQ. I tried
to follow http://activemq.apache.org/jms-bridge-with-oracle-aq.html.
bsnyder wrote:
>
>
> The examples demonstrate the use of the broker URL to create a
> connection factory for a particular broker. The broker URL is noted in
> the activemq.xml configuration for the broker's transport connector
> configuration, specifically the uri attribute.
>
>
Sorry for
On Mon, Jun 22, 2009 at 2:40 PM, David Durham wrote:
> Hi all,
>
> I've got a simple ActiveMQ client running inside Tomcat. When I
> shutdown Tomcat I get an exception from the "Inactivity Monitor Write
> Check" thread. My question is has anyone seen this issue and have a
> fix for it? I've trie
On Mon, 2009-06-22 at 12:57 -0700, pclovec wrote:
> HI all
>
> i try to test CMS asyn send function. found out when i try to setup
> &connection.producerWindowSize=XXX, this option. seems it doesn't work ,
>
> i switch to java client and setup the produceWindowSize=XX ,and running
>
HI all
i try to test CMS asyn send function. found out when i try to setup
&connection.producerWindowSize=XXX, this option. seems it doesn't work ,
i switch to java client and setup the produceWindowSize=XX ,and running
the test program , is work
so anyone have meet this probl
Hi all,
I've got a simple ActiveMQ client running inside Tomcat. When I
shutdown Tomcat I get an exception from the "Inactivity Monitor Write
Check" thread. My question is has anyone seen this issue and have a
fix for it? I've tried making sure that I call the stop() method on
my CamelContext,
On Mon, Jun 22, 2009 at 1:28 PM, demonair wrote:
>
>
> Yes I saw this examples, and I'm using the two separate so as to send and
> receive messages.
>
> but not send data to a queue that is in another machine
The examples demonstrate the use of the broker URL to create a
connection factory for a p
Yes I saw this examples, and I'm using the two separate so as to send and
receive messages.
but not send data to a queue that is in another machine
--
View this message in context:
http://www.nabble.com/Can-not-connect-to-another-machine--tp24152072p24153799.html
Sent from the ActiveMQ - Use
On Mon, Jun 22, 2009 at 11:41 AM, demonair wrote:
>
> Hi all
>
> I'm using ActiveMQ, to send and receive messages.
>
> But now I want to connect to another machine to send and receive messages,
> but not how to do it, I have to change to pass another ip?
>
> for example:
>
> private String url = "1
Hi all
I'm using ActiveMQ, to send and receive messages.
But now I want to connect to another machine to send and receive messages,
but not how to do it, I have to change to pass another ip?
for example:
private String url = "10.4.230.23";
and this is where IP sends and receives messages,
hop
On Mon, Jun 22, 2009 at 9:07 AM, demonair wrote:
>
>
>
> demonair wrote:
>>
>> Hi all
>>
>> I have a problem when trying to insert more than 4000 data to the queue
>> will not let me.
>>
>> No error mark, only no insert more..
>>
>> I need to configure the queue to accept more data?
>>
>> if so, ar
demonair wrote:
>
> Hi all
>
> I have a problem when trying to insert more than 4000 data to the queue
> will not let me.
>
> No error mark, only no insert more..
>
> I need to configure the queue to accept more data?
>
> if so, are some examples of this.
>
> Thanks in advance.
>
>
Wel
Hi,
I'd like to clarify my question a bit.
I'm using ActiveMQ as a Jms to Jms Bridge - source is a tibco messaging
server and destination is local queue. I then expose the messages via a
stomp connector so I can use a perl script to read them. I understand that
temporary queues are not removed u
I'm using the default persistence mechanism (kaha). Anyone have hints on this
error?
SEVERE RecoveryListenerAdapter - Message id xx could not be recovered
from the data store - message already dispatched
--
View this message in context:
http://www.nabble.com/Activemq-5.2---recoverMessage
On Mon, Jun 22, 2009 at 7:02 AM, jet3723 wrote:
>
> Product: Activemq 5.2
>
> I'm having an issue with activemq creating tables when Postgres 8.1 is the
> persistence database. The error that I get is this:
> WARNING: Could not create JDBC tables; they could already exist. Failure
> was: CREATE TAB
Product: Activemq 5.2
I'm having an issue with activemq creating tables when Postgres 8.1 is the
persistence database. The error that I get is this:
WARNING: Could not create JDBC tables; they could already exist. Failure
was: CREATE TABLE ACTIVEMQ_MSGS(ID INTEGER NOT NULL
, CONTAINER VARCHAR(2
On Mon, Jun 22, 2009 at 6:33 AM, pstein wrote:
>
>
> bsnyder wrote:
>>
>>> Is this JMS message now out-of-the-box (=by default) kept persistent
>>> (e.g.
>>> in a textfile) until it is fetched from a JMS consumer?
>>
>> Yes, the message is persisted. ActiveMQ 5.x uses the AMQ Message Store
>> as th
bsnyder wrote:
>
>> Is this JMS message now out-of-the-box (=by default) kept persistent
>> (e.g.
>> in a textfile) until it is fetched from a JMS consumer?
>
> Yes, the message is persisted. ActiveMQ 5.x uses the AMQ Message Store
> as the default persistence store:
>
> http://activemq.apache
Hi,
Could anyone let me know how to do configure load balancing in Active MQ
My requirement in For example if a queue has received 5 messages means the
next 5 messages has to be routed to another queue and so on
I was successfully able to achieve the failover scenario i.e if a queue
f
25 matches
Mail list logo
