You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by JS75 <je...@aboveE.com> on 2007/12/18 03:43:53 UTC
Journal is locked
Dear Sirs:
As a neophyte of activeMQ, I encountered some tasks, and please help me to
solve them >"<!
I tried to embedded one broker into my connections -
producer (ClientSide) and consumer (ServerSide) separately in one
JVM.
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(vm://localhost);
However, when I started these two connections, the latter one has above
messages in cosole
org.apache.activemq.store.DefaultPersistenceAdapterFactory createJournal
資訊: Journal is locked... waiting 10 seconds for the journal to be
unlocked.
Unless did I close the former connection (usually Producer connection), the
latter broker started (Consumer connection received)?
But I wish each of them can work in pararrel as TCP can do?
Did I make any mistake or forget to do any configurations?
Sincerely,
Jean
--
View this message in context: http://www.nabble.com/Journal-is-locked-tp14375869s2354p14375869.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Journal is locked
Posted by JS75 <je...@aboveE.com>.
After following steps in wiki, the embedded broker starts successfully!!
Now I included two jars -
activemq-all-5.0.0.jar and commons-logging-1.1.jar
but I got this exception when my queue producer initialized :
java.lang.NoSuchMethodError:
org.apache.activemq.ActiveMQMessageProducerSupport.getDestination()Ljavax/jms/Destination;
I guess I missed to include certain jar?
Well, I'd also want to get more information about monitoring embedded queue
and I also wonder how to solve the issue of fast producers and slow
consumers, because in future projects I can not handle how fast or slow the
producers will be!
Sincerely,
Jean
rajdavies wrote:
>
>
> I updated the wiki - but this might take a while before its published
> to the amq site:
> http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html?refresh=1
> Basically you can do something like this:
>
> BrokerService broker = new BrokerService();
> broker.setName("fred");
> broker.addConnector("tcp://localhost:61616");
> broker.start();
>
> Then remote clients can use the tcp://somehost:61616 uri to bind to
> the embedded broker - and in JVM clients can use vm://fred
>
> With regards to the class path error - which jars are you using ?
>
> cheers,
>
> Rob
>
>
> Rob Davies
> 'Go further faster with Apache Camel!'
> http://rajdavies.blogspot.com/
>
>
>
> On Dec 18, 2007, at 5:43 AM, JS75 wrote:
>
>>
>> First, thank you for your apply~
>>
>> I tried to assign name to each embedded broker.
>> And these twn connections starts successfully, however, they do not
>> work as
>> I wish!
>>
>> As URI as tcp://localhost:61616, producers send messages and consumers
>> receive messages.
>> After assigning names, they seemd to work without any relationship.
>>
>> Is there any thing I can do to make embedded VM broker as embedded TCP
>> broker?
>>
>> BTW, I tried to upgrade activeMQ to 5.0, and I found this exception in
>> console
>> java.lang.NoSuchMethodError:
>> org
>> .apache
>> .activemq.ActiveMQMessageProducerSupport.getDestination()Ljavax/jms/
>> Destination;
>>
>> Have I misses to include any lib?
>>
>> Sincerely,
>> Jean
>>
>>
>>
>> ttmdev wrote:
>>>
>>> Try assigning different names to your two embedded brokers. For
>>> example,
>>>
>>> ActiveMQConnectionFactory connectionFactory =
>>> new ActiveMQConnectionFactory(vm://clientbroker);
>>>
>>> ActiveMQConnectionFactory connectionFactory =
>>> new ActiveMQConnectionFactory(vm://serverbroker);
>>>
>>> Joe
>>>
>>>
>>>
>>> JS75 wrote:
>>>>
>>>> Dear Sirs:
>>>>
>>>> As a neophyte of activeMQ, I encountered some tasks, and please
>>>> help me
>>>> to solve them >"<!
>>>>
>>>> I tried to embedded one broker into my connections -
>>>> producer (ClientSide) and consumer (ServerSide)
>>>> separately in
>>>> one JVM.
>>>>
>>>> ActiveMQConnectionFactory connectionFactory =
>>>> new ActiveMQConnectionFactory(vm://localhost);
>>>>
>>>>
>>>> However, when I started these two connections, the latter one has
>>>> above
>>>> messages in cosole
>>>>
>>>> org.apache.activemq.store.DefaultPersistenceAdapterFactory
>>>> createJournal
>>>> 資訊: Journal is locked... waiting 10 seconds for the journal
>>>> to be
>>>> unlocked.
>>>>
>>>> Unless did I close the former connection (usually Producer
>>>> connection),
>>>> the latter broker started (Consumer connection received)?
>>>> But I wish each of them can work in pararrel as TCP can do?
>>>> Did I make any mistake or forget to do any configurations?
>>>>
>>>> Sincerely,
>>>> Jean
>>>>
>>>
>>>
>>
>> --
>> View this message in context:
>> http://www.nabble.com/Journal-is-locked-tp14375869s2354p14384479.html
>> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>>
>
>
>
>
>
--
View this message in context: http://www.nabble.com/Journal-is-locked-tp14375869s2354p14429142.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Journal is locked
Posted by Rob Davies <ra...@gmail.com>.
I updated the wiki - but this might take a while before its published
to the amq site: http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html?refresh=1
Basically you can do something like this:
BrokerService broker = new BrokerService();
broker.setName("fred");
broker.addConnector("tcp://localhost:61616");
broker.start();
Then remote clients can use the tcp://somehost:61616 uri to bind to
the embedded broker - and in JVM clients can use vm://fred
With regards to the class path error - which jars are you using ?
cheers,
Rob
Rob Davies
'Go further faster with Apache Camel!'
http://rajdavies.blogspot.com/
On Dec 18, 2007, at 5:43 AM, JS75 wrote:
>
> First, thank you for your apply~
>
> I tried to assign name to each embedded broker.
> And these twn connections starts successfully, however, they do not
> work as
> I wish!
>
> As URI as tcp://localhost:61616, producers send messages and consumers
> receive messages.
> After assigning names, they seemd to work without any relationship.
>
> Is there any thing I can do to make embedded VM broker as embedded TCP
> broker?
>
> BTW, I tried to upgrade activeMQ to 5.0, and I found this exception in
> console
> java.lang.NoSuchMethodError:
> org
> .apache
> .activemq.ActiveMQMessageProducerSupport.getDestination()Ljavax/jms/
> Destination;
>
> Have I misses to include any lib?
>
> Sincerely,
> Jean
>
>
>
> ttmdev wrote:
>>
>> Try assigning different names to your two embedded brokers. For
>> example,
>>
>> ActiveMQConnectionFactory connectionFactory =
>> new ActiveMQConnectionFactory(vm://clientbroker);
>>
>> ActiveMQConnectionFactory connectionFactory =
>> new ActiveMQConnectionFactory(vm://serverbroker);
>>
>> Joe
>>
>>
>>
>> JS75 wrote:
>>>
>>> Dear Sirs:
>>>
>>> As a neophyte of activeMQ, I encountered some tasks, and please
>>> help me
>>> to solve them >"<!
>>>
>>> I tried to embedded one broker into my connections -
>>> producer (ClientSide) and consumer (ServerSide)
>>> separately in
>>> one JVM.
>>>
>>> ActiveMQConnectionFactory connectionFactory =
>>> new ActiveMQConnectionFactory(vm://localhost);
>>>
>>>
>>> However, when I started these two connections, the latter one has
>>> above
>>> messages in cosole
>>>
>>> org.apache.activemq.store.DefaultPersistenceAdapterFactory
>>> createJournal
>>> 資訊: Journal is locked... waiting 10 seconds for the journal
>>> to be
>>> unlocked.
>>>
>>> Unless did I close the former connection (usually Producer
>>> connection),
>>> the latter broker started (Consumer connection received)?
>>> But I wish each of them can work in pararrel as TCP can do?
>>> Did I make any mistake or forget to do any configurations?
>>>
>>> Sincerely,
>>> Jean
>>>
>>
>>
>
> --
> View this message in context: http://www.nabble.com/Journal-is-locked-tp14375869s2354p14384479.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
>
Re: Journal is locked
Posted by JS75 <je...@aboveE.com>.
First, thank you for your apply~
I tried to assign name to each embedded broker.
And these twn connections starts successfully, however, they do not work as
I wish!
As URI as tcp://localhost:61616, producers send messages and consumers
receive messages.
After assigning names, they seemd to work without any relationship.
Is there any thing I can do to make embedded VM broker as embedded TCP
broker?
BTW, I tried to upgrade activeMQ to 5.0, and I found this exception in
console
java.lang.NoSuchMethodError:
org.apache.activemq.ActiveMQMessageProducerSupport.getDestination()Ljavax/jms/Destination;
Have I misses to include any lib?
Sincerely,
Jean
ttmdev wrote:
>
> Try assigning different names to your two embedded brokers. For example,
>
> ActiveMQConnectionFactory connectionFactory =
> new ActiveMQConnectionFactory(vm://clientbroker);
>
> ActiveMQConnectionFactory connectionFactory =
> new ActiveMQConnectionFactory(vm://serverbroker);
>
> Joe
>
>
>
> JS75 wrote:
>>
>> Dear Sirs:
>>
>> As a neophyte of activeMQ, I encountered some tasks, and please help me
>> to solve them >"<!
>>
>> I tried to embedded one broker into my connections -
>> producer (ClientSide) and consumer (ServerSide) separately in
>> one JVM.
>>
>> ActiveMQConnectionFactory connectionFactory =
>> new ActiveMQConnectionFactory(vm://localhost);
>>
>>
>> However, when I started these two connections, the latter one has above
>> messages in cosole
>>
>> org.apache.activemq.store.DefaultPersistenceAdapterFactory
>> createJournal
>> 資訊: Journal is locked... waiting 10 seconds for the journal to be
>> unlocked.
>>
>> Unless did I close the former connection (usually Producer connection),
>> the latter broker started (Consumer connection received)?
>> But I wish each of them can work in pararrel as TCP can do?
>> Did I make any mistake or forget to do any configurations?
>>
>> Sincerely,
>> Jean
>>
>
>
--
View this message in context: http://www.nabble.com/Journal-is-locked-tp14375869s2354p14384479.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Journal is locked
Posted by ttmdev <jo...@ttmsolutions.com>.
Try assigning different names to your two embedded brokers. For example,
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(vm://clientbroker);
ActiveMQConnectionFactory connectionFactory =
new ActiveMQConnectionFactory(vm://serverbroker);
Joe
JS75 wrote:
>
> Dear Sirs:
>
> As a neophyte of activeMQ, I encountered some tasks, and please help me to
> solve them >"<!
>
> I tried to embedded one broker into my connections -
> producer (ClientSide) and consumer (ServerSide) separately in
> one JVM.
>
> ActiveMQConnectionFactory connectionFactory =
> new ActiveMQConnectionFactory(vm://localhost);
>
>
> However, when I started these two connections, the latter one has above
> messages in cosole
>
> org.apache.activemq.store.DefaultPersistenceAdapterFactory
> createJournal
> 資訊: Journal is locked... waiting 10 seconds for the journal to be
> unlocked.
>
> Unless did I close the former connection (usually Producer connection),
> the latter broker started (Consumer connection received)?
> But I wish each of them can work in pararrel as TCP can do?
> Did I make any mistake or forget to do any configurations?
>
> Sincerely,
> Jean
>
--
View this message in context: http://www.nabble.com/Journal-is-locked-tp14375869s2354p14379258.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.