import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
public class JmsSource extends RealtimeSource<String> {
private static final Logger LOG = LoggerFactory.getLogger(JmsSource.class);
<BUG>private static final long JMS_CONSUMER_TIMEOUT_MS = 30000;

private static final String CDAP_JMS_SOURCE_NAME = "JMS Realtime Source";
private int jmsAcknowledgeMode = Session.AUTO_ACKNOWLEDGE;</BUG>
private JmsProvider jmsProvider;

import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
public class JmsSource extends RealtimeSource<String> {
private static final Logger LOG = LoggerFactory.getLogger(JmsSource.class);
private static final long JMS_CONSUMER_TIMEOUT_MS = 2000;
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;
