cemartins

ClientManager client = AccessController.doPrivileged(new PrivilegedExceptionAction<ClientManager>() {

	@Override
	public ClientManager run() throws Exception {
		
		ThreadPoolConfig workerThreadPoolConfig = ThreadPoolConfig.defaultConfig();					
		workerThreadPoolConfig.setInitialClassLoader(this.getClass().getClassLoader());
		workerThreadPoolConfig.setDaemon(false);
		workerThreadPoolConfig.setMaxPoolSize(4);
		workerThreadPoolConfig.setCorePoolSize(3);

cemartins

private URI getServerEndpointAddress() {
	String serverEndpointStr = SERVER_URL;
	Parameters parameters = getParameters();
	if(parameters != null && parameters.getNamed().get("server-url") != null) {
		serverEndpointStr = parameters.getNamed().get("server-url");
		if(serverEndpointStr.startsWith("https"))
			serverEndpointStr = serverEndpointStr.replaceFirst("https", "wss");
		else
			serverEndpointStr = serverEndpointStr.replaceFirst("http", "ws");
		serverEndpointStr = serverEndpointStr + "/wstest";

cemartins

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
	<modelVersion>4.0.0</modelVersion>
 
	<parent>
		<groupId>org.juffrou.test</groupId>
		<artifactId>websocket-test</artifactId>
		<version>0.0.1-SNAPSHOT</version>
	</parent>
	<artifactId>websocket-server</artifactId>

cemartins

TS: ${buildTS}
<?xml version="1.0" encoding="$encoding"?>
<jnlp
    spec="$jnlpspec"
    xmlns:jfx="http://javafx.com"
    codebase="$$codebase" 
    href="$outputFile">
  <information>
  	<title>Websocket JavaFX Test</title>
    <vendor>Carlos Martins</vendor>

cemartins

@Component
public class MyEndpoint extends Endpoint {

	@Autowired
	MyService myService;
	
	@Override
	public void onOpen(Session session, EndpointConfig config) {
		
		session.addMessageHandler(new MyMessageHandler(session));

cemartins

<!-- Local connection factory that "points" to Node2's hornetq broker -->
<bean id="jmsEventsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
	<property name="jndiName" value="java:/Node2Broker" />
</bean>

<!-- Listener container to establish a durable subscrition to the EventsTopic in Node2 -->
<bean id="node2EventListenerContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
    <property name="concurrentConsumers" value="1"/>
    <property name="connectionFactory" ref="jmsEventsConnectionFactory"/>
    <property name="destinationName" value="EventsTopic"/> <!-- Note: must use this name and not "jms/topic/SunsetEventsTopic" -->

cemartins

<bean id="jmsConnectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
	<property name="jndiName">
		<value>ConnectionFactory</value>
	</property>
	<property name="resourceRef"><value>true</value></property>
</bean> 
<bean id="myBrokerSendDestination" class="org.springframework.jndi.JndiObjectFactoryBean">
      <property name="jndiName">
          <value>jms/topic/EventsTopic</value>
      </property>