This is how my MessageListener looks like:
*public class Listener implements MessageListener {
public void onMessage(Message message) {
try {
MapMessage map = (MapMessage)message;
Long msgCount = map.getLong("counter");
Below is how my Consumer looks like:
*public class Consumer {
private static String brokerURL =
"failover:(tcp://localhost:61616,tcp://localhost:61617)?maxReconnectAttempts=-1";
private static transient ConnectionFactory factory;
private transient Connection connection;
private tr
So if I set broker centos-test3 as a unidirectional bridge- it cannot
be a consumer, only a producer on a queue.
how does real world deployments handle data going in both directions?
I can think of two ways:
1.) put the broker in a less restricted DMZ zone in a company with
less ports blocked.
2
If it is duplex, it is not configurable to use a certain port or specific range?
For my case, I am not 100% certain at this time whether unidirectional
will work the the business case.
On Wed, Aug 22, 2012 at 5:07 PM, ceposta wrote:
> The network connector in broker 2 has duplex set to "true"
The network connector in broker 2 has duplex set to "true"
This will open a connection in both directions, which explains the random
port on broker1.
Can you try having uni-directional network connectors on each broker?
-
http://www.christianposta.com/blog
--
View this message in context:
h
attached: activemq-centos-test1.xml for broker 1
attached: activemq-centos-test3.xml for broker 2.
On Wed, Aug 22, 2012 at 3:46 PM, ceposta wrote:
> From your logs:
>
> sk92129 wrote
>>
>> 2012-08-22 12:58:21,363 | INFO | Listening for connections at:
>> ssl://centos-test1.foo.com:61616?needC
This is a difficult question to answer but briefly, it will depend on the
services' design, state management of the system, concurrency-model, the
domain and what the services will be doing. I presume they will have
different behaviors with a mixture of cpu-bound, diskIO-bound,
networkIO-bound, etc
>From your logs:
sk92129 wrote
>
> 2012-08-22 12:58:21,363 | INFO | Listening for connections at:
> ssl://centos-test1.foo.com:61616?needClientAuth=true |
> org.apache.activemq.transport.TransportServerThreadSupport | main
>
You can see from your config:
sk92129 wrote
>
>
>
Hi -
I'm trying to figure out the architecture for a large scale system that
I'm building that consists of hosting a number of services that would use a
pub/sub pattern. Could some please let me know the pros and cons of using
embedded broker Vs. standalone brokers especially in terms of scalab
I can recreate this as you've described. Not sure why it's happening. I've
opened a JIRA for it and will hack at it when I get a sec.
https://issues.apache.org/jira/browse/APLO-246
-
http://www.christianposta.com/blog
--
View this message in context:
http://activemq.2283324.n4.nabble.com/
Further investigation seems to show that if I extract Apollo into C:\Apollo
it works just fine. If I extract to D:\Apollo it does not.
If I extract and install from D:\Apollo and then (just to test) extract to
C:\Apollo before starting the Windows Service it will start just fine. Looks
like there
Maybe this activemq.log might shed more light on this:
2012-08-22 12:58:20,497 | INFO | ActiveMQ 5.6.0 JMS Message Broker
(static-broker-centos-test1) is starting |
org.apache.activemq.broker.BrokerService | main
2012-08-22 12:58:20,497 | INFO | For help or more information please
see: http://ac
Sure... I've no spaces in my path with the exception of the location of
java.exe. apollo-broker-service.xml looks like this:
org.apache.activemq.apollo.Test
Apollo: Test
Apache Apollo is a reliable messaging broker
D:\Apollo\Test\log
roll
"C:\Program Files\Java\jre7\bin\java.exe"
I have two centos machines up and running. When I disable or turn
off iptables, the one broker can establish a transport bridge with the
other broker on the other centos machine.
I noticed that the port number being used changes -- 53033, 53067, etc..
How can I configure each broker in the stat
Well as per the docs, it is so!
http://activemq.apache.org/failover-transport-reference.html
maxReconnectAttempts=-1 will try indefinitely! I will try that tomorrow on
my cluster configuration and let know the results here!
Thanks for all the help!
--
View this message in context:
http://act
I would try increasing the maxReconnectAttempts to a bigger value. Is there a
rule of thumb as to how big this should be? Is there an indefinite try? what
happens if I specify -1? Will it try indefinitely until it gets a
connection? I would love to have that!
--
View this message in context:
ht
The problem is that you're duplicating functionality. The shared database
means that the two brokers share the information they are receiving by
placing it in a shared location, i.e. the database. The Network of Brokers
is a different way of sharing the information between the brokers, by
transmi
At least from what I'm seeing in *ActiveMQ in Action*, that looks right.
Could it be that your maxRecoveryAttempts=1 is preventing it from
recovering the second time? (I'm fairly new to this myself)
(*Chris*)
On Wed, Aug 22, 2012 at 10:32 AM, joesan wrote:
> I'm happy to see some help at las
It's not with two hosts, but with two hosts and a shared database, I lock the
second to a waiting state. I got the point. So my earlier understanding was
correct that with a Master / Slave and a shared database lock, the slave
will not start it's transport connectors and will wait for the lock.
Li
With 2 hosts, you lock the second host in a waiting state.
If you have 4 hosts and two shared databases you can have a NOB.
On Aug 22, 2012, at 12:16 PM, joesan wrote:
> Thanks for the reply. Can you explain me why that with a shared file system I
> cannot have a network of brokers?
>
>
>
> -
Thanks for the reply. Can you explain me why that with a shared file system I
cannot have a network of brokers?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Network-of-Brokers-tp4655435p4655444.html
Sent from the ActiveMQ - User mailing list archive at Nabble.
If you have two brokers with a shared database
you cannot also have network connectors
between them, it doesn't make sense.
you can use a failover url for the clients.
On Aug 22, 2012, at 11:56 AM, joesan wrote:
> When I configure the networkConnector in the activemq.xml file, I'm doing a
> ne
When I configure the networkConnector in the activemq.xml file, I'm doing a
network of brokers. Did I get it correctly?
When my clients use a failover protocol, it is a failover scenario. Is this
correct as well?
In my case, I have both. Something similar to this.
http://fusesource.com/docs/brok
I'm happy to see some help at last.
Here is how the fail-over url looks like from my clients (both producer and
consumer)
failover:(tcp://localhost:61616,tcp://localhost:61617)
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Clustering-Issue-tp4655306p4655440.
You are mixing failover with nob.
Not the same thing.
On Aug 22, 2012, at 11:30 AM, joesan wrote:
> But isn't configuring the networkConnectors with a static discovery in the
> activemq.xml configuration file is a network of brokers?
>
>
>
> --
> View this message in context:
> http://active
But isn't configuring the networkConnectors with a static discovery in the
activemq.xml configuration file is a network of brokers?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/ActiveMQ-Network-of-Brokers-tp4655435p4655439.html
Sent from the ActiveMQ - User mailing lis
That's not a network of brokers, it's a single broker with a failover. For
a network of brokers you would need multiple databases.
(*Chris*)
On Wed, Aug 22, 2012 at 9:28 AM, joesan wrote:
> I"m trying to understand the concept behind the network of brokers in
> ActiveMQ. What I understand fro
What is the connection URL you are using on your clients?
(*Chris*)
On Wed, Aug 22, 2012 at 12:16 AM, joesan wrote:
> Any help friends?
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/ActiveMQ-Clustering-Issue-tp4655306p4655410.html
> Sent from the ActiveMQ -
You appear to be missing the required slf4j-api-1.6.4.jar dependency.
(*Chris*)
On Tue, Aug 21, 2012 at 2:33 PM, offbyone wrote:
> When trying to start a broker I get this error on brokerService.start():
>
> BrokerService brokerService = new BrokerService();
> brokerService.setPersistent(false
I"m trying to understand the concept behind the network of brokers in
ActiveMQ. What I understand from the documentation is that by having a
network or broker we can get load balancing. I would assume that load
balancing would mean that the messages are sent to either one of the brokers
(Master or
The problem is now solved...
It turns out that ActiveMQSslConnectionFactory.setKeyAndTrustManagers does
not work (at least in this context).
Replacing that the following does work:
System.setProperty("javax.net.ssl.keyStore",KEY_STORE_FILE_NAME);
System.setProperty("javax.net.ssl.keyStorePasswor
if you attach your config files i can give it a try on my side
-
http://www.christianposta.com/blog
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Store-and-Forward-with-embedded-brokers-stand-alone-broker-tp4655028p4655431.html
Sent from the ActiveMQ - User mailing
What version of ActiveMQ is your user using? If its any later version, i.e.
5.5.0 or higher, I suggest switching to KahaDB as the persistence adapter.
Torsten Mielke
tors...@fusesource.com
tmie...@blogspot.com
On Aug 21, 2012, at 8:02 AM, Jamie wrote:
> Hi Everyone
>
> A user is complaini
If you're starting with ActiveMQ, do you really want to use such an old version?
I highly encourage you to upgrade to the latest 5.6 version if that is
possible.
Torsten Mielke
tors...@fusesource.com
tmie...@blogspot.com
On Aug 22, 2012, at 11:28 AM, Sri wrote:
> Hi ,
>
> I am using activemq
I just tried on Windows Server 2008 R2 on EC2. I suspected what Hiram
mentioned, but it still worked (path with spaces). Could you post your
apollo-broker-service.xml?
-
http://www.christianposta.com/blog
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Apollo-as-Windo
What is more troubling me is that the messages sent by the Producer to a
Topic is lost when the Master goes down. When I restart my consumer, all
those messages that the Producer had sent to the Topic was lost. How do I
handle this? Where is the high availability in picture in this AMQ
Clustering?
Hi Everyone
A user is complaining about his application logs being filled up with
"Store is locked... waiting 10 seconds". The KahaPersistenceAdapter
seems to be having trouble obtaining a lock. I am using an embedded
broker, but the broker is only ever started once. I am quite sure of
this.
If your only concern on the client side is to not pile up messages then
why don´t you simply use a topic for the reply?
Give each client his own topic on the broker by the servers. If there is
no client listening on the topic then the message can be simply discarded.
This has the advantage that
issue resolved, tag 1.0.1 located to Geronimo specs with help at
us...@geronimo.apache.org:
http://apache-geronimo.328035.n3.nabble.com/Missing-sources-to-geronimo-jta-1-0-1B-spec-1-0-1-tt3985620.html#a3985621
br,
Martti
--
View this message in context:
http://activemq.2283324.n4.nabble.com/m
When trying to start a broker I get this error on brokerService.start():
BrokerService brokerService = new BrokerService();
brokerService.setPersistent(false); //Simpler for testing
brokerService.setSupportFailOver(false);
brokerService.addConnector("tcp://127.0.0.1:61616");
brokerService.start();
Hi ,
I am using activemq 5.4.1 on my window desktop. First time when I start
using activemq.bat , it is working fine. But from second time onwards it was
not starting properly and I need to reinstall I mean need to unzip installer
and again use . is there any where I need to set any settings to av
Can u post the logs?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Activemq-needs-to-be-reinstalled-every-time-tp4655412p4655413.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Here is the log that I am getting for that.
Java Runtime: Sun Microsystems Inc. 1.6.0_32 C:\Program
Files\Java\jdk1.6.0_32\jre
Heap sizes: current=124544k free=121942k max=466048k
JVM args: -Dcom.sun.management.jmxremote -Xmx512M
-Dorg.apache.activemq.UseDedicatedTaskRunner=true
-Djava.ut
We're running Apollo 1.4 under Windows 7 and Windows Server 2008 R2; same
problem on both. procmon doesn't seem to bring anything obvious from a
permissions perspective so I'm struggling a little to pinpoint the cause!
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Apoll
Hi all,
I've followed the instructions at
http://activemq.apache.org/apollo/documentation/user-manual.html#On_Windows
to install a broker as a Windows Service. Unfortunately I it fails to start
the service with the following error in apollo-broker-service.err.log:
Exception in thread "main" java.l
Hi Dean,
Windows is known to be tricky to get classpaths right when jars are in a
path with a space in it. Perhaps this is going on here. Did you by any
chance install to a directory path that has a space in it?
Regards,
Hiram
dean.ward wrote
>
> Hi all,
> I've followed the instructions at
>
Hi,
you should add activemq-optional.jar to your classpath.
Regards
--
Dejan Bosanac
Senior Software Engineer | FuseSource Corp.
dej...@fusesource.com | fusesource.com
skype: dejan.bosanac | twitter: @dejanb
blog: http://www.nighttale.net
ActiveMQ in Action: http://www.manning.com/snyder/
On
47 matches
Mail list logo
