Create a new wrapperparamconsumer the topic subscriberparamsession the session super(consumer, session);
super(consumer, session);
return ((TopicSubscriber) consumer).getNoLocal();
return ((TopicSubscriber) consumer).getTopic();