What’s New in WildFly 8 ?

@ServerEndpoint("/chat") (1)
public class ChatEndpoint {
    @OnMessage (2)
    public void message(String message,
                        Session client) (3)
                   throws IOException, EncodeException {
        for (Session peer : client.getOpenSessions()) {
            peer.getBasicRemote().sendText(message);
        }
    }
}

<job id="myJob" xmlns="http://xmlns.jcp.org/xml/ns/javaee" version="1.0">
    <step id="myStep" >
        <chunk item-count="3"> (1)
            <reader ref="myItemReader"/> (2)
            <processor ref="myItemProcessor"/> (3)
            <writer ref="myItemWriter"/> (4)
        </chunk>
    </step>
</job>

JsonObject jsonObject = Json.createObjectBuilder() (1)
                .add("apple", "red") (2)
                .add("banana", "yellow")
                .build(); (3)
StringWriter w = new StringWriter();
JsonWriter writer = Json.createWriter(w); (4)
writer.write(jsonObject);

public class MyTask implements Runnable { (1)

    @Override
    public void run() {
        . . .
    }
}

@Resource(name = "DefaultManagedExecutorService") (2)
ManagedExecutorService defaultExecutor;

executor.submit(new MyTask()); (3)

Client client = ClientBuilder.newClient(); (1)
WebTarget target = client.target("..."); (2)
target.register(Person.class);
Person p = target
             .path("{id}") (3)
             .resolveTemplate("id", "1")
             .request(MediaType.APPLICATION_XML) (4)
             .get(Person.class); (5)

Undertow.builder() (1)
  .addListener(8080, "localhost")
  .setHandler(new HttpHandler() { (2)
    @Override
    public void handleRequest(final HttpServerExchange exchange)
      throws Exception {
      exchange.getResponseHeaders()
              .put(Headers.CONTENT_TYPE, "text/plain");
      exchange.getResponseSender()
              .send("Hello World");
    }
  }).build().start(); (3)

@JMSDestinationDefinition(name="myQueue", interfaceName="javax.jms.Queue") (1)

@Resource(mappedName="myQueue")
Queue queue; (2)

@Inject
private JMSContext context; (3)

context.createProducer().send(queue, "Hello, JMS 2.0!"); (4)

@Resource(mappedName="myQueue")
Queue queue;

@Inject
private JMSContext context;

JMSConsumer consumer = context.createConsumer(queue); (1)
String text = consumer.receiveBody(String.class, 5000); (2)
// => "Hello, JMS 2.0!"

@JMSDestinationDefinition(name="myQueue", (1)
        interfaceName="javax.jms.Queue",  (2)
        properties = { "durable=false" }  (3)
)

@JMSDestinationDefinition(name="myTopic",
        interfaceName="javax.jms.Topic"   (4)
)

@JMSConnectionFactoryDefinition(name="myFactory", (1)
        interfaceName = "javax.jms.QueueConnectionFactory", (2)
        minPoolSize = 5, (3)
        maxPoolSize = 20,
        clientId = "myclientID", (4)
        properties = { "initial-connect-attempts=5" } (5)
)

ConnectionFactory cf = (ConnectionFactory)namingContext.lookup("..."); (1)
Destination destination = (Destination)namingContext.lookup("...");

try (JMSContext context = cf.createContext(userName, password)) { (2)
  context.createProducer().send(destination, "hello");

  JMSConsumer consumer = context.createConsumer(destination); (3)
  String response = consumer.receiveBody(String.class, 5000);
}

@Inject
// @JMSConnectionFactory("java:comp/DefaultJMSConnectionFactory") (1)
@JMSConnectionFactory("myFactory") (2)
@JMSPasswordCredential(userName="guest",password="password") (3)
@JMSSessionMode(JMSContext.AUTO_ACKNOWLEDGE) (4)
private JMSContext context;

@Resource(mappedName="myTopic")
Topic topic;

@Inject
private JMSContext context;

String subscription = "...";

JMSConsumer consumer = context.createSharedConsumer(topic, subscription); (1)

context.setClientID("...");
JMSConsumer durableConsumer = context.createSharedDurableConsumer(topic, subscription); (2)

JMSProducer producer = context.createProducer()
    .setAsync(new CompletionListener() { (1)
        @Override
        public void onCompletion(Message message) { } (2)

        @Override
        public void onException(Message message, Exception exception) { } (3)
    });
producer.send(destination, "Hello, Async!"); (4)

@MessageDriven(name = "MyMDB", activationConfig = {
    @ActivationConfigProperty(propertyName = "connectionFactoryLookup", (1)
                             propertyValue = "jms/MyConnectionFactory"),
    @ActivationConfigProperty(propertyName = "destinationType",
                             propertyValue = "javax.jms.Queue"),
    @ActivationConfigProperty(propertyName = "destinationLookup", (2)
                             propertyValue = "myQueue"),
    @ActivationConfigProperty(propertyName = "acknowledgeMode",
                             propertyValue = "Auto-acknowledge") })
public class MyMDB implements MessageListener {

    public void onMessage(Message message) { ... }
}