Can’t spot any gottchas. Could you set the Scheduler directory for your
embedded broker - just to check its actually being created ? - see
https://github.com/apache/activemq/blob/master/activemq-unit-tests/src/test/java/org/apache/activemq/broker/scheduler/JobSchedulerTestSupport.java#L100
for inspiration
> On 27 Oct 2016, at 08:28, CallMeXYZ <amos.callme...@gmail.com> wrote:
>
> I'm using ActiveMQ with Spring , I have set the /SchedulerSupport / but seems
> not to work.
> Below is my configuration.
> ============================
> @Configuration
> @EnableJms
> public class MessageConfig {
> private static final String DEFAULT_BROKER_URL =
> "tcp://localhost:61616";
>
> public static final String DESTINATION_FB = "fb";
> private static final String USER_NAME = "admin";
> private static final String USER_PASSWORD = "admin";
> @Profile("embedded")
> @Bean(initMethod = "start", destroyMethod = "stop")
> public BrokerService brokerService() throws Exception {
> BrokerService brokerService = new BrokerService();
> brokerService.setSchedulerSupport(true);
> brokerService.addConnector(DEFAULT_BROKER_URL);
> return brokerService;
> }
> @Bean
> public ConnectionFactory connectionFactory() {
> ActiveMQConnectionFactory connectionFactory = new
> ActiveMQConnectionFactory();
> connectionFactory.setBrokerURL(DEFAULT_BROKER_URL);
> /* connectionFactory.setUserName(USER_NAME);
> connectionFactory.setPassword(USER_PASSWORD);*/
> connectionFactory.setTrustedPackages(Arrays.asList("com.test.test",
> "java.lang"));
> return connectionFactory;
> }
>
> @Bean
> public JmsTemplate jmsTemplate(ConnectionFactory factory) {
> JmsTemplate template = new JmsTemplate();
> template.setConnectionFactory(factory);
> template.setDefaultDestinationName(DESTINATION_FB);
> return template;
> }
> @Bean
> public DefaultMessageListenerContainer
> jmsListenerContainerFactory(ConnectionFactory connectionFactory){
> DefaultMessageListenerContainer containerFactory = new
> DefaultMessageListenerContainer();
> containerFactory.setConnectionFactory(connectionFactory);
> return containerFactory;
> }
> }
> ========Sender============
> @Component
> public class MessageSender {
> @Autowired
> JmsTemplate jmsTemplate;
> public void sendMessage(final ResultCode data) {
>
> jmsTemplate.send(new MessageCreator(){
> @Override
> public Message createMessage(Session session) throws
> JMSException {
> ObjectMessage objectMessage =
> session.createObjectMessage(data);
>
> objectMessage.setLongProperty(ScheduledMessage.AMQ_SCHEDULED_DELAY,600000);
> return objectMessage;
> }
> });
> }
> }
> =======Receiver=====
> @Component
> public class MessageReceiver {
>
> @JmsListener(destination = MessageConfig.DESTINATION_FB)
>
> public void receiveMessage(ResultCode data) {
> System.out.println("Received <" + data.getInfo() + ">");
> }
>
> }
>
>
> Thanks for your reading
>
>
>
> --
> View this message in context:
> http://activemq.2283324.n4.nabble.com/scheduler-message-deliver-immediately-tp4718568.html
> Sent from the ActiveMQ - User mailing list archive at Nabble.com.
