- First, we create a User POJO:
public class User implements Serializable{ private Long id; private String name; public User(long id, String name){ this.id = id; this.name = name; } public Long getId() { return id; } public void setId(Long id) { this.id = id; } public String getName() { return name; } public void setName(String name) { this.name = name; } }
- Then, we create a message sender:
@Statelesspublic class Sender { @Inject private JMSContext context; @Resource(lookup = "jms/JmsQueue") private Destination queue; public void send(User user){ context.createProducer() .setDeliveryMode(DeliveryMode.PERSISTENT) .setDisableMessageID(true) .setDisableMessageTimestamp(true) .send(queue, user); } }
- Now, we create a message ...