How properly close JCSMPSession

pierrett75

Hello i need advice, we use sol-jcsmp version 10.15.0 Session is create with XmlMessageLIstener, XmlMessageConsumer and XMl MessageProducer. 
gproducer is create by JCSMPStreamingPublishCorrelatingEventHandler. 
wwhen i want to close session i call session.clouseSession() Problem is that after close i still can see running thred from ConsumerNotificationDispatcher.run 
and SyncEventDispatcherReacto.
How do i close all these thread properly ?

Thanks Petra

Ragnar

Hi Petra,

The ConsumerNotificationDispatcher and SyncEventDispatcherReactor thread are both created once per context and handle all sessions in the context.

They will not exist when any Session is closed. However they will exit when the context is destroyed.

pierrett75

Hi @Ragnar for response, so how i can destroy context ? we create JCSMPSession, with XMLmessageConsumer, we close the session.closeSession() but when i print threads a can see threads connected with solace:

Context_1_ReactorThread RUNNABLE true

sun.nio.ch.WindowsSelectorImpl$SubSelector.poll0(Native Method)

sun.nio.ch.WindowsSelectorImpl$SubSelector.poll(WindowsSelectorImpl.java:314)

sun.nio.ch.WindowsSelectorImpl$SubSelector.access$400(WindowsSelectorImpl.java:293)

sun.nio.ch.WindowsSelectorImpl.doSelect(WindowsSelectorImpl.java:174)

sun.nio.ch.SelectorImpl.lockAndDoSelect(SelectorImpl.java:86)

sun.nio.ch.SelectorImpl.select(SelectorImpl.java:97)

com.solacesystems.jcsmp.protocol.nio.impl.SyncEventDispatcherReactor.eventLoop(SyncEventDispatcherReactor.java:153)

com.solacesystems.jcsmp.protocol.nio.impl.SyncEventDispatcherReactor$SEDReactorThread.run(SyncEventDispatcherReactor.java:338)

java.lang.Thread.run(Thread.java:748)

Context_1_ConsumerDispatcher WAITING true

sun.misc.Unsafe.park(Native Method)

java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)

java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2044)

java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)

com.solacesystems.jcsmp.protocol.nio.impl.ConsumerNotificationDispatcher.eventLoop(ConsumerNotificationDispatcher.java:111)

com.solacesystems.jcsmp.protocol.nio.impl.ConsumerNotificationDispatcher.run(ConsumerNotificationDispatcher.java:130)

java.lang.Thread.run(Thread.java:748)