Good Day,
If you disable producer flow control and set per destination policy, isn't it
advisable to also move away from vmCursor since all the message are dispatched
from memory. Doesn't using vmCursors defeats the whole purpose of trying to
offline the message to a temporary storage ?. Isn't
I am using version 5.6.0. Here is an excerpt from the debug messages
my HTTP client code reports regarding the GET request:
DEBUG >>> GET
/demo/message/myqueue?type=queue&consumer.prefetchSize=1&clientId=0F371438-8939-4D0D-A
279-35CB9EE77FE0&readTimeout=1000 HTTP/1.1
DEBUG >>> Host: d22
Hi,
I am using ActiveMQ 5.6.0 Broker Cluster mode.
As activemq doc mentioned here
http://activemq.apache.org/multicast-transport-reference.html
*"Note that by default Multicast is not reliable; datagrams can be lost so
you should add a reliability layer to ensure the JMS contract can be
implemen
This seems to be related to the 2000 limit on the linkedblockingqueue
inside of VMTransport…
Where is this configured ?
On 2012-09-11 18:23:56 +, Oleg Dulin said:
Here is the stack trace:
One thread:
Name: LS:IndexItemQueue:2
State: BLOCKED on java.lang.Object@699b7e6 owned by: LS:Ind
Here is the stack trace:
One thread:
Name: LS:IndexItemQueue:2
State: BLOCKED on java.lang.Object@699b7e6 owned by: LS:IndexItemQueue:8
Total blocked: 42,886 Total waited: 27,663
Stack trace:
org.apache.activemq.ActiveMQSession.send(ActiveMQSession.java:1698)
org.apache.activemq.ActiveMQMessag
I will increase the logging level in spring and see what I can find, also I
have no idea whether the initial context factory class is visible or not, I
guess I'd like to understand why it wouldn't be visible or figure out how this
visibility is reconciled, is this something where spring cannot
I will raise I jira,
For now as a temporary bypass I changed the bundle,
org.springframework.web.servlet_3.0.5.RELEASE to import 'org.apache.camel'
package
But Now I am facing a new issue, when trying to consume from a topic using
rest, I get this exception:
java.lang.IllegalStateException: Not
Hi,
JMSCorrelationID should be set as a response header. What version are you using?
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.m
Hi,
we haven't yet osgified the web demo app (containing the rest api).
Can you raise a jira for that?
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 Ac
once a message is acknowledged (acked) by a consumer and the broker
received that ack, it is removed.
What ack mode is in use by your consumer?
for topics there is an extension, retroactive consumer, that can allow
replay of earlier messagers but this is not enabled by default.
On 11 September 20
I am able to obtain the message ID from a header, but I don't see a header
containing the correlation ID. Is there some configuration I need in order for
the broker to put correlation IDs in headers being sent along with message
payloads?
Thanks,
Stephen Vincent
You can also use any of the ActiveMQ 5.x clients, as Apollo supports
OpenWire. The support for OpenWire isn't yet in the "complete" state, but a
majority of the features are there. I'm working on the initial
documentation, and have a project set up here to demo some of the features:
https://github
Hello guys
I just want to know, if there is a way to remove messages from queue/topic
(Enqueued Messages) once the Consumer ( MessageListener) receives the message?
I need this because, the MessageListener is picking up the earlier published
messages. Thank you.
Raj
Sent from my iPhone
On
enable full logging for the broker and you will be able to see what is going on.
One thought is that a memory limit is being reached which is pushing
back on the producer.
In other words, there is not sufficient memory to hold 1 messages
plus what has been prefetched and the system limit that
see if you can increase the logging level for spring. It may just be a
class loading issue trying to resolve the initial context factory.
Are you certain that the activemq initial context factory class is
visible to your spring context?
On 11 September 2012 07:51, Saikat Kanjilal wrote:
>
> Yes
oh , I have get some. that is at : https://github.com/fusesource/stompjms.
thanks.
rmn190
发件人： rmn190
发送时间： 2012-09-11 15:14
收件人： users
主题： request for java client for Apollo
hi, all:
I'm new to Apollo, and am tasked to use Java client (JMS compatible) to get
touched with Apollo.
W
Thanks Peter,
That was exactly the problem I was facing and by setting the
wireFormat.maxInactivityDuration=0 on my connection URL, it solved my issue.
Regards,
Mayank
--
View this message in context:
http://activemq.2283324.n4.nabble.com/How-to-indefinitely-run-a-JMS-consumer-tp4656248p46562
Chapter 8 of ActiveMQ in Action talks about running AMQ in various
containers such as Tomcat
http://manning.com/snyder/
On Tue, Sep 11, 2012 at 8:51 AM, Saikat Kanjilal wrote:
>
> Yes I saw that link already, however we are using spring in our
> infrastructure and unfortunately changing to Cam
hi, all:
I'm new to Apollo, and am tasked to use Java client (JMS compatible) to get
touched with Apollo.
With the distribute, there are some examples, but they are written in Scala,
which I have no idea.
So, It would be great if someone can help me if he give me a java demo code.
than
19 matches
Mail list logo
