Re: How to register consumer with the same name for the different topic

Ya thats a known issue due to the oppertunistic SQLServer locking.
OpenJMS has the bug logged for this.
https://sourceforge.net/tracker/?func=detail&atid=474136&aid=934627&group_id=54559

There is also workaround suggested by creating the views for the Tables. SQL server does not allows to run the CREATE VIEW batch trasactions after the renames so once can use this slightly modified one. This part of the script can be added at the end of the SQL Server DDL. Verified the correct functionality and very high thoughput after this new Schema is applied. All works fine now. :) 
Tim thanks for your inputs :)
===================================================
exec sp_rename @objname='messages',
@newname='messages_table', @objtype =  'OBJECT'
exec sp_rename @objname='message_handles',
@newname='message_handles_table', @objtype='OBJECT'
 
if not exists (select * from sysobjects where name='messages' and xtype='V')
    exec ('create view messages as select * from messages_table with(nolock)')
go
if not exists (select * from sysobjects where name='message_handles' and xtype='V')
    exec ('create view message_handles as select * from message_handles_table with(nolock)')
go

=================================================== 


On Wed, 13 Dec 2006 Hemant Gaur wrote :
>I have been able to get this fixed in the Jmeter.
>Actually the calls made for
>connection.setClientID(idGenerator.generateId());//not supported by OpenJMS
>are removed from the OpenJMS code path in the org.activemq.sampler.Consumer
>And added the UniqueID to the client name while creating the subscription.
><<consumer = ((TopicSession)session).createDurableSubscriber(topic, getClass().getName());
> >>consumer = ((TopicSession)session).createDurableSubscriber(topic, getClass().getName()+idGenerator.generateId());
>
>Ensure that the consumer sampler is the first Member of the test ThreadGroup and the tests run fine.
>
>However on stressting the OpenJMS with more than one (2 Publishers, 2Subscribers, 2 topics, persistent, Durable, tcp) subscribers/Publishers there are SqlServer deadlock exceptions printed on the OpenJMS console.
>OpenJMS selects the victim and reruns the transactions but the consumers are badly affected from this and the messages throughput is drastacally decresed to 2-3 messages/Sec.
>
>17:16:37.440 ERROR [Scheduler-Worker-6] - Error in SentMessageCache.process
>org.exolab.jms.persistence.PersistenceException:
>java.sql.SQLException: [Microsoft][SQLServer 2000 Driver for JDBC][SQLServer]Tra
>nsaction (Process ID 54) was deadlocked on {lock} resources with another process
>  and has been chosen as the deadlock victim. Rerun the transaction.
>         at com.microsoft.jdbc.base.BaseExceptions.createException(Unknown Source
>)
>         at com.microsoft.jdbc.base.BaseExceptions.getException(Unknown Source)
>         at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processErrorToken(Unknown
>  Source)
>         at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processReplyToken(Unknown
>  Source)
>         at com.microsoft.jdbc.sqlserver.tds.TDSRPCRequest.processReplyToken(Unkn
>own Source)
>         at com.microsoft.jdbc.sqlserver.tds.TDSRequest.processReply(Unknown Sour
>ce)
>         at com.microsoft.jdbc.sqlserver.tds.TDSCursorRequest.openCursor(Unknown
>Source)
>         at com.microsoft.jdbc.sqlserver.SQLServerImplStatement.execute(Unknown S
>ource)
>         at com.microsoft.jdbc.base.BaseStatement.commonExecute(Unknown Source)
>         at com.microsoft.jdbc.base.BaseStatement.executeQueryInternal(Unknown So
>urce)
>         at com.microsoft.jdbc.base.BasePreparedStatement.executeQuery(Unknown So
>urce)
>         at org.apache.commons.dbcp.DelegatingPreparedStatement.executeQuery(Dele
>gatingPreparedStatement.java:205)
>         at org.apache.commons.dbcp.DelegatingPreparedStatement.executeQuery(Dele
>gatingPreparedStatement.java:205)
>         at org.exolab.jms.persistence.MessageHandles.removeMessageHandle(Message
>Handles.java:352)
>         at org.exolab.jms.persistence.RDBMSAdapter.removeMessageHandle(RDBMSAdap
>ter.java:495)
>         at org.exolab.jms.messagemgr.MessageHandleFactory.destroyPersistentHandl
>e(MessageHandleFactory.java:361)
>         at org.exolab.jms.server.SentMessageCache.process(SentMessageCache.java:
>146)
>         at org.exolab.jms.server.JmsServerSession.onMessage(JmsServerSession.jav
>a:949)
>         at org.exolab.jms.messagemgr.TopicConsumerEndpoint.deliverMessages(Topic
>ConsumerEndpoint.java:193)
>         at org.exolab.jms.messagemgr.ConsumerEndpoint.run(ConsumerEndpoint.java:
>425)
>         at org.exolab.core.threadPool.ThreadPoolWorker.runIt(ThreadPoolWorker.ja
>va:191)
>         at org.exolab.core.threadPool.ThreadPoolWorker.runWork(ThreadPoolWorker.
>java:178)
>         at org.exolab.core.threadPool.ThreadPoolWorker.access$000(ThreadPoolWork
>er.java:67)
>         at org.exolab.core.threadPool.ThreadPoolWorker$1.run(ThreadPoolWorker.ja
>va:122)
>         at java.lang.Thread.run(Thread.java:595)
>
>
>Tim, Any thoughts on that. Is this the known issue with the 7.6.1 release version. What else can I try ?
>
>Thanks,
>Hemant
>
>
>
>On Wed, 13 Dec 2006 Hemant Gaur wrote :
> >Looking into OpenJMS code it seems that this is not supported.
> >The setClinetID call I can see in the JMeter ConsumerSampler but I this is not supported in OpenJMS Release version.
> >So the consumer name(classs Name) is taken which conflicts.
> >1.) connection.setClientID(idGenerator.generateId());
> >The set ClientID is not supported in the openJMS.
> >
> >2.) consumer = ((TopicSession)session).createDurableSubscriber(topic, getClass().getName());
> >
> >I think I need to do some changes in the JMEter to get this running.
> >Will keep you updated once I get this working.
> >
> >Regards,
> >Hemant Gaur
> >
> >On Tue, 12 Dec 2006 Tim Anderson wrote :
> > >Hemant Gaur wrote:
> > >>
> > >>Hi,
> > >>For the JMeter tests on the OpenJMS release version , I tried to put the configuration for 5 topics, 5 Publishers , 5 subscribers.
> > >>
> > >>There was the error in the jmeter log as the OpenJMS did not allowed creating the consumer for the same name.
> > >>
> > >>2006/12/12 15:49:32 ERROR - org.activemq.sampler.Consumer: Error running consumer  javax.jms.JMSException: Failed to unsubscribe subscriber org.activemq.sampler.Consumer since is still active
> > >>at org.exolab.jms.server.JmsServerSession.unsubscribe(JmsServerSession.java:881)
> > >>at org.exolab.jms.server.JmsServerSession.createSubscriber(JmsServerSession.java:758)
> > >>at org.exolab.jms.server.mipc.IpcJmsSessionConnection.createSubscriber(IpcJmsSessionConnection.java:588)
> > >>at org.exolab.jms.server.mipc.IpcJmsSessionConnection.notify(IpcJmsSessionConnection.java:165)
> > >>at org.exolab.jms.server.mipc.IpcJmsReceiver.notify(IpcJmsReceiver.java:100)
> > >>at org.exolab.jms.server.mipc.IpcServerChannel.run(IpcServerChannel.java:161)
> > >>
> > >>
> > >>Are there anyworkarounds/configuration settings for this to be resolved. Publishers are working fine for the 5 topics.
> > >>
> > >In OpenJMS, subscription names must be unique.You'll need to configure JMeter to use a different subscription name
> > >per durable subscriber.
> > >
> > >-Tim
> >-------------------------------------------------------------------------
> >Take Surveys. Earn Cash. Influence the Future of IT
> >Join SourceForge.net's Techsay panel and you'll get the chance to share your
> >opinions on IT & business topics through brief surveys - and earn cash
> >http://www.techsay.com/default.php?page=join.php&p=sourceforge&CID=DEVDEV
> >_______________________________________________
> >openjms-user mailing list
> >[email protected]
> >https://lists.sourceforge.net/lists/listinfo/openjms-user
>-------------------------------------------------------------------------
>Take Surveys. Earn Cash. Influence the Future of IT
>Join SourceForge.net's Techsay panel and you'll get the chance to share your
>opinions on IT & business topics through brief surveys - and earn cash
>http://www.techsay.com/default.php?page=join.php&p=sourceforge&CID=DEVDEV
>_______________________________________________
>openjms-user mailing list
>[email protected]
>https://lists.sourceforge.net/lists/listinfo/openjms-user

-------------------------------------------------------------------------
Take Surveys. Earn Cash. Influence the Future of IT
Join SourceForge.net's Techsay panel and you'll get the chance to share your
opinions on IT & business topics through brief surveys - and earn cash
http://www.techsay.com/default.php?page=join.php&p=sourceforge&CID=DEVDEV

_______________________________________________
openjms-user mailing list
[email protected]
https://lists.sourceforge.net/lists/listinfo/openjms-user