juancavallotti

/*
 * Copyright (c) AXA Group Operations Spain S.A.
 *
 * Permission is hereby granted, free of charge, to any person obtaining
 * a copy of this software and associated documentation files (the
 * "Software"), to deal in the Software without restriction, including
 * without limitation the rights to use, copy, modify, merge, publish,
 * distribute, sublicense, and/or sell copies of the Software, and to
 * permit persons to whom the Software is furnished to do so, subject to
 * the following conditions:

juancavallotti

<?xml version="1.0" encoding="UTF-8"?>

<mule xmlns:http="http://www.mulesoft.org/schema/mule/http" xmlns:jms="http://www.mulesoft.org/schema/mule/jms" xmlns:jdbc="http://www.mulesoft.org/schema/mule/jdbc" xmlns="http://www.mulesoft.org/schema/mule/core" xmlns:doc="http://www.mulesoft.org/schema/mule/documentation" xmlns:spring="http://www.springframework.org/schema/beans" version="CE-3.3.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="
http://www.mulesoft.org/schema/mule/http http://www.mulesoft.org/schema/mule/http/current/mule-http.xsd 
http://www.mulesoft.org/schema/mule/jms http://www.mulesoft.org/schema/mule/jms/current/mule-jms.xsd 
http://www.mulesoft.org/schema/mule/jdbc http://www.mulesoft.org/schema/mule/jdbc/current/mule-jdbc.xsd 
http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-current.xsd 
http://www.mulesoft.org/schema/mule/core http://www.mulesoft.org/schema/mule/core/current/mule.xsd ">
    
    <!-- activemq con

juancavallotti

public class TestConcurrencyStability {
    
    private static final Logger logger = LoggerFactory.getLogger(TestConcurrencyStability.class);
    
    private static DTOBinder binder;
    
    @BeforeClass
    public static void globalInit() {
        binder = DTOBinderFactory.buildBinder();
    }

juancavallotti

public class ConcurrencyRule implements TestRule {
    
    private static final Logger logger = LoggerFactory.getLogger(ConcurrencyRule.class);
    
    private final int threadsSpawn;

    /**
     * Builds a concurrency test with the given number of worker threads.
     * @param threadsSpawn 
     */

juancavallotti

var ws = new WebSocket("ws://"+document.location.host+document.location.pathname+"/testWebsocket");
ws.onopen = function() {
    console.log("Websocket Ready!!");
}
ws.onmessage= function(data) {
    console.log(data.data);
}
            
function sendMessage() {
    ws.send("Test");

juancavallotti

@WebServlet(urlPatterns="/testWebsocket")
public class TestWebsocket extends WebSocketServlet {
    private static final long serialVersionUID = 1L;

    @Override
    protected StreamInbound createWebSocketInbound(String string, HttpServletRequest hsr) {
        return new MessageInbound() {

            @Override
            protected void onBinaryMessage(ByteBuffer bb) throws IOException {