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

fixed #100

Browse Source
This commit is contained in:
jinyu 2016-11-02 22:38:59 +08:00
parent d3554f0f70
commit ee2261d56a
3 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -29,7 +29,7 @@ public class WeixinServerInitializer extends ChannelInitializer<SocketChannel> {
public WeixinServerInitializer(Map<String, AesToken> aesTokenMap,
WeixinMessageDispatcher messageDispatcher) {
this.messageDispatcher = messageDispatcher;
messageDecoder = new WeixinMessageDecoder(aesTokenMap);
this.messageDecoder = new WeixinMessageDecoder(aesTokenMap);
}
public int addAesToken(final AesToken asetoken){

5
weixin4j-server/src/main/java/com/foxinmy/weixin4j/startup/WeixinServerBootstrap.java
View File

@ -95,7 +95,7 @@ public final class WeixinServerBootstrap {
*
*/
public WeixinServerBootstrap(String token) {
this(null, token, null);
this("", token, null);
}
/**
@ -163,7 +163,7 @@ public final class WeixinServerBootstrap {
for (AesToken aesToken : aesTokens) {
this.aesTokenMap.put(aesToken.getWeixinId(), aesToken);
}
this.aesTokenMap.put(null, aesTokens[0]);
this.aesTokenMap.put("", aesTokens[0]);
this.messageHandlerList = new ArrayList<WeixinMessageHandler>();
this.messageInterceptorList = new ArrayList<WeixinMessageInterceptor>();
this.messageDispatcher = new WeixinMessageDispatcher(messageMatcher);
@ -205,7 +205,6 @@ public final class WeixinServerBootstrap {
EventLoopGroup bossGroup = new NioEventLoopGroup(bossThreads);
EventLoopGroup workerGroup = new NioEventLoopGroup(workerThreads);
try {
wechatInitializer = new WeixinServerInitializer(aesTokenMap,
messageDispatcher);
ServerBootstrap b = new ServerBootstrap();

2
weixin4j-server/src/test/java/com/foxinmy/weixin4j/server/test/MessageServerStartup.java
View File

@ -167,6 +167,6 @@ public class MessageServerStartup {
* @throws Exception
*/
public static void main(String[] args) throws Exception {
new MessageServerStartup().test2();
new MessageServerStartup().test1();
}
}