1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16 package org.jboss.netty.channel;
17
18 import static org.jboss.netty.channel.Channels.*;
19
20 import java.net.SocketAddress;
21
22 import org.jboss.netty.util.internal.StringUtil;
23
24
25
26
27
28
29
30
31
32
33 public class UpstreamMessageEvent implements MessageEvent {
34
35 private final Channel channel;
36 private final Object message;
37 private final SocketAddress remoteAddress;
38
39
40
41
42 public UpstreamMessageEvent(
43 Channel channel, Object message, SocketAddress remoteAddress) {
44
45 if (channel == null) {
46 throw new NullPointerException("channel");
47 }
48 if (message == null) {
49 throw new NullPointerException("message");
50 }
51 this.channel = channel;
52 this.message = message;
53 if (remoteAddress != null) {
54 this.remoteAddress = remoteAddress;
55 } else {
56 this.remoteAddress = channel.getRemoteAddress();
57 }
58 }
59
60 public Channel getChannel() {
61 return channel;
62 }
63
64 public ChannelFuture getFuture() {
65 return succeededFuture(getChannel());
66 }
67
68 public Object getMessage() {
69 return message;
70 }
71
72 public SocketAddress getRemoteAddress() {
73 return remoteAddress;
74 }
75
76 @Override
77 public String toString() {
78 if (getRemoteAddress() == getChannel().getRemoteAddress()) {
79 return getChannel().toString() + " RECEIVED: " +
80 StringUtil.stripControlCharacters(getMessage());
81 } else {
82 return getChannel().toString() + " RECEIVED: " +
83 StringUtil.stripControlCharacters(getMessage()) + " from " +
84 getRemoteAddress();
85 }
86 }
87 }