Java EE 7 Features in DayTrader 7: All 13 Liberty Features

<featureManager>
    <feature>ejb-3.2</feature>
    <feature>servlet-3.1</feature>
    <feature>jsf-2.2</feature>
    <feature>jpa-2.1</feature>
    <feature>mdb-3.2</feature>
    <feature>wasJmsServer-1.0</feature>
    <feature>wasJmsClient-2.0</feature>
    <feature>cdi-1.2</feature>
    <feature>websocket-1.1</feature>
    <feature>concurrent-1.0</feature>
    <feature>jsonp-1.0</feature>
    <feature>beanValidation-1.1</feature>
    <feature>localConnector-1.0</feature>
</featureManager>

@Stateless
@TransactionAttribute(TransactionAttributeType.REQUIRED)
@TransactionManagement(TransactionManagementType.CONTAINER)
public class TradeSLSBBean implements TradeSLSBRemote, TradeSLSBLocal {
    // ...
}

@MessageDriven(activationConfig = {
    @ActivationConfigProperty(propertyName = "destinationType",
                              propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destination",
                              propertyValue = "TradeBrokerQueue") })
public class DTBroker3MDB implements MessageListener { /* ... */ }

@Singleton
public class MarketSummarySingleton {

    @Schedule(second = "*/20", minute = "*", hour = "*", persistent = false)
    private void updateMarketSummary() { /* ... */ }

    @Lock(LockType.READ)
    public MarketSummaryDataBean getMarketSummaryDataBean() { /* ... */ }
}

@PersistenceContext
private EntityManager entityManager;

// TradeActionProducer.java
public class TradeActionProducer {
    @Produces
    @RequestScoped
    public TradeAction produceTradeAction() {
        return new TradeAction();
    }
}

// ExternalContextProducer.java
public class ExternalContextProducer {
    @Produces
    @RequestScoped
    public ExternalContext produceFacesExternalContext() {
        return FacesContext.getCurrentInstance().getExternalContext();
    }
}

// DTStreamer3MDB.java — fires the event
@Inject
@WebSocketJMSMessage
Event<Message> jmsEvent;

jmsEvent.fire(message);   // inside onMessage()

// MarketSummaryWebSocket.java — observes the event
public static void onJMSMessage(@Observes @WebSocketJMSMessage Message message) {
    RecentStockChangeList.addStockChange(message);
    sendRecentQuotePriceChangeList = true;
}

// TradeSLSBBean.queueOrder() — sends to TradeBrokerQueue
try (JMSContext queueContext = queueConnectionFactory.createContext()) {
    TextMessage message = queueContext.createTextMessage();
    message.setStringProperty("command", "neworder");
    message.setIntProperty("orderID", orderID);
    message.setBooleanProperty("twoPhase", twoPhase);
    queueContext.createProducer().send(tradeBrokerQueue, message);
}

// TradeSLSBBean.publishQuotePriceChange() — sends to TradeStreamerTopic
try (JMSContext topicContext = topicConnectionFactory.createContext()) {
    TextMessage message = topicContext.createTextMessage();
    message.setStringProperty("command", "updateQuote");
    message.setStringProperty("symbol", quote.getSymbol());
    message.setStringProperty("price", quote.getPrice().toString());
    // ... additional properties ...
    topicContext.createProducer().send(tradeStreamerTopic, message);
}

@ServerEndpoint(value = "/marketsummary", decoders = ActionDecoder.class)
public class MarketSummaryWebSocket {

    @OnOpen
    public void onOpen(Session session, EndpointConfig ec) { /* ... */ }

    @OnMessage
    public void sendMarketSummary(ActionMessage message, Session currentSession) { /* ... */ }

    @OnClose
    public void onClose(Session session, CloseReason reason) { /* ... */ }

    @OnError
    public void onError(Throwable t, Session currentSession) { /* ... */ }
}

@Resource
private ManagedThreadFactory managedThreadFactory;

// In queueOrder() when mode == ASYNCH_MANAGEDTHREAD:
Thread thread = managedThreadFactory.newThread(new CompleteOrderThread(orderID, twoPhase));
thread.start();

@Resource
private ManagedScheduledExecutorService managedScheduledExecutorService;

scheduler = managedScheduledExecutorService.scheduleAtFixedRate(
    () -> { /* push stock changes */ },
    1, SCHEDULER_PERIOD, TimeUnit.SECONDS);

// MarketSummaryWebSocket.mergeJsonObjects()
JsonObjectBuilder jObjectBuilder = Json.createObjectBuilder();
// ... iterates key sets of both objects and adds to builder ...
return jObjectBuilder.build();

<messagingEngine id="defaultME">
    <queue id="TradeBrokerQueue"/>
    <topicSpace id="TradeTopicSpace"/>
</messagingEngine>

<jmsQueue id="jms/TradeBrokerQueue" jndiName="jms/TradeBrokerQueue">
    <properties.wasJms deliveryMode="NonPersistent" queueName="TradeBrokerQueue"/>
</jmsQueue>

<jmsTopic id="TradeStreamerTopic" jndiName="jms/TradeStreamerTopic">
    <properties.wasJms deliveryMode="NonPersistent" topicSpace="TradeTopicSpace"/>
</jmsTopic>