I'm so stucked on configuring like the below..
it's been for 5 days..
Condition...
1) producer , consumer and broker is loaded on same jvm.
2) each producer in one server have to deliver messages to the producer of
same server.
3) if one of servers is killed, I want the other server's broker
Hi ,
I read about prefetch limit and found out that the default value is : 100
for Durable subscriber. So for testing this what i am doing is : I have
three subscriber in offline mode and I am trying to publish more than 100
messages expecting after crossing the prefetch limit it should block
Thanks Christian,
On
'Maybe just write a camel route to put those messages into a database for
future analysis? '
- Will definitely consider that.
Does this also mean - I am fundamentally 'not' using DLQ in Message-Broker
for what they are actually meant for?
i.e. is it always a bad idea to
I have designed a chat application based on websocket protocol.
i have installed a xampp server in computer A .I start the server in
computer A and then I am trying to access client.php page (url is
ipadresssofA/project/client.php) from computer B using the ip address of
computer A. But it is
I have designed a chat application based on websocket protocol.
i have installed a xampp server in computer A .I start the server in
computer A and then I am trying to access client.php page (url is
ipadresssofA/project/client.php) from computer B using the ip address of
computer A. But it is
This is probably not the forum you want as this doesn't sound like it has
anything to do with ActiveMQ.
Check your firewall settings.
And check if you bound the socket to localhost or the IP address of your
machine. You want to bind the socket to your IP address.
-Original Message-
It work with the 5.8.0 version,
We should add this in the activemq.xml config file
Default value is true
--
View this message in context:
http://activemq.2283324.n4.nabble.com/How-do-I-remove-ActiveMQ-Advisory-Producer-Consumer-Queue--tp2358046p4666883.html
Sent from the ActiveMQ - User
When a message goes into a DLQ it means the consumer cannot handle this
message for one reason or another so it should be looked at. For your
usecase, if it's fine that messages can go undelivered and it's not a big
deal, you can just ignore the DLQ and use discardingDLQBrokerPlugin to
just drop
try setting enableAudit=false on the DQL strategy you're using
On Thu, May 9, 2013 at 6:22 AM, Christian Posta
christian.po...@gmail.comwrote:
sounds like it should work, but your best bet is to alter Tim's test case (
Prefetch does not imply blocking the producer. I recommend reading these
two wiki links closer. Below are the salient points:
From http://activemq.apache.org/what-is-the-prefetch-limit-for.html:
ActiveMQ uses a prefetch limit on how many messages can be *streamed to a
consumer* at any point in
in your diagram, all four brokers cannot be live and share the same
datastore. You can set up a shared datastore using master/slave per two
brokers. That is, when broker A and B are connected to the same datastore,
broker A is master and B is slave. So when broker A dies, B can take over
where A
Yah, could be unintentional. Can you make this comment on the
https://issues.apache.org/jira/browse/AMQ-4033 JIRA?
On Wed, May 8, 2013 at 4:33 PM, Benjamin Jansen
bjansen-activ...@w007.orgwrote:
Hello,
I have been researching how to restrict JMX to bind to a loopback address,
so that it is
Hi,
In our system, Camel produces JMS messages from integrated endpoints, which
are consumed by EJB MDBs.
The EJB application in-turn produces new JMS messages, which are consumed by
Camel to send to other integrated endpoints (eg. WebSphere MQ).
We use transacted routes, and Atomikos as XA
No, prefetch is for consumers.
http://activemq.apache.org/what-is-the-prefetch-limit-for.html
Timing would be your issue here. Unless you have control of when the
producers are producing, it could be tough to guarantee the scenario you
want, ie, if producer A, B, and C are independent, they could
Hi,
Can the following options also be used on a STOMP transport connector?
watchAdvisoryTopics, alwaysSessionAsync and dispatchAsync
Thanks,
Paul
Hi all,
I use activemq as it is embeded in SMX 4.5.0
I'm trying to use the jdbc message storage with Microsoft SQL Server as I
want to achieve master/slave topology among brokers.
In my activemq-broker.xml I have
/persistenceAdapter
jdbcPersistenceAdapter
I have the following broker topology:
NC1 e NC2 are configured with uri=multicast://239.255.2.4 e TTL=5.
duplex=false on both NC1 and NC2.
Both brokers create a openwire transport connector with nio://0.0.0.0:61616
and discoveryURI=multicast://239.255.2.4. Besides, the following
Not sure why consumers are blocked. Are they acking?
---
No, they are not acking at all, they seem to be blocked.
I ran 2 sets of tests.
For both tests following is the route set up
from uri=file:/opt/share/EventFileInput?move=.event-done/
setHeader
On May 10, 2013, at 06:56 , Christian Posta wrote:
Yah, could be unintentional. Can you make this comment on the
https://issues.apache.org/jira/browse/AMQ-4033 JIRA?
Will do.
Thanks,
Ben
On Wed, May 8, 2013 at 4:33 PM, Benjamin Jansen
bjansen-activ...@w007.orgwrote:
Hello,
I have
I have this network connector configuration on both client and server
machine.
networkConnectors
networkConnector name=network uri=static:(tcp://hostname)
networkTTL=4 conduitSubscriptions=false duplex=true
excludedDestinations
queue physicalName=/
Ok, I think I just re-discovered this one: AMQ-4505
What would you suggest? To recompile trunk? Is there a patch that could be
applied to 5.8.0 codebase?
Thanks
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Client-Failover-in-a-brokers-network-tp4666899p4666925.html
Maybe try out the nightly snapshots to see if it is resolved for you:
https://repository.apache.org/content/repositories/snapshots/org/apache/activemq/apache-activemq/5.9-SNAPSHOT/
On Fri, May 10, 2013 at 1:56 PM, matteor matteo.ru...@abodata.com wrote:
Ok, I think I just re-discovered this
I'm not entirely clear what your question is... but I'll give it a shot...
If a broker with a network connector loses connectivity to the network, the
static: part of the network uri will use a discovery mechanism that
continues to try to reconnect. When the network comes back, the connections
Yes, send the camel route and broker configs, etc. Your description seems
to be mixing camel consumer with jms consumer.. if you send a test
case, i can explain to you what's happening.
On Fri, May 10, 2013 at 9:17 AM, deepak_a angesh...@gmail.com wrote:
Not sure why consumers are blocked. Are
So you said transport connector... as in broker side... those options are
for client-side connections and apply to the ActiveMQConnectionFactory.
What client are you using to connect with JMS?
On Fri, May 10, 2013 at 7:49 AM, Paul Gale paul.n.g...@gmail.com wrote:
Hi,
Can the following
s/JMS/the broker
On Fri, May 10, 2013 at 4:09 PM, Christian Posta
christian.po...@gmail.comwrote:
So you said transport connector... as in broker side... those options are
for client-side connections and apply to the ActiveMQConnectionFactory.
What client are you using to connect with JMS?
Hi Christian,
*
What client are you using to connect with JMS?*
Java JMS, .NET and Ruby based STOMP clients. I'm only involved with the
Ruby clients. I have no idea how a JMS client is coded.
Are all of these options reserved exclusively for non-STOMP clients?
inline...
On Fri, May 10, 2013 at 6:44 PM, Paul Gale paul.n.g...@gmail.com wrote:
Hi Christian,
*
What client are you using to connect with JMS?*
Java JMS, .NET and Ruby based STOMP clients. I'm only involved with the
Ruby clients. I have no idea how a JMS client is coded.
Are all of
28 matches
Mail list logo
