|
|
| (One intermediate revision by the same user not shown) |
| Line 1: |
Line 1: |
| ==Gorizza Stomp library==
| | #REDIRECT [[Java_Examples]] |
| | |
| This code requires the [http://www.germane-software.com/software/Java/Gozirra/ Gozirra Stomp library].
| |
| | |
| <code>
| |
| private static void go() throws Exception
| |
| {
| |
| System.out.println("Connecting");
| |
| final Client c = new Client(Constants.SERVER, Constants.PORT, Constants.USERNAME, Constants.PASSWORD);
| |
| System.out.println("Connected");
| |
| System.out.println("Subscribing");
| |
| for (final String topic : Constants.TOPICS)
| |
| {
| |
| System.out.println(" " + topic);
| |
| c.subscribe("/topic/" + topic,
| |
| new Listener()
| |
| {
| |
| public void message(Map map, String s)
| |
| {
| |
| processMessage(map, s);
| |
| }
| |
| });
| |
| }
| |
| System.out.println("done subscribing");
| |
| }
| |
| </code>
| |
