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.
