niko/weixin4j
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rename WeixinMessage of socket

Browse Source
This commit is contained in:
jinyu 2015-05-13 09:37:28 +08:00
parent 286ee4e72a
commit c579aeea1b
4 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/README.md
View File

@ -1,5 +1,5 @@
WeixinMessageDecoder:对微信消息进行解码 WeixinMessageDecoder:对微信消息进行解码
WeixinMessageEncoder:对微信消息进行编码 WeixinRequestHandler:微信请求处理类
WeixinServerHandler:微信请求处理类 WeixinResponseEncoder:对微信回复进行编码

4
weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinMessageHandler.java → weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinRequestHandler.java
View File

@ -38,7 +38,7 @@ import com.foxinmy.weixin4j.util.StringUtil;
* @since JDK 1.7 * @since JDK 1.7
* @see * @see
*/ */
public class WeixinMessageHandler extends public class WeixinRequestHandler extends
SimpleChannelInboundHandler<WeixinRequest> { SimpleChannelInboundHandler<WeixinRequest> {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
@ -46,7 +46,7 @@ public class WeixinMessageHandler extends
private final WeixinMessageDispatcher messageDispatcher; private final WeixinMessageDispatcher messageDispatcher;
private final JAXBContext jaxbContext; private final JAXBContext jaxbContext;
public WeixinMessageHandler(AesToken aesToken, public WeixinRequestHandler(AesToken aesToken,
WeixinMessageDispatcher messageDispatcher) throws WeixinException { WeixinMessageDispatcher messageDispatcher) throws WeixinException {
this.aesToken = aesToken; this.aesToken = aesToken;
this.messageDispatcher = messageDispatcher; this.messageDispatcher = messageDispatcher;

4
weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinMessageEncoder.java → weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinResponseEncoder.java
View File

@ -30,14 +30,14 @@ import com.foxinmy.weixin4j.util.StringUtil;
* @see <a * @see <a
* href="http://mp.weixin.qq.com/wiki/0/61c3a8b9d50ac74f18bdf2e54ddfc4e0.html">加密接入指引</a> * href="http://mp.weixin.qq.com/wiki/0/61c3a8b9d50ac74f18bdf2e54ddfc4e0.html">加密接入指引</a>
*/ */
public class WeixinMessageEncoder extends public class WeixinResponseEncoder extends
MessageToMessageEncoder<WeixinResponse> { MessageToMessageEncoder<WeixinResponse> {
private final Logger log = LoggerFactory.getLogger(getClass()); private final Logger log = LoggerFactory.getLogger(getClass());
private final AesToken aesToken; private final AesToken aesToken;
public WeixinMessageEncoder(AesToken aesToken) { public WeixinResponseEncoder(AesToken aesToken) {
this.aesToken = aesToken; this.aesToken = aesToken;
} }

4
weixin4j-server/src/main/java/com/foxinmy/weixin4j/socket/WeixinServerInitializer.java
View File

@ -30,7 +30,7 @@ public class WeixinServerInitializer extends ChannelInitializer<SocketChannel> {
pipeline.addLast(new HttpServerCodec()); pipeline.addLast(new HttpServerCodec());
pipeline.addLast(new HttpObjectAggregator(65536)); pipeline.addLast(new HttpObjectAggregator(65536));
pipeline.addLast(new WeixinMessageDecoder(aesToken)); pipeline.addLast(new WeixinMessageDecoder(aesToken));
pipeline.addLast(new WeixinMessageEncoder(aesToken)); pipeline.addLast(new WeixinResponseEncoder(aesToken));
pipeline.addLast(new WeixinMessageHandler(aesToken, messageDispatcher)); pipeline.addLast(new WeixinRequestHandler(aesToken, messageDispatcher));
} }
} }