JniOnMQSubscribeListener::JniOnMQSubscribeListener(JNIEnv *env,
jobject jListener,
- JniOcResource* owner)
- : m_ownerResource(owner)
+ RemoveListenerCallback removeListener)
+ : m_removeListener(removeListener)
{
m_jwListener = env->NewWeakGlobalRef(jListener);
}
{
jthrowable ex = env->ExceptionOccurred();
env->ExceptionClear();
- m_ownerResource->removeOnMQTopicSubscribeListener(env, m_jwListener);
+ m_removeListener(env, m_jwListener);
env->Throw((jthrowable)ex);
}
else
{
- m_ownerResource->removeOnMQTopicSubscribeListener(env, m_jwListener);
+ m_removeListener(env, m_jwListener);
}
}