import javax.annotation.Resource;
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.inject.Instance;
import javax.inject.Inject;
import javax.jms.JMSContext;
import javax.jms.Topic;
import javax.transaction.Transactional;

@ApplicationScoped
@Transactional
public class AppScopedBean {
	
	@Inject
	private JMSContext jmsCtx;
	//private Instance<JMSContext> jmsCtx;
	@Resource(lookup = "jms/topic/test")
	private Topic topic;
	
	public void sendMessage() {
		jmsCtx.createProducer().setDisableMessageID(true).setDisableMessageTimestamp(true).send(topic, "a message");
		//jmsCtx.get().createProducer().setDisableMessageID(true).setDisableMessageTimestamp(true).send(topic, "a message");
	}

}

import javax.annotation.Resource;
import javax.enterprise.concurrent.ManagedThreadFactory;
import javax.enterprise.context.ApplicationScoped;
import javax.enterprise.context.Dependent;
import javax.enterprise.context.Initialized;
import javax.enterprise.event.Observes;
import javax.inject.Inject;

@Dependent
public class ThreadLauncher {

	@Resource
	private ManagedThreadFactory threadFactory;
	@Inject
	private AppScopedBean bean;
	
	void start(@Observes @Initialized(ApplicationScoped.class) Object event) {
		System.out.println("starting threads");
		for (int i = 0; i < 5; i++) {
			threadFactory.newThread(new SendRunnable()).start();
		}
		System.out.println("start finished");
	}
	
	private class SendRunnable implements Runnable {

		public void run() {
			System.out.println("starting to send");
			for (int i = 0; i < 100; i++) {
				bean.sendMessage();
			}
			System.out.println("done sending");
		}
		
	}
	
}