[JBoss-dev] [JBoss JIRA] Commented: (JBAS-1547) Session.unsubscribe does not clear JMS messages from the database
[
http://jira.jboss.com/jira/browse/JBAS-1547?page=comments#action_12316324 ]
Plamen Todorov commented on JBAS-1547:
--
I'm sorry for the inconvenience, the problem was at our site. Resolved now.
> ÐÑ ÐÐÑÐÐ
>ÐÑ: "Adrian Brock (JIRA)" <[EMAIL PROTECTED]>
>ÐÑÐÐÑÐÐ: [JBoss JIRA] Closed: (JBAS-1547) Session.unsubscribe does not
>clear
JMS messages from the database
>ÐÐ: [EMAIL PROTECTED]
>ÐÐÐÑÐÑÐÐÐ ÐÐ: ÐÑÐÑÐÐÐ, 2005, ÐÐÑÑ 8 00:47:55 EET
>--
>
> [ http://jira.jboss.com/jira/browse/JBAS-1547?page=history ]
>
>Adrian Brock closed JBAS-1547:
>--
>
>Resolution: Incomplete Description
>
>Please reopen this bug report with either a modified Client.java test
>that reproduces the problem and I can run
>or some TRACE logging that shows the cause of the problem.
>
>> Session.unsubscribe does not clear JMS messages from the database
>> -
>>
>> Key: JBAS-1547
>> URL: http://jira.jboss.com/jira/browse/JBAS-1547
>> Project: JBoss Application Server
>> Type: Bug
>> Components: JMS service
>> Versions: JBossAS-4.0.1 Final
>> Environment: Windows XP
>> JDK 1.5.0
>> MS SQL Server
>> Reporter: Plamen Todorov
>> Assignee: Adrian Brock
>> Attachments: Client.java, server.log
>>
>>
>> I am testing durable topic subscription and have the following issue:
>> session.unsubscribe("") clears the subscription from the database, but does
>> not clear the JMS messages stored for this subscription from the
>> JMS_MESSAGES table. I am using MS SQL Server 2000 to store the messages.
>> Here is my test code:
>> public Result testTopic(TopicJMSPerformanceTestSetup setup){
>> try{
>> boolean guaranteed = setup.isGuaranteed();
>> long t = System.currentTimeMillis();
>> log("Testing " + (guaranteed ? " guaranteed" : "
>> non-guaranteed") + " topic connection delivery...");
>> TopicConnectionFactory factory =
>> connector.getTopicConnectionFactory();
>> TopicConnection conn;
>> try{
>> conn = factory.createTopicConnection(
>> connector.getJMSProperty(ContextJMSConnector.JMS_PROPERTY_CONNECTION_USERNAME),
>>
>> connector.getJMSProperty(ContextJMSConnector.JMS_PROPERTY_CONNECTION_PASSWORD));
>> log("Connected as " +
>> connector.getJMSProperty(ContextJMSConnector.JMS_PROPERTY_CONNECTION_USERNAME)
>> + " Topic connection: " + conn);
>> }catch(JMSConnectorException ex){
>> conn = factory.createTopicConnection();
>> log("Connected using the default user credentials. Topic
>> connection: " + conn);
>> }
>> conn.start();
>> try{
>> log("Topic connection: " + conn);
>> TopicSession session = conn.createTopicSession(false,
>> Session.AUTO_ACKNOWLEDGE);
>> log("Topic session: " + session);
>> int mode = (guaranteed ? DeliveryMode.PERSISTENT :
>> DeliveryMode.NON_PERSISTENT);
>> TopicPublisher publisher =
>> session.createPublisher(connector.getTopic(TOPIC_INTERNAL_NAME));
>> publisher.setDeliveryMode(mode);
>> log("Message publisher: " + publisher);
>> TopicSubscriber subscriber = null;
>> if(guaranteed)
>> subscriber =
>> session.createDurableSubscriber(connector.getTopic(TOPIC_INTERNAL_NAME),
>> "testDurableSubscriber");
>> else
>> subscriber =
>> session.createSubscriber(connector.getTopic(TOPIC_INTERNAL_NAME));
>> long objectCreationTime = System.currentTimeMillis() - t;
>> log("Message subscriber: " + subscriber);
>> //flush topic messages
>> log("Clearing " + empty(subscriber) + " messages from the
>> test topic." );
>> long messageSendingTime = 0;
>> try{
>> log("Publishing/receiving " + setup.getIterations() +
>> (guaranteed? " persistent" : " non-persistent") + " messages, Size = " +
>> setup.getMessageSize() + " bytes...");
>> messageSendingTime = work(publisher, subscriber,
>> session, setup);
>> }finally{
>> try{
>> subscriber.close();
>> publisher.close();
>> }finally{
>> if(guaranteed)
>> session.unsubscribe("testDurableSubscriber");
>> }
>> session.close();
>> }
>>
[JBoss-dev] [JBoss JIRA] Created: (JBAS-1547) Session.unsubscribe does not clear JMS messages from the database
Session.unsubscribe does not clear JMS messages from the database
-
Key: JBAS-1547
URL: http://jira.jboss.com/jira/browse/JBAS-1547
Project: JBoss Application Server
Type: Bug
Components: JMS service
Versions: JBossAS-4.0.1 Final
Environment: Windows XP
JDK 1.5.0
MS SQL Server
Reporter: Plamen Todorov
I am testing durable topic subscription and have the following issue:
session.unsubscribe("") clears the subscription from the database, but does not
clear the JMS messages stored for this subscription from the JMS_MESSAGES
table. I am using MS SQL Server 2000 to store the messages. Here is my test
code:
public Result testTopic(TopicJMSPerformanceTestSetup setup){
try{
boolean guaranteed = setup.isGuaranteed();
long t = System.currentTimeMillis();
log("Testing " + (guaranteed ? " guaranteed" : " non-guaranteed") +
" topic connection delivery...");
TopicConnectionFactory factory =
connector.getTopicConnectionFactory();
TopicConnection conn;
try{
conn = factory.createTopicConnection(
connector.getJMSProperty(ContextJMSConnector.JMS_PROPERTY_CONNECTION_USERNAME),
connector.getJMSProperty(ContextJMSConnector.JMS_PROPERTY_CONNECTION_PASSWORD));
log("Connected as " +
connector.getJMSProperty(ContextJMSConnector.JMS_PROPERTY_CONNECTION_USERNAME)
+ " Topic connection: " + conn);
}catch(JMSConnectorException ex){
conn = factory.createTopicConnection();
log("Connected using the default user credentials. Topic
connection: " + conn);
}
conn.start();
try{
log("Topic connection: " + conn);
TopicSession session = conn.createTopicSession(false,
Session.AUTO_ACKNOWLEDGE);
log("Topic session: " + session);
int mode = (guaranteed ? DeliveryMode.PERSISTENT :
DeliveryMode.NON_PERSISTENT);
TopicPublisher publisher =
session.createPublisher(connector.getTopic(TOPIC_INTERNAL_NAME));
publisher.setDeliveryMode(mode);
log("Message publisher: " + publisher);
TopicSubscriber subscriber = null;
if(guaranteed)
subscriber =
session.createDurableSubscriber(connector.getTopic(TOPIC_INTERNAL_NAME),
"testDurableSubscriber");
else
subscriber =
session.createSubscriber(connector.getTopic(TOPIC_INTERNAL_NAME));
long objectCreationTime = System.currentTimeMillis() - t;
log("Message subscriber: " + subscriber);
//flush topic messages
log("Clearing " + empty(subscriber) + " messages from the test
topic." );
long messageSendingTime = 0;
try{
log("Publishing/receiving " + setup.getIterations() +
(guaranteed? " persistent" : " non-persistent") + " messages, Size = " +
setup.getMessageSize() + " bytes...");
messageSendingTime = work(publisher, subscriber, session,
setup);
}finally{
try{
subscriber.close();
publisher.close();
}finally{
if(guaranteed)
session.unsubscribe("testDurableSubscriber");
}
session.close();
}
log("Message publishing finished. Time: " + messageSendingTime
+ " msec\n");
return new PerformanceResult(setup, objectCreationTime,
messageSendingTime);
}finally{
conn.close();
}
}catch(Exception e){
String message = "ERROR!\nError executing test. Message: " + e +
"\nTest setup: " + setup + "\nTime: " +
SimpleDateFormat.getTimeInstance().format(new Date());
log(message + "\n", Level.ERROR);
e.printStackTrace();
return new ResultImpl(message);
}
}
--
This message is automatically generated by JIRA.
-
If you think it was sent incorrectly contact one of the administrators:
http://jira.jboss.com/jira/secure/Administrators.jspa
-
If you want more information on JIRA, or have a bug to report see:
http://www.atlassian.com/software/jira
---
SF email is sponsored by - The IT Product Guide
Read honest & candid reviews on hundreds of IT Products from real users.
Discover which products truly live up to the hype. Start reading now.
http://ads.osdn.com/?ad_id=6595&alloc_id=14396&op=click
___
JBoss-Development mailing list
JBoss-Development@lists.sourceforge.net
https://lists.sourceforge.n
