01 package examples.jms.jms20.ejb;
02
03 import javax.annotation.PostConstruct;
04 import javax.annotation.PreDestroy;
05 import javax.annotation.Resource;
06 import javax.ejb.Stateless;
07 import javax.ejb.TransactionAttribute;
08 import javax.ejb.TransactionAttributeType;
09 import javax.inject.Inject;
10 import javax.jms.*;
11 import javax.print.DocFlavor;
12
13 /**
14 * @author Copyright (c) 2015, 2020, Oracle and/or its affiliates. All rights reserved.
15 */
16
17 @Stateless
18 public class JMSPublisher {
19
20 @Resource(mappedName = Resources.TOPIC)
21 private Topic topic;
22
23 @Inject
24 private JMSContext jmsContext;
25
26 @TransactionAttribute(TransactionAttributeType.REQUIRED)
27 public void createSubscription() {
28 JMSProducer jmsProducer = jmsContext.createProducer();
29 jmsProducer.setDeliveryDelay(1000);
30 jmsProducer.setPriority(1);
31 jmsProducer.send(topic,Resources.SUBSCRIPTION);
32 }
33 }
|