I have made some sample applications using ActiveMQ BlobMessage and
everything is working. I have a few questions regarding the best
implementation.
1. Since these are large files is there any built in capability to resume
the file transfer from point of failure if a failure occurs while receivi
Looks like timeout parameter has been replaced by maxReconnectAttempts.
--
View this message in context:
http://www.nabble.com/connection-failover-using-ActiveMQ-5.2-tp23374917p23377412.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Reading FailoverTransportFactory.java, I see the code that causes the
exception to occur, but I don't understand the logic. It seems like this
check is added later. I don't see the same check in 4.1.2
public Transport createTransport(CompositeData compositData) throws
IOException {
> Jose Luna-2 wrote:
> >
> > I don't have any recommendation regarding activemq and HTTP but you may
> > consider tunneling openwire through SSL
> > (http://activemq.apache.org/ssl-transport-reference.html).If you set
> > your broker up to use port 443, proxies won't be able to distinguish
>
Jose Luna-2 wrote:
>
> I don't have any recommendation regarding activemq and HTTP but you may
> consider tunneling openwire through SSL
> (http://activemq.apache.org/ssl-transport-reference.html).If you set
> your broker up to use port 443, proxies won't be able to distinguish
> between th
Hello,
I am trying to set up auto-reconnect per
http://activemq.apache.org/failover-transport-reference.html instruction
failover:(tcp://primary:61616)?timeout=3000
But for some reason, I am getting IllegalArgumentException when timeout
attribute is set.
Caused by: javax.jms.JMSException: C
> I developed simplest application where
> client sends array of Integers as ObjectMessage to Server.
> Server application calculates sum of this values and return the result as
> ObjectMessage back to Client.
> Other words, it is simplest example ever.
>
> When I use tcp protocol (tcp://loc
> ht
On Sun, May 3, 2009 at 1:30 AM, riteshtijoriwala
wrote:
>
> I have two consumers C1 and C2 and two brokers B1 and B2 that see each other.
> I have one producer P1.
>
> P1 is connected initially to B1 and C2 is connected to B1. C1 is connected
> to B2. The initial start is as follows:
>
> P1 produc
This might help.
http://activemq.apache.org/total-ordering.html
http://activemq.apache.org/per-destination-policies.html
On Sun, May 3, 2009 at 11:29 AM, riteshtijoriwala <
riteshtijoriw...@yahoo.com> wrote:
>
> Just an FYI, I am seeing this behavior with one producer, one consumer and
> two bro
Hi,
Our consumer stops receiving further messages around 1000 messages.
A commit has not been done at this point, as the consumer is waiting to get
a whole batch of messages before processing them and then doing a
Session.Commit. We need the ability to keep the Commit pending until we get
even u
Hmm have you tried configuring the app?
Regards,
Phillip Mugal
http://makemoneyfromhome.com/ Make Money From Home
IBeaumont wrote:
>
> I've got a fairly complex app, that takes msgs, processing them and sticks
> them on the same or different queues.
>
> The queues are pre-loaded with persist
I developed simplest application where
client sends array of Integers as ObjectMessage to Server.
Server application calculates sum of this values and return the result as
ObjectMessage back to Client.
Other words, it is simplest example ever.
When I use tcp protocol (tcp://localhost:61616) every
Hi,
we're experiencing the same problem.
We also use ActiveMQ 5.1 with jdbc persistant adapter and we use
and a queuePrefetch=1 on consumer side.
Our Broker waits at the same Unsafe.park as shown in jconsole:
Name: QueueThread:queue://NEW_FILE
State: WAITING
Total blocked: 120 Total waited: 15
13 matches
Mail list logo
