activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From JS75 <jean...@aboveE.com>
Subject Re: Journal is locked
Date Thu, 20 Dec 2007 01:48:17 GMT

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.


Mime
View raw message