private static final String CDAP_JMS_SOURCE_NAME = "JMS Realtime Source";
private int jmsAcknowledgeMode = Session.AUTO_ACKNOWLEDGE;</BUG>
private JmsProvider jmsProvider;
private transient Connection connection;
private transient Session session;
<BUG>private MessageConsumer consumer;

@Override</BUG>
public void configure(StageConfigurer configurer) {
configurer.setName(CDAP_JMS_SOURCE_NAME);

private static final String CDAP_JMS_SOURCE_NAME = "JMS Realtime Source";
private static final String JMS_MESSAGES_TO_RECEIVE = "jms.messages.receive";
private int jmsAcknowledgeMode = Session.AUTO_ACKNOWLEDGE;
private JmsProvider jmsProvider;
private transient Connection connection;
private transient Session session;
private transient MessageConsumer consumer;
private int messagesToReceive = 50;
@Override
public void configure(StageConfigurer configurer) {
configurer.setName(CDAP_JMS_SOURCE_NAME);
