How properly close JCSMPSession

pierrett75
pierrett75 Member Posts: 2 ✭
edited August 2022 in General Discussions #1 
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

Answers

  • Ragnar
    Ragnar Member, Employee Posts: 65 Solace Employee
    #2

    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
    pierrett75 Member Posts: 2 ✭
    #3

    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)

Categories

This Month's Leaders

This Week's Leaders