Have you tried setting the connector's name?
e.g. connector.setName("myNetworkConnector");
The tests available at https://issues.apache.org/jira/browse/AMQ-3348 may also
give you some hints to get this working.
Hope this helps,
-Marcelo
On Sep 22, 2011, at 1:52 PM, sub3 wrote:
> Hi,
>
> I wa
Hi,
I want to be able to add a network connector a runtime. I believe this code
works, but it throws an error on the first line:
> NetworkConnector connector =
> broker.addNetworkConnector("static://"+"tcp://"+host+":61616");
> connector.setDuplex(true);
> connector.start();
Is it the connector
Hi,
ok I see, but this is only possible if sending is done directly before
committing the database transaction. It wouldn't work so well if
sending was done "somewhere" during the process. I had hoped that I
could feed something along a UUID as the message ID and it would be
used then, but I can s
you would need to pass use your own message impl that extends
ActiveMQMessage and override
org.apache.activemq.command.ActiveMQMessage#onSend
on that callback, you will have the messageId and be able to commit
the db transaction. On return from that method the message will be
sent.
be sure and cal
Hi,
I'd like to know the message ID of a message I am going to send before
actually sending it. Is this possible?
Reason is that I want to delay sending the JMS messages until my
database transaction has been comitted, but I already want to record
the message IDs as correlation IDs in exactly thi
Hello, i'm using activeMQ 5.6 SNAPSHOT on Windows 7 and java SE 7.
I successfully installed it as a service but when i try to start it i get an
error and it doesn't start.
Watching at the wrapper.log file here is what i get:
INFO | Listening for connections at: tcp://0.0.0.0:61611
INFO | jvm
Hi,
I think that was the problem what we had at the moment:
https://issues.apache.org/jira/browse/AMQ-2484
what you think over that?
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Messages-stuck-in-queue-tp3244342p3833610.html
Sent from the ActiveMQ - User mailing lis
Hello,
I extend the heap size of the consumer but that didn't help.
Regards
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Messages-stuck-in-queue-tp3244342p3833530.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Is this code shared by multiple threads? does it need synchronization?
What you are experiencing does seem odd, it would be great if you
could provide a simple junit test case that can reproduce.
Also, peeking that the code of the logging plugin, it should be
logging sends, that is again odd:
htt
Any idea on this problem? What i wrote about the 10 seconds made me look for
configuration parameters that are 1 ms by default, and i found
maxInactivityDurationInitalDelay. I've tried changing it in the consumer
uri:
failover://(tcp://host1:61616?wireFormat.maxInactivityDurationInitalDelay=9
would someone be kind enough to have a quick look at this code to see if it
could cause problems? The method returns a reusable connection so the user of
the class doesn't have to connect/disconnect on every message. The first
message never fails, it's always when reusing the connection that ran
nothing seems to help. There are still messages just disappearing. Also the
logging doesn't seem to log anything to do with producers:
I can see lots of camel consumers from the local machine looking at the routes
but nothing about incoming messages from producers.
Alistair
--
mov eax,1
mov
> Just to make sure I am getting things right I do the following in the
> cleanup:
>
> delete destination;
> consumer.stop();
> session.stop();
> consumer.close();
> delete consumer;
> delete session;
>
> Is this the correct order?
Yes, it looks correct.
Your broker is running out of JVM heap memory. From that moment on, anything
can happen.
I suggest you try to figure out the reason for running out of memory in the
first place.
Do you impose memory limits on each destination?
Do you configure for a system memory usage in your broker that is wel
On Thu, 22 Sep 2011 08:02:47 +0700, Ivan Pechorin
wrote:
The reason is that the ActiveMQConsumer object is crashing during its
destruction.
>>>Stack traces and sample code that reproduces the issue are needed before
>>>any help here, this could result from a number of different sce
15 matches
Mail list logo
