}).start();
System.out.println("-----> Started queue and session");
} finally {
Thread.currentThread().setContextClassLoader(cl);
}
<BUG>}
public void stop() throws Exception {</BUG>
shutdown.set(true);
if (session != null)
session.close();

}).start();
System.out.println("-----> Started queue and session");
} finally {
Thread.currentThread().setContextClassLoader(cl);
}
}
@Override
public void stop() throws Exception {
shutdown.set(true);
if (session != null)
session.close();
