- BeanKernel.getBeanFactory().find(MonitorScheduler.class)
- .initialize();
- } catch (SchedulerException e) {
- LOG.error("Error starting scheduler", e);
+ Connection connection = connectionFactory.createConnection();
+ Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+ ObjectMessage msg = session.createObjectMessage();
+ msg.setObject(config.getIntervalSeconds());
+ MessageProducer producer = session.createProducer(timerQueue);
+ producer.send(msg);
+ } catch (Exception e) {
+ LOG.fatal("Error sending message", e);