public void configure(StageConfigurer configurer) {
configurer.setName(CDAP_JMS_SOURCE_NAME);
configurer.setDescription("CDAP JMS Realtime Source");
}
public void initialize(RealtimeContext context) throws Exception {
<BUG>super.initialize(context);
initializeJMSConnection();</BUG>
}
private void initializeJMSConnection() {
if (jmsProvider == null) {

public void configure(StageConfigurer configurer) {
configurer.setName(CDAP_JMS_SOURCE_NAME);
configurer.setDescription("CDAP JMS Realtime Source");
}
public void initialize(RealtimeContext context) throws Exception {
super.initialize(context);
if (context.getRuntimeArguments().get(JMS_MESSAGES_TO_RECEIVE) != null) {
messagesToReceive = Integer.valueOf(context.getRuntimeArguments().get(JMS_MESSAGES_TO_RECEIVE));
}
initializeJMSConnection();
}
private void initializeJMSConnection() {
if (jmsProvider == null) {
