This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<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> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<!-- 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" --> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
@Component | |
public class MyEndpoint extends Endpoint { | |
@Autowired | |
MyService myService; | |
@Override | |
public void onOpen(Session session, EndpointConfig config) { | |
session.addMessageHandler(new MyMessageHandler(session)); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
<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> |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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"; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); |