Biblioteca Java - Blame information for rev 31
Subversion Repositories:
(root)/Frameworks and Technologies/TestActiveMQ2/src/main/java/com/linkscreens/activemq/protocol/EchoMessageProtocol.java
Rev | Author | Line No. | Line |
---|---|---|---|
31 | mihai | 1 | package com.linkscreens.activemq.protocol; |
2 | |||
3 | /** | ||
4 | * Returning back to client a echo message. | ||
5 | */ | ||
6 | public class EchoMessageProtocol extends MessageProtocol { | ||
7 | private long id; | ||
8 | |||
9 | EchoMessageProtocol() { | ||
10 | super(ProtocolType.ECHO); | ||
11 | } | ||
12 | |||
13 | public String handleProtocolMessage(String messageText) { | ||
14 | String responseText; | ||
15 | id++; | ||
16 | System.out.println("::: Processing message "+id+" with protocol "+this.getProtocolType()); | ||
17 | responseText = "ECHO: "+messageText+" message count="+id; | ||
18 | return responseText; | ||
19 | } | ||
20 | } |