session auto close problem

[galanfish]

hi all.

    i've read the manual, which mention that the producer/consumer is reusable and should not be create everytime. so i create a consumer which is setup a MessageHandler to aysnc-receive message. and somehow i got this warn:

2011-8-11 22:28:11 org.hornetq.core.logging.impl.JULLogDelegate warn

warn: I'm closing a core ClientSession you left open. Please make sure you close all ClientSessions explicitly before letting them go out of scope! 19723987

2011-8-11 22:28:11 org.hornetq.core.logging.impl.JULLogDelegate warn

warn: The ClientSession you didn't close was created here:

java.lang.Exception

  at org.hornetq.core.client.impl.DelegatingSession.<init>(DelegatingSession.java:94)

  at org.hornetq.core.client.impl.ClientSessionFactoryImpl.createSessionInternal(ClientSessionFactoryImpl.java:740)

  at org.hornetq.core.client.impl.ClientSessionFactoryImpl.createSession(ClientSessionFactoryImpl.java:295)

my question is, when should i close my consumer? once i close the consumer, can it be reopen?(how to reuse, now i just don't close it and leave it there listening to the queue). i want the messageHandler work for the whole time.

[ataylor]

Firstly your session is being closed because it is being garbage collected. regarding consumers just close it once you have finished using it.

tbh i'm not really sure whatyour asking here

[galanfish]

sorry for my english.

i use the MessageHandler as listener

i call consumer#setMessageHandler, then session#start

in this situation, need i close the consumer?

[ataylor]

just close the consumer once you dont need it anymore

[galanfish]

and even that the listener is still works? setMessageHandler  ->  session#start  ->  consumer#close... and all done?

[ataylor]

and even that the listener is still works? setMessageHandler  ->  session#start  ->  consumer#close... and all done?

I dont really understand what you are sayng here

[clebert.suconic]

Someone asked something similar on Stack Overflow (and I have been following stack over flow recently):

Java WeakReferences = Understandingproblem (with HornetQ JMS Implementation)?

[galanfish]

oh, sorry again.. actually i was asking: whether the MessageHandler will still work even after i close the consumer which the MessageHandler is set on. i made a test just now, it seems that the listener is not work anymore after i close the consumer?

[clebert.suconic]

You closed the consumer, how you would expect the listener still receiving messages from the consumer?

[galanfish]

so, once i set up a message handler, i should not call consumer#close?

[ataylor]

so, once i set up a message handler, i should not call consumer#close?

No, the listener is bound to the life cycle of the consumer as is the consumer with the sessiion and the session with the connection.

[galanfish]

then i have to keep the consumer/session open, but how can i prevent hornetq auto-closing the session?

[ataylor]

This is basic Java concepts, if you let your session object go out of scope it will be garbage collected and closed.